0

我有一个用于连接 RabbitMQ的node.js应用程序。amqlib我正在尝试使用 RabbitMQ 重现连接错误，并且通过重复相同的流程得到两个不同的错误。

我正在做的是：

  • 使用 RabbitMQ 管理启动 Docker 容器。
  • 启动连接到 RabbitMQ 的 node.js 应用程序（docker 或 npm）。
  • 继续 RabbitMQ 管理并rabbitmqctl执行stop_app

此流程每次都会产生以下两个异常之一（不确定它如何决定每个异常）：

  • OperationalError：连接 ECONNREFUSED 172.24.0.3:5672
  • 错误：心跳超时

为什么会这样？另外，处理它们的最佳方法是什么？

这是我在连接器上的连接功能，似乎没有涵盖心跳异常：

  async connect(): Promise<Connection> {
    const conn = await amqp.connect({
      protocol: AMQP_PROTOCOL,
      hostname: RABBITMQ_HOST,
      port: Number(RABBITMQ_PORT),
      username: RABBITMQ_USER,
      password: RABBITMQ_PASS,
      vhost: RABBITMQ_VHOST
    });

    conn.on('error', this.onError);
    conn.on('close', this.onClose);

    logger.debug('Connected to amqp');

    this.conn = conn;
    this.emit('connect', conn);

    return conn;
  }
4

1 回答 1

1

ECONNREFUSED 表示应用程序无法连接到 docker 容器内的 RabbitMQ。

心跳错误表示连接建立成功，但是客户端已经停止接收到broker的心跳，说明连接已经丢失。

您可能还会收到另一种类型的通知。如果您已开始使用来自应用程序的消息，则当您停止代理时，amqplib 将向null消费者传递一条消息。如果您没有预料到这一点，它通常会导致您的应用程序出现错误。

处理这些不同的场景可能很困难。最简单的方法是将处理程序附加到所有连接和通道，然后优雅地停止您的应用程序，并允许任何管理它的程序使用合适的退避算法自动重新启动。

如果这是不可接受的，那么您需要重新连接并从处理程序重新使用。您可能还希望在内部对已发布的消息进行排队，直到重新建立连接。我写Rascal就是为了做到这一点。还有amqp-connection-manager。

您可能会考虑使用其他东西来测试...

  • docker kill（粗暴地终止连接）
  • docker pause（会导致心跳超时）
  • 队列删除（我相信这会触发空消息）
于 2020-05-10T06:46:28.467 回答