如何在RabbitMQ中实现多个用户订阅同一主题并获取同一消息

Question

首先，我知道这里已经有一个类似问题的答案了，但我仍然不能确定这是因为RabbitMQ的不可能，还是因为我研究得不够。

我来自事件pub/sub模式是这样工作的JS/Node背景：当许多消费者用pub/sub模式订阅同一个主题时，无论何时某个生产者发布它，所有人都应该得到相同的消息。

我希望用消息代理实现相同的模式。

例如：

生产者%1发布到主题“request.user.add”

生产者2发布到主题“request.user.detail”

RabbitMQ的实际操作（根据这个关于主题的RabbitMQ示例）

使用者3获得这两条消息，而使用者1或使用者2获得第一条消息，并且只有其中一条获得第二条消息。

我期望实现的

其中三个人同时收到两条信息。

您有没有想法用消息代理（RabbitMQ处于最优先级）来实现这一点？如果我在我的问题中遗漏了什么或不清楚的地方，请指出来。

使用解决方案编辑：

感谢@CantSleepNow，下面是我在他的提示后为消费者1和消费者2提供的代码(NodeJS):

var amqp = require('amqplib/callback_api');

amqp.connect('amqp://localhost', (err, conn) => {
  conn.createChannel((err, ch) => {
    var ex = 'topic_exchange'; // Exchange name    
    ch.assertExchange(ex, 'topic'); // Exchange with 'topic' type    
    ch.assertQueue('', {exclusive: true}, (err, q) => {
      ch.bindQueue(q.queue, ex, 'request.user.#'); // Topic pattern
      ch.consume(q.queue, (msg) => {
        // Process message
      });
    });
  });
});

Answer 1

我希望实现的东西
其中三个得到了这两个消息。

好吧，只需使用主题exchange并让每个使用者用适当的路由密钥声明它自己的队列。

当您发布时，您正在使用（例如）'request.user.add'发布到主题交换（我们称之为E1)，并且所有绑定到具有匹配路由密钥的E1的队列（因为我们在这里讨论的是主题）都将获得该消息。

嗯，我不使用javascript，但我会尝试帮助：）在exclusive中，您是说只有一个使用者可以连接到队列，这是可以的。另外，如果您在每个使用者中创建一个具有唯一名称的队列，您将获得几乎相同的结果（明显的区别是允许其他使用者使用它），在JS中也不知道，但是应该有一种方法，您可以创建一个具有给定名称的队列，或者让服务器返回名称给您。另外，看起来也可以，您只需要测试它。