<dependency>

    <groupId>com.github.kuhn-he</groupId>

    <artifactId>elastic-job-lite-spring-boot-starter</artifactId>

    <version>2.1.53</version>

</dependency>

#elastic-job

elaticjob.zookeeper.server-lists=127.0.0.1:2181

elaticjob.zookeeper.namespace=bounter-job

package cn.bounter.job.elasticjob;

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;

//Job configuration annotation

@ElasticSimpleJob(cron="*/3 * * * * ?", shardingTotalCount=2)

@Component

public class AppJob implements SimpleJob {

    @Override

    public void execute(ShardingContext shardingContext) {

        switch (shardingContext.getShardingItem()) {

            case 0:

                System.out.println("hello from shard 0");

                break;

            case 1:

                System.out.println("hello from shard 1");

                break;

        }

    }

}