我们可以使用铲子(动态)将RMQ消息成批地移动到另一个RMQ吗？

Question

我编写了一个脚本，它使用RMQ铲子的PUT api将消息转移到另一个RMQ，但我想知道它是如何内部工作的。它会立即移动所有的消息吗？如果是的话，我们能分批移动它以优化它吗？

Answer 1

来自文档

铲子的行为就像一个写得很好的客户端应用程序，它连接到它的源和目的地，使用和重新发布消息，并在两端使用确认来处理失败。铲子是做什么的？本质上，铲子是一个极简的信息泵。每把铲子：

• 连接到源群集和目标群集。
• 使用队列中的消息。
• 重新发布到目标
• 在两端使用数据安全功能，并处理故障。

Rabbitmq发布者可以根据您的确认策略处理批量消息(请参阅出版者认可与数据安全)。

如果你想要更多的控制出版商的行为，你应该创建自己的，而不是使用铲子插件。