最新开源分布式定时任务调度系统
Open-Job
开源分布式任务调度系统,项目官方文档地址
?? Open-Job 介绍
??2022 最新的轻量级分布式任务调度系统
? 已实现功能点
-
定时任务基于 redis 实现,支持动态修改任务状态,同时支持拓展其他实现方式
-
客户端与服务端通信采用 Grpc,同时支持拓展其他通信方式
-
注册中心支持 Nacos、Zookeeper,同时支持拓展其他注册中心,而且支持节点动态上线下线
-
客户端集群部署支持负载均衡,默认提供了一致性hash、随机权重算法,支持多种容错机制,默认提供了失败重试、故障转移等机制,负载均衡和容错都支持拓展
-
任务监控报警能力支持
-
前后端分离,管理后台基于 antd-pro 搭建
?? 快速开始
1 搭建任务管理系统
- 下载本项目
git clone https://github.com/lijunping365/Open-Job.git
- 创建数据库表
sql 文件在 doc/open_job.sql
- 下载前端项目
git clone https://github.com/lijunping365/Open-Job-Admin.git
需安装 node.js,
- 启动服务端,启动前端项目
登录任务管理系统创建任务,之后便可以进行任务管理了
2 搭建任务执行模块
创建任务执行模块可按照项目中客户端示例工程搭建
- 在任务执行项目中加入以下依赖
org.open.job
job-starter-client
1.0-SNAPSHOT
- 创建任务执行类并实现 JobHandler
示例1
@Slf4j
@Component
public class JobHandlerOne implements JobHandler {
@Override
public String bindingJobHandlerName() {
return JobHandlerNameConstants.JOB_ONE;
}
@Override
public void handler(String params) {
log.info("JobHandlerOne 处理任务");
}
}
示例2
@Slf4j
@Component
public class JobHandlerTwo implements JobHandler {
@Override
public String bindingJobHandlerName() {
return JobHandlerNameConstants.JOB_TWO;
}
@Override
public void handler(String params) {
log.info("JobHandlerTwo 处理任务");
}
}
注意:
-
handler 方法的参数 params 为 json 字符串格式,可进行 json 序列化
-
启动后端服务端与后端客户端无先后顺序
-
详细说明请参阅官方文档:https://lijunping365.github.io/#/
?? 目前还未完成的功能
-
任务的监控功能
-
任务的报警功能
? FAQ
有问题可以提 issues,我会及时解答
??收尾
该分布式任务调度系统,是从本人之前做的一个系统中抽离出来的,开源不易,欢迎 star