一个企业级开源分布式任务调度系统，定时调度基于时间轮算法实现，调度中心与执行器通信支持 Grpc，同时支持 Netty，执行器支持集群部署，任务分片执行，任务支持监控报警能力。

Open-Job

🔥2022 最新的轻量级分布式任务调度系统

🎨 Open-Job 介绍

项目官网地址

项目官方文档地址

✨ 已实现功能点

定时任务基于时间轮算法实现，支持动态修改任务状态，同时支持拓展其他实现方式
客户端与服务端通信采用 Grpc，同时支持 Netty
注册中心支持 Nacos、Zookeeper，同时支持拓展其他注册中心，而且支持节点动态上线下线
执行器支持集群部署，支持负载均衡，默认提供了一致性 hash、随机权重算法，支持多种容错机制，默认提供了失败重试、故障转移等机制，负载均衡和容错都支持拓展
任务监控报警能力支持
前后端分离，管理后台基于 antd-pro 搭建
支持多应用任务调度
支持调度脚本
支持前后端统一部署，代码分支为：beta
调度完成后可查看任务具体是哪个节点执行的，可在任务执行日志中查看
支持任务分片执行，解决大任务问题，大大提升任务执行效率

🍪 快速开始

1 搭建任务管理系统

下载本项目

git clone https://github.com/lijunping365/Open-Job.git

创建数据库表

sql 文件在 doc/db/open_job.sql

启动 Dashboard 服务

@EnableSecurity
@EnableScheduling
@EnableOpenRpcClient
@SpringBootApplication
public class JobDashboardApplication {

    public static void main(String[] args) {
        SpringApplication.run(JobDashboardApplication.class, args);
    }
}

启动执行器

@EnableOpenRpcServer
@SpringBootApplication
public class JobClientApplication {

    public static void main(String[] args) {
        SpringApplication.run(JobClientApplication.class, args);
    }
}

下载前端项目

git clone https://github.com/lijunping365/Open-Job-Admin.git

安装依赖

npm install

启动前端项目

npm start

2 创建 JobHandler

示例 1

@Slf4j
@JobHandler(name = "job-one")
@Component
public class OpenJobHandlerOne implements OpenJobHandler {

    @Override
    public void handler(JobParam jobParam) {
        log.info("JobHandlerOne 处理任务");
    }
}

示例 2

@Slf4j
@Component
public class OpenJobHandlerMethodOne{

    @JobHandler(name = "job-method-one1")
    public void handlerOne1(JobParam jobParam) {
        log.info("JobHandlerOne 处理任务, 任务参数 {}", jobParam.getParams());
    }

    @JobHandler(name = "job-method-one2")
    public void handlerOne2(JobParam jobParam) {
        log.info("JobHandlerOne 处理任务, 任务参数 {}", jobParam.getParams());
    }
}

❓ FAQ

有问题可以提 issues，我会及时解答

Contributing

欢迎参与项目贡献！比如提交 PR 修复一个 bug，或者新建 Issue 讨论新特性或者变更。

Copyright and License

产品开源免费，并且将持续提供免费的社区技术支持。个人或企业内部可自由的接入和使用。如有需要可邮件联系作者免费获取项目授权。

Licensed under the Apache License v2.0.

🎉 收尾

欢迎大家的关注和使用，欢迎 star，本项目将持续更新
欢迎接入的公司在登记地址登记，登记仅仅为了产品推广。

PreviousOpen-Authority Next模型演进