提问者:小点点

RabbitMQ和循环主题交换


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

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

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

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

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


共1个答案

匿名用户

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

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

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