VB.net 2010 视频教程 VB.net 2010 视频教程 python基础视频教程
SQL Server 2008 视频教程 c#入门经典教程 Visual Basic从门到精通视频教程
当前位置:
首页 > 编程开发 > Java教程 >
  • rocketmq实现延迟队列精确到秒级实现方案2-时间轮和delay-file实现

上图是通过RocketMQ源码分析一个实现原理方案示意图。

分为两个部分:

消息的写入
消息的Schedule

在写入CommitLog之前,如果是延迟消息,按照每10分钟写入delayfile文件,对于快到时间执行的,直接写入时间轮,并且写入delayfile
,时间轮每秒钟执行,如果时间到了,就执行队列中的任务,写入commitlog文件中,commitlog会自动写入 comsumqueue中,然后客户端就能消费到了。

为什么delayfile文件保存10分钟的数据呢,考虑到时间轮不能太多任务在里面,保存10分钟内的数据,也不会占用太多的内存

 

开源rocketmq延迟队列实现: 

https://gitee.com/venus-suite/rocketmq-with-delivery-time.git

出处:https://www.cnblogs.com/tomj2ee/p/15815157.html


相关教程