micro-job- 分布式任务调度框架

micro-job- 分布式任务调度框架

快速开始

micro-job是一款分布式任务调度执行框架，内部通过各个组件的Jersey共享出的Rest路径进行数据访问。

名词解释：consumer -> 任务消费节点schedule -> 任务调度器provider -> 任务生产者registry -> 任务注册中心

任务注册中心（registry）

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

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

com.github.hengboy spring-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.hengboy spring-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：{}，执行参数：{}", jobExecuteParam.getJobKey(), jobExecuteParam.getjsonParam()); return JobExecuteResult.JOB_EXECUTE_SUCCESS; }}

在上面定义的Job对应的JobKey为testJob.

任务生产节点（provider）

provider是任务生产节点，由业务方进行添加依赖并执行MicroJobProvider.newXxxJob调用创建任务，如：创建订单后执行发送邮件通知操作。

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

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

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

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

任务执行示例

@RunWith(SpringRunner.class)@SpringBootTestpublic class ProviderTester { /** * 注册任务提供者 */ @Autowired private MicroJobProvider microJobProvider; @Test public void newJob() { // 创建的任务仅执行一次 microJobProvider.newOnceJob(OnceJobWrapper.Context() // 对应consumer内定义任务的jobKey，默认为类名首字母小写 .jobKey("testJob") // 自定义的任务队列key，可以准确定位任务并操作暂停、删除等操作 .jobQueueKey(UUID.randomUUID().toString()) // 参数，任意类型参数，consumer消费时会转换为json字符串 .param(new HashMap() { { put("name", "admin"); } }) .wrapper()); }}

测试流程

启动任务注册中心启动任务调度中心启动任务消费者节点执行ProviderTester#newJob单元测试方法

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。