Java实现RabbitMQ延迟消息（无需DelayedMessage插件、不阻塞线程）

以下方案均基于RabbitMQ原生能力实现，无需安装DelayedMessage插件，也不会阻塞业务线程：

1. 死信队列(DLX) + 消息TTL 方案 #

这是目前最通用的替代方案，核心利用RabbitMQ原生的消息过期机制和死信路由能力实现延迟效果：

• 声明两类队列：第一类是临时TTL队列，不需要配置消费者，声明时指定参数x-dead-letter-exchange（绑定死信交换机）、x-dead-letter-routing-key（绑定死信路由键），可以按需求设置队列全局x-message-ttl属性，或者发送消息时单独指定消息的expiration参数作为延迟时间；第二类是业务消费队列，和死信交换机绑定，消费者正常监听这个队列即可。
• 消息发送时先发到临时TTL队列，等消息达到设置的过期时间后，会被RabbitMQ自动投递到死信交换机，最终路由到业务消费队列被消费者处理，天然实现延迟效果。
• 注意：不要将不同TTL的消息放到同一个临时队列，RabbitMQ是按队列顺序判定消息过期的，队首消息未过期时，队后已到期的消息也不会被提前投递，多延迟时长场景需要拆分多个独立的临时TTL队列。

2. 惰性队列 + 定时任务扫描方案 #

适合延迟时间跨度大、延迟档位不固定的场景：

• 声明一个专门的延迟存储惰性队列，发送延迟消息时在消息属性中携带expected_exec_time（期望执行时间戳），消息直接发到这个队列。
• 消费侧不实时监听该队列，而是用非阻塞的定时任务（比如每10秒执行一次），拉取队列中expected_exec_time小于等于当前时间的消息，投递到业务消费队列处理。
• 惰性队列默认将消息落盘存储，不会占用过多内存，可支撑百万级以上的延迟消息堆积，拉取时可以通过basic.get控制单次拉取量，避免压力过大。

3. 优先级队列模拟分层延迟方案 #

仅适合延迟档位固定且数量较少（一般≤5档）的轻量场景：

• 声明带优先级的队列，每个优先级对应一个固定延迟档位，比如优先级1对应延迟5分钟、优先级2对应延迟15分钟。
• 发送消息时按延迟需求设置对应优先级，消费侧从高优先级到低优先级拉取消息，拉取后校验消息的期望执行时间，未到时间的消息调用basic.nack并设置requeue=true放回队列即可。

4. 客户端非阻塞定时调度方案 #

适合消息量小、客户端可靠性有保障的场景：

• 发送消息前先将消息内容、目标队列、期望发送时间持久化到本地磁盘或者分布式KV存储（如Redis），用客户端自带的非阻塞定时调度能力（比如Java的ScheduledThreadPool、Go的time.AfterFunc）触发发送逻辑，到点后再将消息正常投递到RabbitMQ业务队列。
• 注意不要用Thread.sleep这类阻塞线程的实现，客户端重启后需要重新加载未发送的延迟消息，避免消息丢失。

内容的提问来源于stack exchange，提问作者Jacob McCall