DisJob 是一个基于Quartz、Netty、ZooKeeper的分布式rpc调度job框架，是目前业内极少使用tcp协议来做异步RPC调度的框架，因为基于tcp协议，所以支持多语言，多语言系统间定时调用非常方便。在整个集团有java版本和php版本，支撑着数十个团队，数万个job的运行。目前只开源java版本。容易要支持PHP或者python等版本，只需要根据协议写服务端代码即可。支持多语言
项目是16年本人主导从0到1研发而成，当时参考了当当的esjob（当时elasticJob刚刚展露头脚）的调度模型和新浪微博开源的服务框架motan的服务发现。
由于历史原因项目被作者删除，代码在作者的另外一个账号上:https://github.com/chunfengchui/disjob
disjob分布式任务调度概述
公司现有定时任务（job）有10w+，基于crontab实现分散于很多系统中，有时会发生故障，原因有多种，job执行过程中本身发生故障，系统进程挂 掉，系统所在服务器宕机；对于需要执行几个小时的大型job没有分片功能，或者不能非常方便的分片。因此disjob调度中心是为解决这些问题而设计，初步计 划要实现的功能如下：
1、防单点故障：业务系统的单点故障以及调度中心本身的单点故障
应用服务器必须要两台及以上才能防单点故障
2、job本身发生故障时可通过邮件/短信通知相关人员
3、job执行进程僵死时，可通过job管理平台kill进程
4、对于无状态任务，可提供并发执行功能，对于有状态任务，严格按照先后顺序执行，且不会重复执行
5、提供web管理平台，将所有定时任务集中管理，可手动提交、停止任务、设置任务执行的频率
停止任务、设置任务频率均要在下次任务执行时才能生效，也就是说正在执行的任务不能停止，设置的新的执行频率也不会即时生效
6、提供任务监控功能，即时生成任务执行进度报告
7、任务执行发生异常时的异常信息，可以在后台job执行明细中查看
8、大型任务的分片功能，每个分片执行特定参数的job。
你们需要做的:
1、基于RPC（远程过程调用或者说远程方法调用）框架提供定时任务接口，框架和基础方法我们提供，方便快捷
2、使用我们提供的网络API给调度中心发送日志消息，会一定程度侵入业务代码，只增加代码，不会改变原有代码的逻辑
目前该项目上线后支持数万个Job，数十个项目在线调度，还在不断的有项目接入。disjob客户端是java，目前有java服务端和php服务端，开源部分是java服务端和客户端。经过压测，三台4核云主机能支持几千个20秒内随机周期job并发运行，无延迟。
一个事件通知模式的基础公共模块，在disjob的服务端和客户端代码中都有引入该模块。
一个基于无阻塞队列的线程池顺序调度公共模块，线程池执行完队列中一个任务继续有序的执行下一个任务。在disjob 的服务端和客户端代码中都有引入该模块。
服务端发布job只需要引入该包，实现相应的接口，配置zk地址和节点信息，启动服务即可将job发布到zk上并启动netty服务接收客户端的定时调用。
disjob客户端公共模块
disjob客户端的监控模块，disjob服务端的进度信息以及任务接收、任务开始执行、执行结束时间传给monitor模块保存进db中
disjob客户端的rpc模块，rpc通信以及任务调度是通过该模块执行的
disjob客户端的注册模块，zk的监听，选主等都是在该模块中进行的
disjob 后台管理模块，在后台对job进行管理、监控、登陆等都是通过该模块
服务端接入disjob的例子，实际步骤就是引入disjob-jar然后按照要求配置并实现接口接口
<dependency><br/>
<groupId>com.disJob</groupId><br/>
<artifactId>Disjob-jar</artifactId><br/>
<version>1.0.0</version><br/>
我们先构造disjob的服务端（被调用方），先用最简单的普通java接入方式做例子：
#please tall me where is the zookeeper server host
zk.host=127.0.0.1:2181
#start the server listener on the port,if the port has occupancy then change the port
server.port=9501
#where is the job class inside the packages
job.packages=com.huangyiming.job.pack;
@JobDec(group="alarm",jobName="alarmJob1",quartz="0/10 * * * * ?",fireNow=true)
public class AlarmJobAction implements EJob{
@Override
public void execute(SchedulerParam schedulerParam)throws TaskExecuteException {
DebugInfoPrintUtil.debug("D:/"+this.getClass().getSimpleName()+"_.log", this.getClass().getSimpleName()+ " at:"+TimeUtils.getFormatNow());
}
@Override
public void beforeExecute(SchedulerParam schedulerParam) {
}
@Override
public void executeSuccess(SchedulerParam schedulerParam) {
}
@Override
public void executeFail(SchedulerParam schedulerParam) {
}
}
public class FireNowMain {
public static void main(String[] args) {
String path = "E:/workspace/disjob/EjobJavaApp/src/main/resources/META-INF/ejob.properties";
new EjobBootstrap().startUpEjob(EjobConstants.StartUpType.JAVA_APPLICATION, path);
}
}
如pom的profiles标签中有三种环境可配置,根据实际环境在指定路径配置conf文件，如在 D:/conf/Disjob路径下放入 disjob.zip 中的jdbc.properties等文件。
最后对DisJob的pom文件 所在路径下执行mvn clean package install -Ppublish -X(这里是执行publish环境)
