基于Promise实现可跨模块复用的MongoDB单例连接咨询

首先得说，你的思路是对的——用Promise封装单例连接，利用Node.js模块缓存特性来保证复用性，但代码里有几个关键问题导致它无法正常工作：

主要问题 #

• 异步时序错误：MongoClient.connect是异步操作，但你在Promise里同步检查MongoDB变量，这时候连接请求还没完成，MongoDB肯定是undefined，所以代码直接走到rej('no DB')，永远不会等到连接成功的回调。
• 变量未定义：res(db)里的db根本没在当前作用域定义，你应该用赋值后的MongoDB，但因为异步的问题，这个值永远不会被正确赋值。
• 错误处理缺失：连接失败时（比如MongoDB没启动、地址错误），你没有在connect的回调里处理err，导致Promise既不会resolve也不会reject，调用方会一直处于pending状态。
• API版本不匹配：新版MongoDB Node.js驱动中，connect回调的第二个参数是MongoClient实例，不是直接的数据库对象，需要调用client.db()才能获取对应数据库的引用。

正确的实现方式 #

下面是修复后的代码，同时适配新版驱动，并且保证单例特性：

Server.js（连接模块） #

const { MongoClient } = require('mongodb');
// 把连接字符串和数据库名抽成常量，方便维护
const DB_URL = 'mongodb://localhost:27017';
const DB_NAME = 'WIGAMEX';

// 利用模块缓存，导出一个Promise，只会执行一次连接操作
module.exports = new Promise((resolve, reject) => {
  MongoClient.connect(DB_URL, { poolSize: 30 }, (err, client) => {
    if (err) {
      // 连接失败，reject错误信息
      return reject(err);
    }
    // 获取指定数据库实例
    const db = client.db(DB_NAME);
    console.log('MongoDB连接成功');
    // resolve数据库实例，供其他模块使用
    resolve(db);
  });
});

模块1（调用示例） #

const dbPromise = require('../Server.js');

// 每次使用时，通过then获取数据库实例
dbPromise.then(db => {
  // 在这里执行数据库操作，比如查询
  return db.collection('users').find({}).toArray();
})
.then(data => {
  console.log('查询结果:', data);
})
.catch(err => {
  console.error('数据库操作失败:', err);
});

额外优化建议 #

如果你的Node.js版本支持async/await，可以让调用代码更简洁：

const dbPromise = require('../Server.js');

async function getUsers() {
  try {
    const db = await dbPromise;
    const users = await db.collection('users').find({}).toArray();
    console.log('用户列表:', users);
  } catch (err) {
    console.error('获取用户失败:', err);
  }
}

getUsers();

这样实现的好处：

• 利用Node.js模块的缓存机制，Server.js导出的Promise只会被创建一次，所有模块引用的都是同一个连接Promise，保证了单例特性。
• 正确处理了异步时序，只有当连接成功或失败时，才会resolve/reject Promise。
• 完善了错误处理，任何连接或操作错误都会被捕获。

内容的提问来源于stack exchange，提问作者Willem van der Veen