六、RocketMQ消息定时消息
- DelayLV:共有18档次,0到17,每个LV对应一个consumeQueue。时间间隔配置在broker.conf,messageDelayLevel,默认值1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h,空格分割,支持4种时间单位:s、m、h、d。
- ScheduleMessageService线程,启动时候给所有的延迟级别(delayLV)创建一个调度任务,每个延迟级别其实对应SCHEDULE_ TOPIC_XXXX主题下的一个消息消费队列。每个调度任务初次延迟1s执行。
- 某个调度任务执行时,若从consumeQueue取到数据后,且未到投递时间,则更新延迟队列定时拉取进度并创建新定时任务(延迟间隔投递时间)待下一次继续尝试;若到投递时间,则投递3号消息,并更新延迟队列定时拉取进度并创建新定时任务(延迟1s)。