Node.js CommonJS环境下如何复用单个Promise式RabbitMQ连接避免重复创建？

解决方案：单例模式+惰性初始化实现连接全局复用 #

你可以通过封装独立的AMQP连接管理模块，完全在CommonJS规范下实现连接全局复用，不需要顶层await，也不需要修改现有项目的模块化配置。

步骤1：封装连接管理模块

新建amqp-connection.js文件，统一管理RabbitMQ连接的创建、缓存、重连逻辑：

const amqp = require('amqplib');

// 全局缓存连接Promise，仅初始化一次
let cachedConnection = null;
const AMQP_SERVER_URL = '你的RabbitMQ服务地址';

async function getAmqpConnection() {
  // 已有缓存直接返回
  if (cachedConnection) return cachedConnection;

  // 首次调用创建连接
  cachedConnection = amqp.connect(AMQP_SERVER_URL);

  // 处理连接异常，断开后清空缓存触发下次重连
  cachedConnection
    .then(conn => {
      conn.on('error', err => {
        console.error('AMQP连接错误：', err);
        if (cachedConnection === conn) cachedConnection = null;
      });
      conn.on('close', () => {
        console.warn('AMQP连接已关闭，下次调用将自动重连');
        if (cachedConnection === conn) cachedConnection = null;
      });
    })
    .catch(err => {
      console.error('AMQP连接初始化失败：', err);
      cachedConnection = null;
      throw err;
    });

  return cachedConnection;
}

module.exports = getAmqpConnection;

步骤2：在控制器中直接使用

你的接口控制器无需大幅修改，直接引入封装好的连接方法调用即可：

const getAmqpConnection = require('./amqp-connection');

app.post("/routethatdelegatesheavywork", async (req,res) => { 
  try {
    const connection = await getAmqpConnection();
    const channel = await connection.createChannel();
    // 原有业务逻辑
    // ...
  } catch (err) {
    console.error('请求处理失败：', err);
    res.status(500).send('服务内部错误');
  }
})

方案原理

• 惰性初始化：服务启动时不会创建连接，第一次收到请求时才会初始化连接，不会阻塞服务启动流程，完全避开CommonJS不支持顶层await的限制
• 单例复用：缓存的是连接Promise实例，同一时间的所有并发请求都会等待同一个连接初始化完成，不会出现重复创建连接的问题
• 自动重连：监听连接错误、关闭事件，连接异常时自动清空缓存，下次调用会自动创建新连接，不需要人工干预
• 无侵入性：完全兼容CommonJS规范，不需要修改任何现有项目的导入导出逻辑，迁移成本为0

如果你的业务场景中信道不需要频繁创建销毁，也可以用同样的逻辑缓存信道实例，进一步提升性能。

内容的提问来源于stack exchange，提问作者Ebdulmomen1