GopherCron
Golang 开箱即用的分布式 crontab system
提供响应式 web 管理界面
预览
架构介绍
Gophercron 分为中心服务与边缘 agent 两部分，中心服务负责接收用户 api 请求，主要用来增删改查项目与项目下的任务，同时 api 提供一些任务临时调度、停止调度、强行结束等功能。
实际的任务调度是由边缘 agent 自身进行调度的(指定时执行)，agent 启动时会将自身节点注册进中心服务中，表示该 agent 上线运行，agent 会根据自身配置的项目向中心请求该项目下所有的任务，中心将任务列表响应给边缘，由边缘负责定时执行。
同项目多个 agent 通过与中心服务建立的长连接来进行抢锁，同一时间调度的任务，哪个 agent 拿到锁哪个 agent 来执行，拿锁行为有 5s 的最短释放周期，所以 Gophercron 最细粒度的调度间隔为 5s，同时也仅能保障机器间时钟偏差值在 5s 内才不会出现任务异常执行的情况。
API 请求下发逻辑可以参考图中 绿色线 部分。
监控面板
在线交流
Discussions Now
依赖
- Etcd # 服务注册与发现
- Mysql # 任务日志存储
引用
- Gin 提供 webapi
- gopherCronFe 提供可视化管理界面(已将构建后的文件内置于 dist/view 目录下)
- cronexpr 提供 cron 表达式解析器
- 🍉水瓜 提供服务注册发现能力
项目优势
- 分布式定时任务管理
- 任务流编排
- 响应式前端，移动端也可以轻松管理任务
实现功能
- 秒级定时任务
- 任务日志查看
- 随时结束任务进程
- 分布式扩展
- 健康节点检测 (分项目显示对应的健康节点 IP 及节点数)
- workflow 任务编排
项目构成
中心服务
- 提供定时任务 api 能力
- 提供任务管理服务端接口
- 提供 workflow 任务流编排能力
- 提供边缘任务状态与结果上报服务（日志默认存储 7 天）
- 提供服务注册与发现能力
- 为边缘节点提供分布式锁服务
- 集成即时通讯能力，任务状态变更感知更及时
边缘 agent
- 接收中心命令执行临时任务
- 实际执行定时任务的服务
- 自旋实现任务的定时执行，多副本任务通过分布式锁解决执行冲突问题