RocketMQ延迟消息原理图
2020-09-25 14:58:11 0 举报延迟消息原理
作者其他创作
大纲/内容
修改消息的topic为SCHEDULE_TOPIC_XXX，计算投递时间：消息存储时间(storeTimestamp) + 延迟级别对应的时间
broker
拉取
commitLog
是
重新投递消息
consumer
存入CosumeQueue
存入对应延迟队列
异步线程
是否延迟消息
发送消息
解析消息，还原topic
否
producer
定时任务处理到达投递时间的消息
收藏
0 条评论
下一页
