RabbitMQ 通过官方插件 rabbitmq_delayed_message_exchange 实现延迟队列，比 TTL+DLX 方案更简洁可靠；需启用插件、声明 x-delayed-message 类型交换机，并在消息头中设置 x-delay 属性指定毫秒级延迟。
RabbitMQ 本身不原生支持延迟队列，但可以通过官方插件 rabbitmq_delayed_message_exchange 实现可靠的延迟消息投递。这是目前最推荐、最稳定的方式，比基于 TTL + 死信队列（DLX）的手动方案更简洁、语义更清晰。
安装并启用 delayed message exchange 插件
该插件是 RabbitMQ 官方维护的，从 3.6.0 版本起支持，3.8.0+ 默认已包含，但仍需手动启用：
- 确认插件存在：
rabbitmq-plugins list | grep delayed - 启用插件：
rabbitmq-plugins enable rabbitmq_delayed_message_exchange - 重启 RabbitMQ 节点（如使用 Docker 则需重启容器）
声明延迟交换机（Delayed Exchange）
启用插件后，需声明类型为 x-delayed-message 的自定义交换机，并指定 x-delayed-type（如 direct、topic 等）：
// Java（使用 Spring AMQP）
@Bean
public CustomExchange delayedExchange() {
Map<String, Object> args = new HashMap<>();
args.put("x-delayed-type", "direct");
return new CustomExchange("delayed.exchange", "x-delayed-message", true, false, args);
}
注意：该交换机不会自动创建绑定，需后续显式绑定队列。
Alibabacloud Sdk Client Initialization For Java
下载
在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。
立即学习“Java免费学习笔记（深入）”；
发送带延迟的消息
发送时通过消息属性 x-delay 指定延迟毫秒数（单位：毫秒），RabbitMQ 会暂存消息并在到期后路由到匹配队列：
// 发送延迟 5 秒的消息
MessageProperties props = new MessageProperties();
props.setDelay(5000); // 延迟 5000ms
Message message = new Message("hello".getBytes(), props);
rabbitTemplate.send("delayed.exchange", "routing.key", message);
关键点：
– x-delay 是消息级属性，每次发送可不同；
– 若未设置或设为 0，消息立即投递；
– 延迟时间过长（如数天）也支持，但建议结合业务评估内存与磁盘占用。
注意事项与常见问题
- 插件不支持集群中所有节点同时作为延迟调度器 —— 延迟消息只由声明该交换机的节点处理，因此生产环境建议配合镜像队列或高可用部署
- 延迟精度为秒级（内部基于定时器轮询），非严格毫秒级实时触发，一般误差在几十毫秒内
- 若消费者宕机或队列被删，延迟中的消息会丢失（因未落盘到目标队列），关键业务需考虑幂等与重发机制
- Spring Boot 2.4+ 中
setDelay()已废弃，应改用MessagePostProcessor设置头信息：message.getMessageProperties().setHeader("x-delay", 5000)
这套方案无需配置死信交换机、TTL、冗余队列，逻辑清晰、运维简单，是 Java 生态下 RabbitMQ 延迟队列的事实标准做法。
