8

我想知道是否可以将消息从一个队列移动/合并到另一个队列。例如：

main-queue包含消息['cat-1','cat-2','cat-3','cat-4','dog-1','dog-2','cat-5']

dog-queue包含消息['dog-1, dog-2, dog-3, dog-4]

所以问题是，（假设两个队列都在同一个集群上，vhost）可以将消息从移动dog-queue到main-queueusingrabbitmqctl吗？

所以最后我希望得到类似的东西：

理想情况下：

main-queue：['cat-1','cat-2','cat-3','cat-4','dog-1','dog-2','cat-5', dog-3, dog-4]

但这也可以：

main-queue：['cat-1','cat-2','cat-3','cat-4','dog-1','dog-2','cat-5', 'dog-1, dog-2, dog-3, dog-4]

4

1 回答 1

20

您正在/正在寻找的是“铲子”插件。铲子插件内置在核心中，但您必须明确启用它。它真的很容易使用，因为它可以为您完成所有事情（无需手动消费/重新发布到另一个队列）。

通过 cli 启用铲子插件：

sudo rabbitmq-plugins enable rabbitmq_shovel

如果您通过 GUI 管理 RabbitMQ，请安装 shovel mgmt 插件：

sudo rabbitmq-plugins enable rabbitmq_shovel_management

登录到 GUI，您将在 Admin 部分下看到 Shovel Management。您可以创建铲子将消息从任何队列移动到另一个队列，甚至是远程托管的队列。您可以在完成后删除铲子，或将其留在原处，它会在消息进入时不断移动消息。

如果通过 CLI 管理 RabbitMQ，则可以直接从 rabbitmqctl 执行 shovel：

sudo rabbitmqctl set_parameter shovel cats-and-dogs \
'{"src-uri": "amqp://user:pass@host/vhost", "src-queue": "dog-queue", \
"dest-uri": "amqp://user:pass@host/vhost", "dest-queue": "main-queue"}'

官方插件文档：

铲子插件 - https://www.rabbitmq.com/shovel.html
创建铲子 - https://www.rabbitmq.com/shovel-dynamic.html

于 2014-11-08T06:55:27.020 回答