安装zookeeper

2.0 Zookeeper 安装配置 | 菜鸟教程

解压到本地，并创建data和logs文件夹

创建配置zoo.cfg

tickTime=2000

dataDir=C:/zookeeper-3.4.5/data

dataLogDir=C:/zookeeper-3.4.5/logs

clientPort=2181

启动

引入依赖

    com.github.kuhn-he
    elastic-job-lite-spring-boot-starter
    2.1.53

新建job类

package com.javacore.job;

import com.dangdang.ddframe.job.api.ShardingContext;
import com.dangdang.ddframe.job.api.simple.SimpleJob;
import com.dangdang.elasticjob.lite.annotation.ElasticSimpleJob;
import org.springframework.stereotype.Component;
@ElasticSimpleJob(cron = "0/5 * * * * ?",
        jobName = "firstJob",
        shardingTotalCount = 2,
        jobParameter = "测试参数",
        shardingItemParameters = "0=A,1=B")
@Component
public class MySimpleJob implements SimpleJob {

    @Override
    public void execute(ShardingContext shardingContext) {
        System.out.println(String.format("------Thread ID: %s, 任务总片数: %s, " +
                        "当前分片项: %s,当前参数: %s," +
                        "当前任务名称: %s,当前任务参数: %s," +
                        "当前任务的id: %s"
                ,
                //获取当前线程的id
                Thread.currentThread().getId(),
                //获取任务总片数
                shardingContext.getShardingTotalCount(),
                //获取当前分片项
                shardingContext.getShardingItem(),
                //获取当前的参数
                shardingContext.getShardingParameter(),
                //获取当前的任务名称
                shardingContext.getJobName(),
                //获取当前任务参数
                shardingContext.getJobParameter(),
                //获取任务的id
                shardingContext.getTaskId()
        ));
    }
}

配置job

#如果zookeeper集群的话，则以英文逗号隔开
elaticjob.zookeeper.server-lists=127.0.0.1:2181
elaticjob.zookeeper.namespace=my-project

执行结果

Corn在线表达式生成

在线Cron表达式生成器