RabbitMQ和循环主题交换

Question

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

我试着用循环系统的方法来交换话题。每个使用者都有自己的（唯一的）命名队列连接到主题交换。我希望交换为“相同”主题循环消息到每个使用者队列-比如*.log。

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

为了清楚起见，我还有一个扇出交换，我用它来“控制”消费者（启动、停止等）。这应该在任何结果中都保持在适当的位置。

任何关于如何最好地实现所述结果的指导都是很好的。

Answer 1

每个使用者都有自己的（唯一的）命名队列连接到主题交换

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

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