延迟队列框架
框架整合了多种延迟任务实现方式,提供开箱即用的延迟队列:
- carp-framework-queue-kekio。迁移 spinnaker 中 orca 服务的 kekio 延迟队列。orca 相关依赖使用 springboot 2.7x,与 carp 使用的 springboot 3.3x 依赖存在兼容问题,无法直接加入 kekio 依赖至 pom.xml 中使用,需迁移过来
在 Java 生态中存在多种延迟任务解决方案:
- RocketMQ。在 5.0 版本中,延迟时间取消了固定值,可设置任意时间,但延迟时间不能超过 24 小时。4.x 版本支持 18 个延迟级别。参考:定时/延时消息
- Kafka。Kafka 并不支持延迟消息,但是用户可以参照 RocketMQ 实现延迟消息思路,实现 Kafka 版本的固定间隔延迟消息功能
- Pulsar。参考:Delayed message delivery
- Redis。基于 Redis 实现延迟队列
- 基于Spring Boot实现redis延迟队列
- redisson。参考:Delayed Queue
- Spring Boot + Redission 自定义分布式延时任务组件设计
- tql-delayqueue。延迟消息框架,延迟消息支持秒级精度、消息高可靠性、水平扩展,底层基于redisson实现
- redeq。
- delay-queue
- 有赞延迟队列设计
- redis-delay-queue
- DelayingQueue
- rqueue
- camellia
- orca。或者 spinnaker
- lmstfy
- conductor