Node.js连接AWS上的RabbitMQ服务报ECONNRESET错误如何解决

开发者阿泽

2026-10-6

Node.js连接RabbitMQ ECONNRESET 报错解决方案

核心问题根因

你遇到的报错是两个配置错误共同导致的：

端口5671是RabbitMQ TLS加密连接的专属端口，你当前配置的protocol: "amqp"是明文传输协议，明文协议默认使用5672端口，协议与端口不匹配导致RabbitMQ服务端主动断开连接，触发ECONNRESET错误。
代码中port: 5671(default)的写法不符合JavaScript语法规范，运行时会触发隐式语法错误，需要改为纯数字值。
额外说明：Python的pika库会自动根据端口适配加密协议，而Node.js的amqplib需要显式指定协议类型，这就是相同凭证两边连接表现不一致的原因。

修复后的代码示例

const amqp = require('amqplib/callback_api');

exports.connectQueue = () => {
  amqp.connect(
    {
      protocol: "amqps", // 加密连接必须指定amqps协议
      username: "username",
      password: "password",
      hostname: "aws host address",
      port: 5671, // 修改为纯数字端口
      vhost: "/",
      heartbeat: 60, // 不建议设置为0，避免被AWS防火墙断开无活动连接
      // 若使用自签名SSL证书，可添加下面这行跳过证书校验，生产环境建议配置官方CA证书
      // rejectUnauthorized: false
    },
    (connError, connection) => {
      if (connError) {
        console.log("connError is this - ", connError);
        throw connError;
      }
      console.log("connected");
      // 后续通道创建、队列声明逻辑可在此处实现
    }
  );
};