Node.js中使用MongoDB原生驱动v3.6.6实现数据库连接复用的问题排查

现有实现的核心问题 #

• 单例存储指向错位：模块顶层声明的var _db用于缓存数据库实例，但方法内部实际给this._db赋值，从未操作过顶层的_db变量。一旦方法被脱离对象绑定调用（如作为回调传递、解构后单独引用），this指向丢失，直接导致实例判断失效，触发不必要的重连。
• 无并发连接去重：没有缓存连接建立过程中的Promise实例，当初始化未完成时，多个并发的getDb调用会同时触发connectDb流程，产生重复连接初始化开销。
• 容错机制缺失：连接建立的异步流程没有错误捕获逻辑，一旦网络波动、凭证错误导致连接失败，会抛出未处理的Promise异常，且无法将错误透传给上层调用方。

调整后的稳定实现 #

改造思路 #

1. 所有单例状态（数据库实例、连接初始化Promise）全部存储在模块作用域内，完全摆脱对方法this上下文的依赖，从根源上避免指向问题。
2. 用模块级的连接Promise缓存做并发去重，无论多少个调用同时请求连接，都只会执行一次client.connect()流程。
3. 完全兼容现有代码的回调调用模式，同时保留原生Promise返回能力，不需要大幅修改上层业务代码。

改造后的mongoCon模块代码 #

const MongoClient = require('mongodb').MongoClient;
const mongoCredentials = require('./../config.json')["mongoCredentials"];
const url = `mongodb://${mongoCredentials["url"]}:${mongoCredentials["port"]}`;

// 模块作用域内存储单例状态，不依赖this
let _db = null;
let _connectPromise = null;
const client = new MongoClient(url, { 
  useNewUrlParser: true, 
  useUnifiedTopology: true 
});

module.exports = {
  connectDb: async function(callback = null) {
    // 用缓存的连接Promise做并发去重，避免重复连接
    if (!_connectPromise) {
      _connectPromise = client.connect()
        .then(() => {
          _db = client.db(mongoCredentials["db"]);
          console.log("Database Connected");
          return _db;
        })
        .catch(err => {
          // 连接失败时清空缓存，允许后续重试
          _connectPromise = null;
          throw err;
        });
    }

    try {
      const db = await _connectPromise;
      if (callback) callback(null, db);
      return db;
    } catch (err) {
      if (callback) callback(err, null);
      throw err;
    }
  },

  getDb: async function(callback = null) {
    // 直接复用已初始化的连接流程，不会重复触发连接
    return this.connectDb(callback);
  }
}

配套的上层代码优化建议 #

当前app.js中把所有Express初始化逻辑都塞在连接回调中的写法，可以做小幅调整：

• 不需要把session、路由配置等和数据库连接无直接依赖的逻辑包裹在回调内，仅将需要直接操作数据库的逻辑（如session的MongoDB存储配置）放在连接成功后执行。
• 所有路由内的数据库操作，直接通过mongoCon.getDb()获取实例即可，由于模块级的Promise缓存存在，无论多少路由同时触发数据库调用，都只会复用同一个已建立的连接，不会产生新的连接实例。

效果验证 #

改造完成后，启动应用时只会打印一次Database Connected日志，后续所有getDb调用都会直接返回已缓存的数据库实例，不会重复触发连接流程；当连接未建立时的并发请求，都会等待同一个连接初始化完成，不会新建多余连接。

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