并行使用不同队列中的消息+ rabbitmq + nodejs
它看起来像是在那里用于通过rabbitmq编写nodejs应用程序的唯一库
https://github.com/postwait/node-amqp
我有一个生产者以很快的速度向多个队列发布消息，在消费者中我为每个队列创建订阅。
connection.on('ready', function () {
for(var i=0;i<queues.length;i++)
connection.queue(queues[i],{autoDelete:false}, qOnReady);
});
function qOnReady(q){
// Catch all messages
logger("Q "+q.name+" is ready");
q.bind('#');
// Receive messages
q.subscribe(subscriber);
}
但是，当我运行消费者时，所有消费的消息都来自特定的队列，并且直到队列耗尽，订阅不会在另一个队列上启动。如何实现并行消费消息。
您可能希望使用异步库来实现队列的并行执行。
虽然不确定它是否适合您的需求。
https://github.com/caolan/async#paralleltasks-callback
链接地址: http://www.djcxy.com/p/34167.html上一篇: Parallel consumption of messages on different queues +rabbitmq+nodejs