Tag: node amqp

RabbitMQ / AMQP:单个队列,多个消费者相同的消息?

一般来说,我只是开始使用RabbitMQ和AMQP。 我有一个消息队列 我有多个消费者,我想用同样的信息做不同的事情。 大部分的RabbitMQ文档似乎都集中在循环法(round-robin)上,也就是单个消费者消费单个消息的情况,负载分散在每个消费者之间。 这确实是我所见证的行为。 一个例子:生产者有一个单一的队列,每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; […]