0
点赞
收藏
分享

微信扫一扫

RocketMQ怎么实现延时消息的?

简单,八个字: 临时存储+ 定时任务。

Broker收到延时消息了,会先发送到主题(SCHEDULE_TOPIC_XXXX)的相应时间段的Message Queue中,然后通过一个定时任务轮询这些队列,到期后,把消息投递到目标Topic的队列中,然后消费者就可以正常消费这些消息。

RocketMQ怎么实现延时消息的?_时间段

举报

相关推荐

RocketMq实现延时队列

0 条评论