看起来唯一用于在 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);
}
但是当我运行消费者时，所有消耗的消息都来自特定队列并且直到队列耗尽，订阅不会在另一个队列上开始。我如何实现并行消费消息。