【RocketMQ每日一问】RocketMQ延迟消息是怎么实现的?

2023-12-27 18:51:43
  1. 生产者发送消息时带上延迟级别。
  2. Broker接收消息并根据延迟级别存储在特定的延迟队列中。（SCHEDULE_TOPIC_XXXX）
  3. 定时任务（时间轮里的任务）定期扫描延迟队列，将到期的消息转移到正常的消费队列。
  4. 消费者从正常的消费队列中获取并消费消息。

文章来源:https://blog.csdn.net/jianjun_fei/article/details/135248824
本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。