我有一个由 3 个 RabbitMQ 节点组成的集群，我希望在所有节点之间保持主队列平衡，即使在节点重新启动后也是如此。尽管如此，当新节点加入集群或其中一个节点断开连接并重新连接时，主队列不会重新平衡。
示例：我在节点 A、B 和 C 上创建了 100 个队列。
如果节点 C 关闭，来自 C 的主队列在节点 A 和 B 之间几乎相等地重新平衡。因此，此时，节点 A 和 B 都有大约 50 个主队列。
现在，如果我重新连接节点 C，它将保留 0 个主队列，直到创建新队列。这是有问题的，因为我希望我的所有节点都产生相同数量的工作。
我的交换是持久的，我的队列是持久的和镜像的，我的消息是持久的。我想避免丢失消息。
我知道有一种方法可以change the master node manually using a policy trick。但这并不令人满意，因为它破坏了 HA（通过引起所有镜像的重新同步）。
【问题讨论】：
你可以使用这个命令：
rabbitmq-queues rebalance type --vhost-pattern pattern --queue-pattern pattern
例如
rabbitmq-queues rebalance "all" --vhost-pattern "a-vhost" --queue-pattern ".*"
【讨论】：
一种解决方案是使用Federated Queues。
联合队列链接到其他队列（称为上游队列）。它将从上游队列中检索消息以满足本地消费者对消息的需求。
您可以在原始集群的上游和下游创建一个全新的集群。您还需要确保发布者和消费者定期重新连接（以避免一个集群垄断所有连接，从而破坏负载平衡）。
正如你所指出的，rabbitmq-users 组还有 Simon MacMullen 的把戏。
# rabbitmqctl set_policy --apply-to queues --priority 100 my-queue '^my-queue$' '{"ha-mode":"nodes", "ha-params":["rabbit@master-node"]}'
# rabbitmqctl clear_policy my-queue
但它具有使镜像暂时失去同步的不良副作用。这可能是可以接受的，也可能不是，取决于您的要求，所以我认为这是可能的。
4.x 中可能会出现更高级的技术，但完全不确定。
【讨论】：
queue-master-locator strategy ; Michael Klishin's hint for improvements in 4.x（抱歉，我不得不将其作为单独的评论发布，因为我缺乏每个答案发布超过 2 个链接的声誉）