任务注册中心(registry)

registry是任务注册中心,在整个生态圈内担任着各个组件注册节点的任务,任务注册中心实现方式是多样化的,目前包含:memory、zookeeper、redis、consul等。

通过idea、eclipse工具创建SpringBoot项目并添加如下依赖到pom.xml文件内。

com.github.hengboyspring-boot-starter-registry-memory{lastVersion}

在resources资源目录下添加application.yml配置文件,配置内容如下所示:

server: port: 9000hengboy: job: registry: # 任务注册中心节点注册方式 away: memory

任务调度器(schedule)

schedule是任务调度器,每一个任务的创建都是通过调度器进行分配执行,分配过程中根据消费节点的负载均衡策略配置进行不同消费者节点任务消费。

在生产任务时,也会根据调度器的负载均衡策略来进行筛选执行任务调度的调度器节点。

通过idea、eclipse工具创建SpringBoot项目并添加如下依赖到pom.xml文件内。

com.github.hengboy spring-boot-starter-schedule {lastVersion}

在resources资源目录下添加application.yml配置文件,配置内容如下所示:

server: port: 8081hengboy: job: registry: # 保持与任务注册中心节点注册方式一致即可 away: memory schedule: # 内存方式调度器处理任务队列以及任务日志的存储 job-store-type: memory 

任务消费节点(consumer)

consumer是任务消费者执行节点,任务由consumer进行定义以及上报,当schedule调用消费者执行任务请求时,会自动根据jobKey来执行对应的任务逻辑方法。

通过idea、eclipse工具创建SpringBoot项目并添加如下依赖到pom.xml文件内。

com.github.hengboyspring-boot-starter-consumer{lastVersion}

在resources资源目录下添加application.yml配置文件,配置内容如下所示:

server: port: 8082hengboy: job: registry: # 保持与任务注册中心节点注册方式一致即可 away: memory

任务定义示例

我们来定义一个简单的Job,示例如下所示:

@Job(jobExecuteAway = JobExecuteAwayEnum.ONCE)public class TestJob implements MicroJob { /** * logger instance */ static Logger logger = LoggerFactory.getLogger(TestJob.class); @Override public JobExecuteResult execute(JobExecuteParam jobExecuteParam) throws JobException { logger.info("执行Key:{},执行参数:{}

plsql job执行多个存储过程_spring-boot-micro-job一款分布式任务调度执行框架相关推荐

  1. docker启动后自动退出_Spring Boot项目启动后如何自动执行逻辑

    1. 前言 不知道你有没有接到这种需求,项目启动后立马执行一些逻辑.比如简单的缓存预热,或者上线后的广播之类等等.如果你使用 Spring Boot 框架的话就可以借助其提供的接口CommandLin ...

  2. @scheduled 执行一次_Spring Boot 定时任务 @Scheduled

    项目开发中经常需要执行一些定时任务,比如在每天凌晨,需要从 implala 数据库拉取产品功能活跃数据,分析处理后存入到 MySQL 数据库中.类似这样的需求还有许多,那么怎么去实现定时任务呢,有以下 ...

  3. js等待异步执行完再执行_Spring Boot 之异步执行方法

    前言: 最近的时候遇到一个需求,就是当服务器接到请求并不需要任务执行完成才返回结果,可以立即返回结果,让任务异步的去执行.开始考虑是直接启一个新的线程去执行任务或者把任务提交到一个线程池去执行,这两种 ...

  4. springboot map数据类型注入_Spring Boot(五):春眠不觉晓,Mybatis知多少

    在JavaWeb项目开发中,我们使用最多的ORM框架可能就是Mybatis了,那么对于常用的mybatis,你究竟了解多少呢? 一 全局了解 1 Mybatis是什么 MyBatis 是支持定制化 S ...

  5. springboot 优雅停机_Spring Boot 2.3 新特性优雅停机详解

    什么是优雅停机 先来一段简单的代码,如下: @RestControllerpublic class DemoController { @GetMapping("/demo") pu ...

  6. springboot事务回滚源码_Spring Boot中的事务是如何实现的

    1. 概述 一直在用SpringBoot中的@Transactional来做事务管理,但是很少想过SpringBoot是如何实现事务管理的,今天从源码入手,看看@Transactional是如何实现事 ...

  7. springboot 事务手动回滚_Spring Boot中的事务是如何实现的

    1. 概述 一直在用SpringBoot中的@Transactional来做事务管理,但是很少想过SpringBoot是如何实现事务管理的,今天从源码入手,看看@Transactional是如何实现事 ...

  8. SQL查询语句执行速度快,存储过程执行慢

    今天一个生成10w条数据的存储过程执行了95s,但是单独执行SQL语句只需要28s,查资料后发现原来这是存储过程的机制导致的,也就是传说中的参数嗅探 网上的一段话: (1)可能是发生了参数嗅探,第一次 ...

  9. springboot日志可视化_spring boot面试问题集锦

    击上方"码农突围",马上关注,每天早上8:50准时推送 真爱,请置顶或星标 译文作者:david  原文链接:https://www.javainuse.com/spring/Sp ...

最新文章

  1. 自动驾驶系统关系与自动泊车原理
  2. 【每日一算法】1比特与2比特字符
  3. String[] arrayIP= null;的典型错误
  4. 网络通讯程序整理(一)
  5. MaxCompute 实现增量数据推送(全量比对增量逻辑)
  6. php可逆加密解密函数,php 好用可逆的 加密解密 函数。
  7. 关于vs2015每次打开都要配置opencv问题
  8. 利用cad计算型材的弹性模量_3米高广告牌钢结构设计计算书(最后附CAD图纸)
  9. c语言竞赛信息管理系统,一种基于ACM程序设计竞赛在线评测系统解决方案
  10. MarkDown编辑器设置图片大小
  11. 中考英语听说计算机考试成绩查询,中考英语听说考试成绩查询
  12. Android Studio生成keystore签名文件
  13. 云服务器怎么配置cpu与内存搭配
  14. ARM裸机-13.LCD
  15. 性价比降噪耳机:NANK南卡降噪耳机和小米降噪耳机买哪个好?
  16. Micro SD 卡(TF卡) spi 模式实现方法
  17. 线性代数常用基本知识整理
  18. Java课程设计:考勤管理系统(附源码+调试)
  19. Java: Tomcat到底是干嘛的?
  20. 网站如何添加php模板文件路径,Dede网站怎么修改模板路径

热门文章

  1. 【JavaScript】实现将从Excel中复制的数据粘贴到WEB页面Grid中
  2. 一个列用render渲染的时候,如果列宽度不够,内容多出的部分会被隐藏,无法显示。这时需要一个鼠标滑过提示全部内容的tip功能。...
  3. Java中BigDecimal解决精度丢失问题
  4. php7.0支持调用lua脚本
  5. yaf框架学习文件配置
  6. 利用Linux命令行进行文本按行去重并按重复次数排序yes
  7. c语言实验答案周信东第三章,桂林电子科技大学C语言程序设计习题答案周信东实验顺序结构与逻辑运算.pdf...
  8. 宝塔面板搭载ThinkPHP5.0项目关于open_basedir报错解决办法
  9. java 设置panel背景图片_jpanel设置背景图片的二个小例子
  10. 抽屉开关_技术天地|380伏抽屉开关指示灯更换流程