我刚刚开始使用RabbitMQ和AMQP。

我有一个消息队列 我有多个消费者,我希望用相同的消息做不同的事情。

大多数RabbitMQ文档似乎都关注于循环,即单个消息由单个消费者消费,负载分布在每个消费者之间。这确实是我亲眼所见的行为。

举个例子:生产者只有一个队列,每2秒发送一次消息:

var amqp = require('amqp');
var connection = amqp.createConnection({ host: "localhost", port: 5672 });
var count = 1;

connection.on('ready', function () {
  var sendMessage = function(connection, queue_name, payload) {
    var encoded_payload = JSON.stringify(payload);  
    connection.publish(queue_name, encoded_payload);
  }

  setInterval( function() {    
    var test_message = 'TEST '+count
    sendMessage(connection, "my_queue_name", test_message)  
    count += 1;
  }, 2000) 


})

这是一位消费者:

var amqp = require('amqp');
var connection = amqp.createConnection({ host: "localhost", port: 5672 });
connection.on('ready', function () {
  connection.queue("my_queue_name", function(queue){
    queue.bind('#'); 
    queue.subscribe(function (message) {
      var encoded_payload = unescape(message.data)
      var payload = JSON.parse(encoded_payload)
      console.log('Recieved a message:')
      console.log(payload)
    })
  })
})

如果我启动消费者两次,我可以看到每个消费者都在循环行为中使用备用消息。例如,我将在一个终端上看到消息1,3,5,在另一个终端上看到消息2,4,6。

我的问题是:

我能让每个消费者收到相同的消息吗?也就是说,两个消费者都得到消息1,2,3,4,5,6 ?这在AMQP/RabbitMQ中被称为什么?它通常是如何配置的? 这种做法普遍吗?我是否应该让交换器将消息路由到两个单独的队列中,只有一个消费者?


当前回答

是的,每个消费者都可以收到相同的消息。看一看 http://www.rabbitmq.com/tutorials/tutorial-three-python.html http://www.rabbitmq.com/tutorials/tutorial-four-python.html http://www.rabbitmq.com/tutorials/tutorial-five-python.html

用于路由消息的不同方法。我知道他们是python和java,但它很好地理解原则,决定你在做什么,然后找到如何在JS中做到这一点。听起来好像您想要做一个简单的扇出(教程3),它将消息发送到连接到交换机的所有队列。

你正在做的和你想做的之间的区别基本上是你要设置和交换或输入扇出。扇出交换机将所有消息发送到所有连接的队列。每个队列都有一个消费者,该消费者可以单独访问所有消息。

是的,这是很常见的,这是AMPQ的特点之一。

其他回答

如果你碰巧像我一样使用amqplib库,他们有一个发布/订阅RabbitMQ教程的实现示例,你可能会觉得很方便。

请阅读rabbitmq教程。你发布消息是为了交换,而不是为了排队;然后将其路由到适当的队列。在本例中,您应该为每个消费者绑定单独的队列。这样,它们就可以完全独立地使用消息。

据我评估,你的情况是

我有一个消息队列(您接收消息的源,让它命名为q111) 我有多个消费者,我希望用相同的消息做不同的事情。

这里的问题是,当这个队列接收到3个消息时,消息1被消费者a消费,其他消费者B和C消费消息2和3。当你需要一个设置,让rabbitmq同时将这三个消息(1,2,3)的相同副本传递给所有连接的消费者(a,B,C)。

虽然可以通过许多配置来实现这一点,但简单的方法是使用以下两步概念:

使用动态rabbitmq-shovel从所需队列(q111)提取消息并发布到扇出交换机(专门为此目的创建和专用的交换机)。 现在重新配置你的消费者A,B和C(他们正在监听队列(q111)),直接使用每个消费者的排他和匿名队列从这个Fanout交换机监听。

注意:当使用这个概念时,不要直接从源队列(q111)消费,因为已经消费的消息不会被移到你的Fanout交换机。

如果您认为这不能满足您的具体要求……欢迎发表你的建议:-)

发送模式是一对一的关系。如果你想“发送”给多个接收者,你应该使用“发布/订阅”模式。详情见http://www.rabbitmq.com/tutorials/tutorial-three-python.html。

我认为你应该检查一下用扇出交换器发送信息。这样你就会收到不同消费者的相同消息,在表下面,RabbitMQ正在为每个新的消费者/订阅者创建不同的队列。

这是javascript教程示例的链接 https://www.rabbitmq.com/tutorials/tutorial-one-javascript.html