RabbitMQ联邦交换场景下冗余队列消息堆积及自动重现问题排查

一、为何会出现两个指向不同节点的队列？ #

• 联邦配置重复或规则冗余：如果上游集群的联邦交换配置中，针对目标交换器重复添加了指向rabbitmq-1和rabbitmq-2的上游条目，或者下游集群的联邦绑定策略覆盖了多个节点，会触发上游为每个有效连接生成对应队列。
• 集群队列节点归属配置缺失：RabbitMQ队列默认仅在单个节点实例化，若联邦插件未指定队列的节点归属规则，当集群节点状态波动时，可能在不同节点上生成关联的队列实例，形成多节点队列。

二、rabbitmq-1队列消息堆积、无法处理且删除后重现的原因 #

• 下游消费者关联失效：下游集群仅显示与rabbitmq-2的连接，说明rabbitmq-1对应的联邦消费者已断开或未完成初始化，队列无消费者处理消息，导致消息持续堆积。
• 联邦插件自动重建机制：联邦交换默认会依据上游交换器的绑定规则自动创建队列，若上游的绑定策略（如通过policy配置的自动联邦绑定）未移除，手动删除队列后，插件会定期检查并重建符合规则的队列。
• rabbitmq-1节点异常：该节点可能存在网络分区、资源耗尽（CPU/内存/磁盘）或插件故障，导致队列无法接收消费者连接、无法处理消息；同时集群健康检查未清理该节点配置，联邦插件仍会尝试创建指向它的队列。

三、解决建议 #

• 清理冗余上游配置：检查上游集群的federation-upstreams配置，删除指向rabbitmq-1的无效上游条目。
• 修复下游消费者连接：在下游集群执行rabbitmqctl list_federation_consumers命令，确认消费者状态；若缺失则重新配置联邦绑定，确保消费者正确连接至目标节点。
• 排查rabbitmq-1节点健康：执行rabbitmqctl node_health_check检查节点状态，查看节点日志排查资源不足、网络异常等问题，修复后重启联邦插件。
• 调整联邦策略：移除针对rabbitmq-1队列的自动绑定规则（修改federation-policies），避免手动删除队列后被自动重建。

内容的提问来源于stack exchange，提问作者Silvan Mühlemann