首页 > 编程语言 > 详细

SpringBoot 快速集成 Elastic Job

时间:2019-05-26 11:34:11      阅读:308      评论:0      收藏:0      [点我收藏+]

 

一、引入依赖

<dependency>
    <groupId>com.github.kuhn-he</groupId>
    <artifactId>elastic-job-lite-spring-boot-starter</artifactId>
    <version>2.1.53</version>
</dependency>

 

二、配置Elastic Job

#elastic-job
elaticjob.zookeeper.server-lists=127.0.0.1:2181
elaticjob.zookeeper.namespace=bounter-job

 

三、开发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;
        }
    }
}

 

四、启动SpringBoot应用,观察控制台输出

 

这就是所有步骤了,是不是很简单哉!那就赶快自己试试吧!
 
需要源代码的见Github传送门:

SpringBoot 快速集成 Elastic Job

原文:https://www.cnblogs.com/gdufs/p/10925420.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!