RabbitMQ联邦交换机与Celery适配故障：Celery消息无法同步至备节点

核心问题 #

通过Celery发布的任务仅在主节点（节点1）排队，无法同步至备节点，但手动向celery交换机发消息、用Kombu编写的独立生产者发消息时，联邦同步均正常。

可能原因及解决步骤 #

1. 联邦配置方向错误

RabbitMQ联邦交换机的逻辑是备节点（下游）从主节点（上游）拉取消息，而非主节点主动推送。你当前在主节点配置联邦上游是错误的，需在备节点执行以下操作：

• 添加上游参数（指向主节点）：

  rabbitmqctl set_parameter federation-upstream master '{"uri":"amqps://user:password@master-hostname:5671?cacertfile=<path-to-pem>"}' -p celery_vhost
  

• 应用联邦策略，匹配celery交换机：

  rabbitmqctl set_policy exchange-federation  "^celery$" '{"federation-upstream-set":"all"}' --apply-to exchanges -p celery_vhost
  

2. Celery任务路由键未同步

Celery默认用celery路由键向celery交换机发消息，若任务配置了自定义路由键（通过CELERY_TASK_ROUTES），需确保备节点交换机有对应绑定：

• 查看主节点celery交换机的绑定关系：

  rabbitmqctl list_bindings -p celery_vhost | grep celery
  

• 在备节点手动创建相同绑定（若联邦未自动同步）：

  rabbitmqctl bind_queue celery_queue celery celery -p celery_vhost
  

  （替换celery_queue为你的实际任务队列名）

3. 联邦插件未完全启用

确保两个RabbitMQ节点都启用了联邦相关插件：

rabbitmq-plugins enable rabbitmq_federation rabbitmq_federation_management

4. Celery队列自动删除导致绑定丢失

若Celery队列设置了auto_delete=True，空闲时队列会被删除，绑定关系消失，联邦无法同步消息。修改Celery配置禁用自动删除：

# Django项目的Celery配置中添加
CELERY_TASK_QUEUES = {
    'celery': {
        'exchange': 'celery',
        'routing_key': 'celery',
        'queue_arguments': {'x-auto-delete': False},
    },
}

验证操作 #

1. 重启Celery服务，发布测试任务
2. 在备节点查看消息是否同步：

   rabbitmqctl list_queues -p celery_vhost celery_queue messages
   

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