测试RabbitMQ交换

Question

我正在尝试编写一个应用程序，测试将N个交换绑定到内存、IO等相同队列的效果。

所有测试都使用“主题”交换类型。我遇到的问题是，当我使用多个exchange进行测试时，我没有收到我发布回的所有消息。但是，当我使用1 exchange时，我会收到所有消息。

你知道为什么会这样吗？

谢谢

编辑：

我有一个队列，它使用相同的绑定键绑定到两个“主题”交换：

• *。系统日志#
• #。系统错误

我将向每个exchange发布两条消息，如下所示：

>

Exchange 0

• [正文]消息0[路由密钥]#.system.error
• [正文]消息1[路由密钥]*.system.log.#

Exchange 1

• [正文]消息0[路由密钥]#.system.error
• [正文]消息1[路由密钥]*.system.log.#

我有一个消费者正在监听队列，但只收到以下消息：

• 来自exchange 0的带有路由键（*.system.log.#）的邮件，邮件正文为“邮件1”

有什么想法吗？

Answer 1

我不太确定您试图通过测试来证明什么，但请记住IO和内存将是一个与队列总体大小相关的函数，而不是一个队列绑定了多少个交换。您可能会发现这篇关于使用RabbitMQ实现性能和可伸缩性的路由拓扑的博文非常有用。

无论如何，问题似乎出在您的绑定上，我可以通过使用RabbitMQ的Web管理门户来重现问题，而无需编写一行代码。

请查看此处有关主题交换的部分，但重要部分包括：

发送到主题交换的消息不能有任意routing_key——它必须是一个由点分隔的单词列表。单词可以是任何东西，但通常它们指定与消息相关的一些特征。一些有效的路由键示例：“stock.usd.nyse”、“nyse.vmw”、“quick.orange.rabbit”。路由键中可以有任意数量的单词，最多不超过255个字节。

绑定密钥的格式也必须相同。主题交换背后的逻辑类似于直接交换-使用特定路由密钥发送的消息将被传递到使用匹配绑定密钥绑定的所有队列。但是，绑定密钥有两种重要的特殊情况：

* (star) can substitute for exactly one word.
# (hash) can substitute for zero or more words.

这意味着，当您发布消息时，您应该执行系统操作。错误和系统。日志

但是，我认为您的交换绑定实际上有问题。如果您尝试使用RabbitMQ Web管理使用这些路由键发布，您会注意到您的消息实际上根本没有被路由到队列，这可以解释为什么您的消费者会收到它们...我会玩弄绑定，并使用RabbitMQ Web管理来尝试您在运行更大测试之前尝试实现的路由行为。