我们有一个配置了三个节点的 RabbitMQ 集群。每个节点都有两个虚拟主机(Vhost-A 和 Vhost-B)。我们需要一种将消息从 Vhost-A 移动到 Vhost-B 的可能性。为此,我们设置了一个铲子,将消息从 Vhost-A 上的 Exchange-1 引导到 Vhost-B 上的 Exchange-2。
rabbitmqctl -p Vhost-A set_parameter shovel shovel-exchange-1-to-vhost-b /
'{"src-uri": "amqp://user@/Vhost-A", "src-exchange": "Exchange-1", /
"src-exchange-key": "#", "dest-uri": "amqp://user@/Vhost-B", /
"dest-exchange": "Exchange-2", "add-forward-headers": false, /
"ack-mode": "on-confirm", "delete-after": "never"}'
这具有在目标 Exchange-2 上复制邮件的副作用。意思是,我们绑定到 Vhost-B 上的 Exchange-2 的测试队列三次收到相同的消息(每个集群节点一次)。
我们怎样才能防止这种情况发生?是否需要更改铲子配置或集群配置?
RabbitMQ 版本:3.6.15
更新 1:
我们有两个无法删除的独占队列,因为它们被锁定了。一旦我们在所有集群节点上禁用铲子插件,这些队列就会消失。一旦我们在一个节点上重新激活插件,就会再次创建队列。