我刚刚开始使用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中被称为什么?它通常是如何配置的? 这种做法普遍吗?我是否应该让交换器将消息路由到两个单独的队列中，只有一个消费者?
