RabbitMQ/AMQP 未处理的通道错误 - NOT_FOUND

Question

我正在尝试从 Ruby 脚本（使用 Bunny）向 RabbitMQ 发布消息，并从Node.js 服务器（使用 node-amqp）。

第一条消息成功到达，但随后在 Node.js 中记录了一个错误，并且连接关闭，并且没有收到进一步的消息：

mu:charlie-node tom$ node charlie.js 
22 Jul 09:11:04 - Running in development environment.
22 Jul 09:11:04 - Connected to AMQP.
22 Jul 09:11:04 - {"build_id":1234}
Unhandled channel error: NOT_FOUND - unknown delivery tag 1

如果我将两条消息发布到交换中，然后运行 ​​Node.js 服务器，我可以看到两条消息其中一些在记录错误之前到达，这表明 RabbitMQ 在交换或队列为空时正在关闭它。但是，由于我已将这两个文件的 autoDelete 设置为 false，所以不应该这样做。

有什么建议吗？

我的 node.js 脚本看起来像这样：

var amqpConnection = amqp.createConnection({ host: config.rabbitmq.host });

amqpConnection.addListener('ready', function() {
  sys.log("Connected to AMQP.");

  var exchange = amqpConnection.exchange('job_exchange', {
    type : 'topic',
    passive : false,
    durable : true, 
    autoDelete : false
  })

  exchange.addListener('open', function() {

    var queue = amqpConnection.queue('arthr_queue', {
      passive : false,
      autoDelete : false,
      durable : true,
      exclusive : false
    });

    queue.bind(exchange, '#');

    queue.subscribe(function(message) {
      sys.log(message.data.toString());
    });
  });
});

我的 Ruby 脚本看起来像这样：

require 'rubygems'
require 'bunny'
require 'json'

b = Bunny.new(:logging => true)

b.start

job_exchange = b.exchange('job_exchange', 
  :type => :topic, 
  :durable => true, 
  :auto_delete => false, 
  :passive => false
)

message = {
  :build_id => 1234
}

job_exchange.publish(message.to_json, :key => 'arthr.rebuild')

b.stop

Answer 1

我认为这是 node-amqp 中的一个错误。当 options.ack 设置为 false 时，代码默认发送 ack。

amqp 0.8 规范规定，当 noAck 时，服务器代表客户端执行此操作。

我亲眼目睹了 RabbitMQ 1.8.1 的错误。也许他们变得更严格了。

它已在我的分支中修复（http://github.com/spahl/node-amqp ）并且所有测试都通过。
我还修复了它尝试将默认的“amq.topic”交换重新声明为非持久交换的事实。