NodeJS AMQP 只能接收一次消息

Question

var amqp=require('amqp');
var conn=amqp.createConnection({/**/});
conn.on('ready',function() {
        console.log('Server Connected');
        conn.exchange('order',options={type:'topic'},function(exchange) {
                console.log('Exchange connected');
                conn.queue('order-consumer',function(queue) {
                        queue.bind(exchange,'');
                        console.log('Queue Connected');
                        queue.subscribe({ack:true},function(msg) {
                                //conn.end();
                                console.log(msg);
                        });
                });
        });
});

请注意，conn.end()被注释掉了。经过大量研究，我仍然不明白为什么这里需要它。虽然它很神奇，但每次连接都会结束，并且必须在每条消息后再次连接到服务器。

AMQP是这样设计的吗？或者这是node-amqp实现的问题？

Answer 1

正如精细手册所述：

将选项参数设置为 { ack: true }（默认为 false ）将使 AMQP 服务器一次只传递一条消息。当您需要下一条消息时，请拨打 q.shift() 。

你不是在打电话queue.shift()：

queue.subscribe({ ack : true }, function(msg) {
  console.log(msg);
  queue.shift(); // <-- necessary
});