🔥🔥🔥 灵活，可靠和快速的分布式任务重试和分布式任务调度平台

✅️ 可重放，可管控、为提高分布式业务系统一致性的分布式任务重试平台

✅️ 支持秒级、可中断、可编排的高性能分布式任务调度平台

项目特性

• 易用性 业务接入成本小。避免依赖研发人员的技术水平，保障稳定性

• 灵活性 能够动态调整配置，启动 / 停止任务，以及终止运行中的任务

• 操作简单 分钟上手，支持 WEB 页面对任务数据 CRUD 操作。

• 数据大盘 实时管控系统任务数据

• 分布式重试任务 支持多样化退避策略、多样化重试类型、流量管控等

• 分布式调度任务 提供丰富的任务触发策略、任务分片、停止恢复、失败重试等

• 工作流任务编排 仿钉钉设计的流程编排引擎，支持复杂的功能编排、失败重试、告警等

• 任务数据管理 可以做到数据不丢失、数据一键回放

• 容器化部署 服务端支持 docker 容器部署

• 高性能调度平台 支持服务端节点动态扩容和缩容

• 支持多样化的告警方式 邮箱、企业微信、钉钉、飞书、自定义告警

• 支持多种流行数据库 mysql、mariadb、sqlserver、oracle、postgres 数据库

开源组件对比

更新日志

1. 增加 WebSocket 实时获取重试任务和定时任务日志【新增】

2. 重试新增OpenApi支持查询重试任务、触发、状态更新【新增】

3. 定时任务支持通过名称模糊查询【新增】

4. 死信表新增 groupId 和 sceneId 字段【新增】

5. 重试任务支持"防止任务重复拉取"配置【新增】

6. 增加重试任务列表更新时间字段【新增】

7. 回滚死信表数据时支持异常明确提示（存在重复数据）【新增】

8. 内置 HTTP 执行器支持自定义响应结果判断【新增】

9. GitHub Action 构建优化，支持 arm64 镜像 【优化】

10. 修复重试次数传播机制错误问题【BUG】

11. 修复 CVE 漏洞并移除 log4j 【BUG】

12. 修复随机等待退避策略的时间单位转换错误【BUG】

13. 重构 RPC 命名结构，方便后续扩展【优化】

14. 翻译系统中文字符串为英文【优化】

15. 新增ES、Mongo日志存储插件【新增】

16. 新增SSO登录插件【新增】

17. 优化SQL性能 【优化】

18. 修复重试序列化LocalDateTime失败问题【BUG】

19. 修复滑动窗口上报窗口时间错误【BUG】

20. 优化重试任务列表和死信列表查询按钮显示问题 【优化】

21. 重试任务列表增加更新时间 2.修复重试列表更新时间title【优化】

22. 修复场景阻塞策略错误问题【BUG】

23. 重试任务达到最大重试次数后可以手动执行【优化】

24. 优化重试列表更多按钮的下拉框样式【优化】

注意本次重点重构了重试模块的流程，由之前的同步调度客户端改为异步调度客户端. 将支持更高并发的调度同时大大提高服务端的稳定性

MYSQL变更(其他DB变更请自行同步)

全量的SQL请参考项目 /doc/sql/x.sql

alter table sj_retry_dead_letter
    add group_id bigint not null comment '组Id' after group_name;

alter table sj_retry_dead_letter
    add scene_id bigint not null comment '场景ID' after scene_name;

alter table sj_retry
    add group_id bigint not null comment '组Id' after group_name;

alter table sj_retry
    add scene_id bigint not null comment '场景ID' after scene_name;

drop index idx_namespace_id_group_name_retry_status on sj_retry;

drop index idx_namespace_id_group_name_scene_name on sj_retry;

create index idx_retry_status_bucket_index
    on sj_retry (retry_status, bucket_index);

alter table sj_retry
    drop key uk_name_task_type_idempotent_id_deleted;

alter table sj_retry
    add constraint uk_scene_tasktype_idempotentid_deleted
        unique (scene_id, task_type, idempotent_id, deleted);