对于RabbitMQ，是否有相当于"ping“的内容？如何诊断交换机或队列是否正在广播？

Question

我使用postwait/node-amqp (链接)连接到我们组织中的各种RabbitMQ交换和队列。

当我的项目从dev转移到产品时，我遇到了几个问题:队列设置不正确，密码不正确等等。在后一种情况下，很明显，我会得到ECONNREFUSED错误。但是，在第一种情况下，我没有任何错误，只是连接上的超时。

给定像amqp://USER:PASS@messaging.abc.xyz.com这样的URI，如何确定名为“FooWorkItems.Work”的队列是否接受侦听连接?这方面的最低限度代码是什么，这相当于检查一个API是否正在侦听或服务器是否在运行并监听ping端口？

代码：

if (this.amqpLib == null) {
    this.amqpLib = require('amqp');
  }
this.connection = this.amqpLib.createConnection({
    url: this.endpoint
  });

  this.connection.on('ready', (function(_this) {
    return function() {
      var evt, _fn, _fn1, _i, _j, _len, _len1, _ref, _ref1;
      _this.logger.info("" + _this.stepInfo + " connected to " + _this.endpoint + "; connecting to " + queueName + "  now.");
      if (_this.fullLogging) {
        _ref = ['connect', 'heartbeat', 'data'];
        _fn = function(evt) {
          return _this.connection.on(evt, function() {
            _this.logger.trace("" + _this.stepInfo + " AMQP event: " + evt);
            if (arguments != null) {
              return _this.logger.trace({
                args: arguments
              });
            }
          });
        };
        for (_i = 0, _len = _ref.length; _i < _len; _i++) {
          evt = _ref[_i];
          _fn(evt);
        }
        _ref1 = ['error', 'close', 'blocked', 'unblocked'];
        _fn1 = function(evt) {
          return _this.connection.on(evt, function() {
            if (evt !== 'close') {
              return _this.logger.error("" + _this.stepInfo + " AMQP event: " + evt);
            } else {
              return _this.logger.warn("" + _this.stepInfo + " AMQP event: " + evt);
            }
          });
        };
        for (_j = 0, _len1 = _ref1.length; _j < _len1; _j++) {
          evt = _ref1[_j];
          _fn1(evt);
        }
      }
      return _this.connection.queue(_this.queueName, {
        passive: true
      }, function(q) {
        logger.debug("" + stepInfo + " connected to queue " + queueName + ". Init complete.");
        return q.subscribe(function(message, headers, deliveryInfo, messageObject) {
          logger.trace("" + stepInfo + " recvd message");
          return logger.trace({
            headers: headers
          });
        });
      });
    };

Answer 1

在amqp中，队列和交换是与连接无关的概念，它们不监听或广播，您不能连接到它们，只能连接到代理。

当然，RabbitMQ服务器接受网络连接，而协议定义是传输之上的逻辑连接，这种连接包括一个心跳，可以在这个库中使用heartbeat选项进行配置。

正如您所说，连接错误(包括超时)在启动时需要处理，其余的则可以依赖心跳，类似于"ping“机制。如果连接中断，并且设置了心跳参数，则库只会抛出一个错误，因此不需要重新实现这个错误。

您还应该查看postwait/node中的reconnect设置，因为它可能会自动处理一些网络故障模式。