rabbitmq 消费者获取不同路由键的消息

Question

我们有两个使用 c1（在 php 中）绑定到交换 1、队列 1 和路由键 1 的消费者；和 c2（在 java 中）绑定到交换 1、队列 1 和路由密钥 2。即只有路由密钥不同，但交换和队列是相同的。

在 php 中，我们做如下绑定

$channel->queue_bind($this->queue, $this->exchange, $this->routing1);

在java中，以下

channel.queueBind(queue, exchange, routing2);

现在，当我们使用路由键 2 发布用于 c2 的消息时，我们观察到消息以循环方式被 c1 和 c2 接收，而不是仅被 c2 接收。

c1 和 c2 的发件人都在 php 中，c1 的发件人执行以下操作

$channel->basic_publish($message, $this->exchange, $this->routing1);

c2 的发件人执行以下操作

$channel->basic_publish($message, $this->exchange, $this->routing2);

我们有正确的假设吗？代码有什么问题吗？

[Edit1] 作为实验，我们更改为绑定到两个消费者和发布者的单独队列。我们观察到 c2（q2 和 r2）的消息被 c2 和 c1 都收到了……这里出了点问题。

Answer 1

只有路由键不同，但交换和队列是相同的。

你已经设计了你的队列和消费者来产生这种行为。

当 RMQ 有多个消费者用于一个队列时，它会将来自该队列的消息轮询到所有可用的消费者。这是在 RMQ 中的设计 - 它允许您扩展给定队列的使用者数量，因此您可以处理大量消息。

如果您需要 C1 和 C2 接收不同的消息，而不是它们之间来自 Q1 的循环消息，那么 C1 和 C2 必须有不同的订阅队列。

例如：

通过为消费者设置单独的队列，您将保证消息到达正确的消费者