Go操作RabbitMQ direct交换机路由键不匹配仍收消息问题咨询

业务场景 #

基于Go语言对接RabbitMQ实现实时评论、点赞通知功能：用户B对用户A的帖子产生评论/点赞操作时，向用户A的客户端实时推送「有新互动」的通知。

核心实现代码 #

生产者端 #

• 声明direct类型持久化交换机：
  err = channel.ExchangeDeclare("realtime", "direct", true, false, false, false, nil)
• 发布消息，指定路由键为like-key：
  err = channel.Publish("realtime", "like-key", false, false, message)

消费者端 #

• 声明持久化队列，队列名与交换机同名均为realtime：
  q, err := channel.QueueDeclare("realtime", true, false, false, false, nil)
• 绑定队列到交换机，指定绑定路由键为zxcv：
  err = channel.QueueBind(queueName, "zxcv", "realtime", false, nil)

异常现象 #

生产者发送消息使用的路由键like-key，与消费者绑定队列使用的路由键zxcv完全不匹配，但消费者依然能从队列中接收到消息。

根因说明 #

该问题是持久化资源的旧绑定关系残留导致，完全符合RabbitMQ的路由逻辑，不属于框架bug：

1. 代码中声明的交换机、队列均开启了持久化配置（ExchangeDeclare、QueueDeclare的第三个参数均传了true），这类资源的元数据（包含交换机和队列之间的绑定规则）会被RabbitMQ持久化存储，不会因为客户端断开重连、服务重启自动删除。
2. 前期调试代码时，你大概率曾经执行过将realtime队列通过like-key路由键绑定到realtime交换机的操作，这条绑定规则一直留存在RabbitMQ元数据中没有被清理。
3. RabbitMQ的QueueBind方法只会给队列新增绑定规则，不会覆盖、删除队列上已经存在的旧绑定规则。当前realtime队列实际上同时绑定了like-key、zxcv两个路由键，只要生产者发送的消息路由键命中任意一个绑定规则，消息就会被投递到该队列，消费者自然能收到消息。
4. 额外注意：当前代码给交换机和队列设置了完全相同的名称，调试排查时很容易混淆资源，建议队列名按照业务维度命名（例如用户通知类队列可命名为user_notify_{userID}），不要与交换机重名。

验证与修复 #

• 验证：打开RabbitMQ管理面板，找到名为realtime的交换机，查看其下的所有绑定关系，就能看到残留的like-key绑定规则。
• 修复：
  • 调试阶段可直接删除持久化交换机、队列，重新运行代码即可自动清理所有残留绑定。
  • 生产环境不要随意删除持久化资源，通过管理面板或API手动删除无效的旧绑定规则即可。

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