rabbitmq - RabbitMQ 和轮询主题交流

Question

我正在寻求一些关于如何最好地配置我的 rabbitMQ 交换的建议。

我正在尝试在循环方法中使用主题交换。每个消费者都有自己的（唯一的）命名队列附加到主题交换。我希望交换轮询消息到每个消费者队列的“相同”主题 -*.log比如说。

我尝试了多种组合，但似乎只能同时将消息传递到消费者队列，这实际上意味着我要处理消息两次，每个消费者一次。

为了清楚起见，我还有一个扇出交换，我用它来“控制”消费者（开始、停止等）。这应该在任何结果中保持不变。

任何关于如何最好地实现既定结果的指导都会很棒。

Answer 1

每个消费者都有自己的（唯一的）命名队列附加到主题交换

诀窍是让您想要在其之间循环的每个工作人员/消费者设置一个命名队列，并且都使用相同的队列而不是创建自己的队列。

因此，您可以为所有“日志”工作人员创建一个名为“日志”的命名队列。您将为所有“foo”工作人员创建一个不同的命名队列，例如“foo”。请求将循环传递给查看同一队列的所有消费者。