分类：延迟消息

2021
10-12

RocketMQ-延迟消息的处理流程介绍

概述RocketMQ支持发送延迟消息，但不支持任意时间的延迟消息的设置，仅支持内置预设值的延迟时间间隔的延迟消息；预设值的延迟时间间隔为：1s、5s、10s、30s、1m、2m、3m、4m、5m、6m、7m、8m、9m、10m、20m、30m、1h、2h；在消息创建的时候，调用setDelayTimeLevel(intlevel)方法设置延迟时间；broker在接收到延迟消息的时候会把对应延迟级别的消息先存储到对应的延迟队列中，等延迟消息时间到达时，会把消... 继续阅读 >