博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
elasticjob 当当的分布式定时任务管理
阅读量:4684 次
发布时间:2019-06-09

本文共 1712 字,大约阅读时间需要 5 分钟。

elasticjob官网:

https://blog.csdn.net/a13627210064/article/details/81201800

https://www.jianshu.com/p/8411504c53a3

https://blog.csdn.net/yangliuhbhd/article/details/80902212

 

一 管理平台安装

1.在github  

上导入项目到本地

 

 2.http://localhost:8899/# 访问默认的端口

 

3. 注册中心 zk 安装配置上 

注意:命名空间一定是配置定时任务中命名的一致

 

 

 

4. 可以看到相应的作业任务 

 

 

二 项目中配置定时任务

1.pom添加依赖

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

2.yml 中配置参数

elaticjob:  zookeeper:    server-lists: localhost:2181    namespace: my-project-name

 

3.建一个任务类 LateInfoTask

@Slf4j@Component//springboot整合主要就是注解了。这里指定一下相关配偶。服务链接到zk上。 控制台配置之后就看得到啦,之后也可以在控制台上手动修改一些相关配置@ElasticSimpleJob(cron = "0/3 * * * * ? *", jobName = "lateInfoTask", shardingTotalCount = 2, jobParameter = "测试参数", shardingItemParameters = "0=A,1=B")public class LateInfoTask implements SimpleJob {    @Autowired    private UserService userService;    @Override    public void execute(ShardingContext shardingContext) {        List
allUser = userService.findAllUser(1, 10); for (User user : allUser) { log.info("对象:{}", user); } System.out.println(new Date() + " job名称 = " + shardingContext.getJobName() + "分片数量" + shardingContext.getShardingTotalCount() + "当前分区" + shardingContext.getShardingItem() + "当前分区名称" + shardingContext.getShardingParameter() + "当前自定义参数" + shardingContext.getJobParameter() + "============start=================");// 原文:https://blog.csdn.net/u013018994/article/details/76212229 }}

 

 

 

后期整理 cloud 相关的 job .......

转载于:https://www.cnblogs.com/qinls/p/10478833.html

你可能感兴趣的文章
win7-64 mysql的安装
查看>>
dcm4chee 修改默认(0002,0013) ImplementationVersionName
查看>>
maven3在eclipse3.4.2中创建java web项目
查看>>
发布时间 sql语句
查看>>
黑马程序员 ExecuteReader执行查询
查看>>
记一些从数学和程序设计中体会到的思想
查看>>
题目1462:两船载物问题
查看>>
POJ 2378 Tree Cutting(树形DP,水)
查看>>
第二冲刺阶段个人博客5
查看>>
UVA 116 Unidirectional TSP (白书dp)
查看>>
第三方测速工具
查看>>
MySQL 网络访问连接
查看>>
在aws ec2上使用root用户登录
查看>>
数据访问 投票习题
查看>>
CIO知识储备
查看>>
cnblog!i'm coming!
查看>>
使用点符号代替溢出的文本
查看>>
Axios 中文说明
查看>>
fatal: remote origin already exists.
查看>>
gridview 自定义value值
查看>>