node.js - 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

正如精美的手册所述：

将 options 参数设置为{ ack: true }（默认为false）将使 AMQP 服务器一次只发送一条消息。当您想要下一条消息时，请致电q.shift()。

你没有打电话queue.shift()：

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