代码拉取完成，页面将自动刷新
Hodor是一个专注于任务调度以及任务编排的一站式分布式任务调度系统。
通过提供任务编程API和接口协议， 方便支持用户使用不同的编程语言实现任务执行以及自定义任务类型的扩展，以满足各种业务场景下的任务执行。
支持多种接入方式，支持Java SDK包方式、Java Agent独立进程方式接入，以及兼容XXLJob框架、Spring Task框架任务无缝接入。
多语言执行器实现，计划支持Go或者Rust语言执行器（正在设计与开发中）的接入，满足在资源有限的执行器节点执行，比如物联网场景下面的定时任务执行。
支持丰富的任务类型，除了支持普通的Java、脚本任务的执行，也支持了大数据任务Hadoop、Spark、Flink、Kettle等主流任务的执行，满足用户的不同场景。
详细文档请查阅：https://www.yuque.com/tomgs/hodor
项目结构：
hodor-scheduler
├─docs # 文档存放位置
├─hodor-actuator # hodor任务执行器
│ ├─hodor-actuator-api # 执行器扩展接口
│ ├─hodor-actuator-java # jar包方式任务执行器
│ ├─hodor-actuator-agent # 独立进程方式任务执行器
│ ├─hodor-actuator-xxljob # 支持xxl-job执行器
│ └─hodor-actuator-springtask # 支持spring task执行器
├─hodor-admin # hodor管理控制台（TODO）
├─hodor-client # 提供与hodor server的交互sdk
├─hodor-common # hodor公共依赖
├─hodor-core # hodor核心业务
├─hodor-examples # hodor测试用例
├─hodor-cache # hodor扩展
│ ├─hodor-cache-local # 基于本地内存的缓存
│ ├─hodor-cache-embedded # 基于embedded的分布式缓存
│ └─hodor-cache-redis # 基于redis的分布式缓存
├─hodor-model # hodor公共数据模型
├─hodor-storage # hodor storage模块，任务资源管理
├─hodor-register # hodor注册中心
│ ├─hodor-register-api
│ ├─hodor-register-embedded # 基于Raft实现注册中心
│ └─hodor-register-zookeeper # 基于zk实现注册中心
├─hodor-remoting # hodor通信框架
│ ├─hodor-remoting-api
│ └─hodor-remoting-netty
├─hodor-scheduler # hodor调度器实现
│ ├─hodor-scheduler-api
│ └─hodor-scheduler-quartz
└─hodor-server # hodor调度服务
详细参考 执行器操作指南
详细demo代码参考 hodor-examples/hodor-actuator-java-example 模块
普通java任务
@Job(group = "testGroup", jobName = "test1", cron = "0/30 * * * * ?")
public String test1(JobExecutionContext context) {
log.info("Job [testGroup#test1] execute, context: {}", context);
JobLogger logger = context.getJobLogger();
logger.info("start executor job test1");
logger.info("job argument: {}", context.getJobParameter());
logger.info("executing......");
logger.info("executed");
return "a=123";
}
动态分片任务
// 任务动态切分
@Job(command = "splitStage")
public List<ShardData> split(JobExecutionContext context) {
ShardData shardData = ShardData.builder().id(0).params("hello").build();
ShardData shardData1 = ShardData.builder().id(1).params("world").build();
return Lists.newArrayList(shardData, shardData1);
}
// 任务并行执行
@Job(command = "parallelJob")
public String parallelJob(JobExecutionContext context) {
log.info("Job [parallelJob] execute, context: {}", context);
JobLogger logger = context.getJobLogger();
final ShardData parentJobData = context.getParentJobData(ShardData.class);
logger.info("start executor job parallelJob, parentJobData: {}", parentJobData);
log.info("start executor job parallelJob, parentJobData: {}", parentJobData);
return "a=123";
}
// 任务汇总执行
@Job(command = "reduceJob2")
public void reduceJob(JobExecutionContext context) {
log.info("Job [reduceJob] execute, context: {}", context);
JobLogger logger = context.getJobLogger();
logger.info("job argument: {}", context.getJobParameter());
logger.info("executed");
logger.info("Job [reduceJob] execute, context: {}", context);
logger.info("Job [reduceJob] execute, results {}", context.getParentJobExecuteResults()
);
logger.info("Job [reduceJob] execute, statues {}", context.getParentJobExecuteStatuses());
}
详细demo代码参考 hodor-examples/hodor-actuator-xxljob-example 模块
/**
* 1、简单任务示例（Bean模式）
*/
@XxlJob("demoJobHandler")
public void demoJobHandler() throws Exception {
XxlJobHelper.log("XXL-JOB, Hello World.");
for (int i = 0; i < 5; i++) {
XxlJobHelper.log("beat at:" + i);
TimeUnit.SECONDS.sleep(2);
}
// default success
}
/**
* 2、分片广播任务
*/
@XxlJob("shardingJobHandler")
public void shardingJobHandler() throws Exception {
// 分片参数
int shardIndex = XxlJobHelper.getShardIndex();
int shardTotal = XxlJobHelper.getShardTotal();
XxlJobHelper.log("分片参数：当前分片序号 = {}, 总分片数 = {}", shardIndex, shardTotal);
// 业务逻辑
for (int i = 0; i < shardTotal; i++) {
if (i == shardIndex) {
XxlJobHelper.log("第 {} 片, 命中分片开始处理", i);
} else {
XxlJobHelper.log("第 {} 片, 忽略", i);
}
}
}
详细demo代码参考 hodor-examples/hodor-actuator-springtask-example 模块
@Scheduled(fixedRate = 3000)
public void task1() throws InterruptedException {
TimeUnit.SECONDS.sleep(2);
System.out.println("执行 fixedRate 任务的时间：" + new Date(System.currentTimeMillis()));
}
@Scheduled(fixedDelay = 4000)
public void task2() throws InterruptedException {
TimeUnit.SECONDS.sleep(2);
System.out.println("执行 fixedDelay 任务的时间：" + new Date(System.currentTimeMillis()));
}
@Scheduled(cron = "0/5 * * * * ?")
public void task3() {
System.out.println("执行 cron 任务的时间：" + new Date(System.currentTimeMillis()));
}
详细参考 执行器操作指南 中的agent方式的使用。
详细参考 安装部署操作指南
目前，Hodor仍处于建设的过程中，团队成员只能抽出空闲时间投入其中，主要精力还是放在日常工作中。 如果有兴趣的同学想要参与Hodor的实现或者一起学习，欢迎通过微信联系我们，我们非常欢迎新的成员加入！
Hodor的未来发展方向包括以下几个方面：
Wechat：(备注：Hodor)
此处可能存在不合适展示的内容，页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容，可点击提交进行申诉，我们将尽快为您处理。
1. 开源生态
2. 协作、人、软件
3. 评估模型