基于redis实现可靠的延时队列

基于redis实现可靠的延时队列 源码地址,欢迎star 调度流程图 整体实现要点 seata保证业务和消息的一致性 后续可以将消息和业务放到微服务本地库,使用本地事务即可保证一致性 load模块 基于定时任务加载消息库消息到内存 应用启动时基于检查点进行消息加载 checkpoint机制保证获取较新故障恢复点,结合消息状态减少重复投递 定时预加载与及时入库结合,保证消息投递及时性和中转效率 po
相关文章
相关标签/搜索