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; […]