RabbitMQ 和round robin 主题交流

Question

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

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

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

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

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

Answer 1

Each consumer has its own (uniquely) named queue attached to a topic exchange

诀窍是让您希望在设置命名队列之间循环的每个 worker /消费者都使用相同的队列而不是创建自己的队列。

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