RabbitMQ延迟消息必须使用x-delayed-message类型Exchange并启用rabbitmq_delayed_message_exchange插件，声明时需指定x-delayed-type参数，发送端通过headers["x-delay"]（uint32毫秒）设置延迟，消费者按常规绑定队列接收。
延迟消息必须用 x-delayed-message 类型的 Exchange
普通 exchange 不支持延迟，rabbitmq 延迟功能依赖官方插件 rabbitmq_delayed_message_exchange，且必须声明为 exchange_type = "x-delayed-message"。如果误用 "direct" 或 "topic"，即使设置了 x-delay header，消息也会立刻投递，不会延迟。
声明时还需显式传入 arguments：map[string]interface{}{"x-delayed-type": "direct"}（或 "topic"），否则插件无法识别该 Exchange 为延迟类型。
- 插件未启用时，声明会报错：
channel.ExchangeDeclare: Exception (503) Reason: "command invalid when feature not enabled" - Exchange 名字不能带点号（
.）或下划线（_）开头，某些旧版插件对命名敏感 - 建议在启动时用
channel.ExchangeDeclarePassive验证 Exchange 是否已存在且类型正确
发送端必须通过 header 设置 x-delay，不能用 properties.Delay
Go 客户端 streadway/amqp 的 amqp.Publishing 结构体里没有 Delay 字段，properties.Delay 是 AMQP 0.9.1 协议里不存在的字段——它根本不会被序列化进 wire 协议。真正起作用的是 header 中的 "x-delay"，类型必须是 uint32（毫秒），不是字符串、不是 int64。
常见错误是写成 headers: map[string]interface{}{"x-delay": "5000"} 或 {"x-delay": int64(5000)}，这会导致 RabbitMQ 忽略该 header，消息立即路由。
- 正确写法：
headers: map[string]interface{}{"x-delay": uint32(5000)} - 如果延迟值来自变量，注意强制类型转换：
uint32(delayMs)，Go 不自动转换 - 最大延迟值受插件配置限制，默认上限是 86400000（24 小时），超限会触发 channel 关闭并报错：
PRECONDITION_FAILED - x-delay must be a non-negative integer
消费者无需特殊处理，但需注意队列绑定方式
延迟消息最终仍会进入普通队列，消费逻辑和普通消息完全一致。关键在于：队列必须通过 channel.QueueBind 绑定到那个 x-delayed-message 类型的 Exchange，并指定 routing key（如果 Exchange 类型是 direct）或 binding key（如果是 topic）。
RabbitMQ 4.2.3 是 2026 年初发布的重要稳定更新版本，重点修复了 Khepri 元数据存储相关问题，并改进了监控性能。对于使用 Docker、Kubernetes 或微服务架构的开发团队来说，该版本兼容性和稳定性表现较好。
不能指望“延迟消息自动落到某个默认队列”——它和普通消息一样遵循 Exchange → Queue 的绑定规则。如果绑定遗漏或 routing key 不匹配，消息会被丢弃（除非配置了 alternate exchange）。
- 绑定示例：
channel.QueueBind("my.queue", "my.key", "delayed.exchange", false, nil) - 确保队列已声明且 durable=true，否则重启后绑定丢失，延迟消息可能进 dead letter 或直接消失
- 如果使用死信队列做兜底，注意延迟消息本身也可能触发 TTL 过期，导致重复进入 DLX；应避免在延迟 Exchange 和 DLX 之间形成循环
完整可运行的最小发送代码片段
以下是最简可用的发送逻辑，不含重连、日志、context 超时等增强，聚焦核心路径。所有 amqp. 调用后应检查 error，此处省略以保简洁，但生产环境不可省。
conn, _ := amqp.Dial("amqp://guest:guest@localhost:5672/")
ch, _ := conn.Channel()
<p>// 声明延迟 Exchange
ch.ExchangeDeclare(
"delayed.exchange",
"x-delayed-message",
true, // durable
false, // delete when unused
false, // internal
false, // no-wait
amqp.Table{"x-delayed-type": "direct"},
)</p><p>// 发送延迟消息
err := ch.Publish(
"delayed.exchange", // exchange
"test.route", // routing key
false, // mandatory
false, // immediate
amqp.Publishing{
Headers: map[string]interface{}{"x-delay": uint32(3000)},
ContentType: "text/plain",
Body: []byte("hello delayed"),
},
)
真正容易漏的是插件启用状态和 Exchange 类型声明——这两步出错，后面全白搭。调试时优先确认 rabbitmq-plugins list | grep delayed 输出是否含 [E*]，再用 rabbitmqctl list_exchanges 看目标 Exchange 的 Type 列是否为 x-delayed-message。
