前段时间写了一篇《自研分布式任务调度框架 Revolver 第一版》，这算是一个Demo版本，真正应用到项目中时，确实需要做一些调整。经过一段时间的调整、自测、与同事讨论，第一版已提测，在项目中验证，现在应该正式的介绍一下这个分布式任务调度平台 xxx（内部名字）核心之 revolver。revolver 是左轮手枪的意思，很多有定时功能的框架中都有「时间轮」的设计，比如 xxl-job、Kafka，设计巧妙，非常适用于定时或者延迟任务，revolver 也使用了时间轮。选择一个既简单又具有代表含义的名字，我想到了左轮手枪，形象相似，时间轮用来放任务，左轮用来放子弹。

01. 基本设计

基本设计

revolver 不同于 xxl-job、elasticJob 这些常规的任务调度平台，不需要独立部署，不需要后台注册，使用生产者、消费者模式，DB 作为中间媒介，自动注册自动消费。生产者、消费者可以分属于不同的服务，生产者指定执行任务的服务。

02. 为什么要做这个

做了 ToB 业务才知道，维护各种不同的版本、各种不同的环境真麻烦，常规的后台注册式任务管理，使用起来也会不方便，具备自动注册、自动消费能力的任务调度更合适，类似于 MQ 和 任务调度平台的结合。

非常适合在某个条件下，自动注册一个定时单次、有限次（无限次）的定时重复任务，这种场景 MQ 和 任务调度平台都不太合适。

03. 特点

• 使用简单

生产者调用 producer client 即可，消费者需要启动消费者调度，使用方式类似于 Spring Kafka。

# API 注册
RevolverProducer.produceFixed(FixedTask fixedTask)

# 也提供注解注册，类似于使用 @Transcational
@FixedRegister(handler = "taskHandler", delayTime = 5L)

# 消费者启动
RevolverConsumer.start();

# 消费者需要实现 ITaskHandler 接口
@Component("taskHandler")
public class TaskHandler implements ITaskHandler {
}

• 动态分片

提交上来的任务，会分配到任务较少机器上，均衡利用集群资源。

• 故障转移

任务节点故障时，由注册中心通知其他可用节点，leader 从故障节点撤出任务，提交给分片任务。

• 去中心化

leader 节点承担故障转移、分片功能，不承担调度，只要分片之后，每个节点都是独立调度自己的任务。

• 线程安全

一个任务只会在一台机器执行，不会出现多机并发问题，也不会出现单机并发调度。

• 性能保证

内存时间轮队列 + 阻塞通知机制，实现高效调度，在没有任务时，也不会出现空轮询。

之前netty空轮询造成 cpu 彪高

原因：若Selector的轮询结果为空，没有阻塞、通知机制，不断轮询，使得CPU使用率100%

Netty4解决：加入了阻塞机制。

如果持续的时间大于等于timeoutMillis，说明就是一次有效的轮询，重置selectCnt标志，否则，表明该阻塞方法并没有阻塞这么长时间，可能触发了jdk的空轮询bug，当空轮询的次数超过一个阀值的时候，默认是512，就开始重建selector

xxl-job 其实也存在空轮询问题，虽然一秒钟一次影响不明显，在已经有这么多优秀的调度框架的前提自研，前期必然要注意一些。

• 线程池隔离

为减少任务之间的影响，采用执行线程池隔离，线程池数可配置，提供不同的线程池选择策略。

03. 短期规划

总体方向是 MQ模式 与 平台化管理相结合，可能会支持数据调度，自动化、平台化、多元化。

近期规划，支持平台化、报警、运行日志等等。

公众号：看起来很美（kanqilaihenmei_）