Go 项目中使用 RabbitMQ 延迟插件发送延迟消息的完整手写代码示例

RabbitMQ延迟消息必须使用x-delayed-message类型Exchange并启用rabbitmq_delayed_message_exchange插件，声明时需指定x-delayed-type参数，发送端通过headers["x-delay"]（uint32毫秒）设置延迟，消费者按常规绑定队列接收。 延迟消息必须用 x-delayed-message 类型的 Exchange 普通 exchange 不支持延迟， rabbitmq 延迟功能依赖官方插件 ，且必须声明为 。如果误用 或 ，即使设置了 header，消息也会立刻投递，不会延迟。 声明时还需显式传入 ： （或 ），否则插件无法识别该 Exchange 为延迟类型。 插件未启用时，声明会报错： Exchange 名字不能带点号（ ）或下划线（ ）开头，某些旧版插件对命名敏感 建议在启动时用 验证 Exchange 是否已存在且类型正确 发送端必须通过 header 设置 x-delay，不能用 properties.Delay Go 客户端 的 结构体里没有 字段， 是 AMQP 0.9.1 协议里不存在的字段——它根本不会被序列化进 wire 协议。真正起作用的是 header 中的 ，类型必须是 （毫秒），不是字符串、不是 int64。 常见错误是写成 或 ，这会导致 RabbitMQ 忽略该 header，消息立即路由。 正确写法： 如果延迟值来自变量，注意强制类型转换： ，Go 不自动转换 最大延迟值受插件配置限制，默认上限是 86400000（24 小时），超限会触发 channel 关闭并报错： 消费者无需特殊处理，但需注意队列绑定方式 延迟消息最终仍会进入普通队列，消费逻辑和普通消息完全一致。关键在于：队列必须通过 绑定到那个 类型的 Exchange，并指定 routing key（如果 Exchange 类型是 ）或 binding key（如果是 ）。 go语言参考手册 中文CHM版 Go 是一个开源的编程语言，它能让构造简单、可靠且高效的软件变得容易。本文给大家带来Go参考手册，需要的可以来下载！ Go是从2007年末由Robert Griesemer, Rob Pike, Ken Thompson主持开发，后来还加入了Ian Lance Taylor, Russ Cox等人，并最终于2009年11月开源，在2012年早些时候发布了Go 1稳定版本。现在Go的开发已经是完全开放的，并且拥有一个活跃的社区。 Go 语言特色 简洁、快速、安全 并行、有趣、开源 内存管理、v数组安全、编译 下载 不能指望“延迟消息自动落到某个默认队列”——它和普通消息一样遵循 Exchange → Queue 的绑定规则。如果绑定遗漏或 routing key 不匹配，消息会被丢弃（除非配置了 alternate exchange）。 绑定示例： 确保队列已声明且 durable=true，否则重启后绑定丢失，延迟消息可能进 dead letter 或直接消失 如果使用死信队列做兜底，注意延迟消息本身也可能触发 TTL 过期，导致重复进入 DLX；应避免在延迟 Exchange 和 DLX 之间形成循环 完整可运行的最小发送代码片段 以下是最简可用的发送逻辑，不含重连、日志、context 超时等增强，聚焦核心路径。所有 调用后应检查 error，此处省略以保简洁，但生产环境不可省。 真正容易漏的是插件启用状态和 Exchange 类型声明——这两步出错，后面全白搭。调试时优先确认 输出是否含 ，再用 看目标 Exchange 的 Type 列是否为 。