RabbitMQ原生不支持延迟队列，需通过TTL+DLX组合或rabbitmq-delayed-message-exchange插件实现：前者需配置x-message-ttl、x-dead-letter-exchange和x-dead-letter-routing-key三参数并绑定DLX，后者需启用插件并使用x-delay头。
Go 语言本身没有内置延迟队列能力，RabbitMQ 也**不原生支持 Delayed Message Exchange**（除非启用 rabbitmq-delayed-message-exchange 插件），直接调用 publish 设置 expiration 只能控制消息 TTL，且无法精准调度——这是初学者最容易卡住的地方。
为什么 RabbitMQ 的 expiration 不等于延迟队列
设置消息级 expiration（如 amqp.Publishing{Expiration: "5000"}）会让消息在进入队列后 5 秒未被消费就进死信队列，但前提是队列必须已存在、消费者未拉取，且该值对已入队消息不可动态修改。更关键的是：它不能让消息“准时唤醒”，只是被动淘汰。
- 消息发到空队列后立刻开始倒计时，哪怕消费者还没启动
- 多个不同延迟时间的消息混在一个队列里，早到期的会被阻塞在队头（AMQP 是 FIFO）
- 没有回调或重试机制，超时即丢弃，无法二次路由
用死信交换机（DLX）模拟延迟队列的实操要点
这是最稳定、无需插件、兼容所有 RabbitMQ 版本的方案：把“延迟”拆成“先入 TTL 队列 → 到期自动转 DLX → 再路由到业务队列”。核心在于交换机和队列的绑定关系设计。
- 声明一个专用 TTL 队列，设置
x-message-ttl（单位毫秒）和x-dead-letter-exchange（指向你的业务交换机） - 该队列**不能绑定任何消费者**，只负责“睡够时间”
- 业务交换机需提前绑定真实业务队列，且 routing key 必须与 DLX 转发时一致（通常设为
""或显式指定） - 发送消息时，必须发到 TTL 队列所绑定的交换机，而不是直连队列；否则 DLX 不触发
示例关键参数：
立即学习“go语言免费学习笔记（深入）”；
args := amqp.Table{
"x-message-ttl": 30000,
"x-dead-letter-exchange": "my_app_exchange",
"x-dead-letter-routing-key": "process_order",
}
ch.QueueDeclare("delay_queue_30s", false, false, false, false, args)
Go 客户端发送延迟消息时的常见错误
用 streadway/amqp 发送时，容易忽略 AMQP 协议层与 RabbitMQ 实现的细节差异，导致消息“发了但没延迟”或“直接消失”。
- 误把
expiration当成全局延迟时间：它只对当前消息生效，且单位是字符串（如"60000"），不是 int - 忘记设置
deliveryMode: amqp.Persistent—— 非持久化消息在 broker 重启后丢失，TTL 无意义 - 在未开启手动确认（
ch.Qos(1, 0, false)）时启用了预取，导致死信转发后消费者收不到（因 prefetch 占位） - 使用
ch.Publish()时 exchange 名写错，或 routing key 与 DLX 绑定不匹配，消息进黑洞
插件方案：rabbitmq-delayed-message-exchange 的取舍
启用该插件后，可直接声明 delayed 类型交换机，用 x-delay header 控制延迟，代码更简洁，但引入运维复杂度。
- 必须由管理员在所有节点启用并重启，K8s 环境需改 ConfigMap + 滚动更新
- 延迟精度受 broker 负载影响，高并发下可能偏差 100–200ms
- Go 发送时只需加 header：
amqp.Publishing{Headers: amqp.Table{"x-delay": 10000}}，但要确保 exchange 类型是delayed - 不建议开发环境直接依赖——本地 Docker 启动时容易漏掉插件挂载步骤
真正需要精确到秒级调度、且能掌控 RabbitMQ 运维权限时再上，否则 DLX 方案更可控。
