Node.js中MongoDB全局连接最优方案咨询（Node-Mongo-Native）

嘿，我完全懂你纠结的点——每次请求新建连接确实是个大坑，不仅浪费资源，还会拖慢整个服务的性能。下面给你两种靠谱的全局连接方案，都是业界常用的，你可以根据自己的项目结构选：

方案一：单例模式封装数据库连接 #

这种方式适合项目里多个模块（比如路由、服务层）都需要访问数据库的场景，把连接逻辑封装成一个单例模块，确保整个应用生命周期里只有一个连接实例被复用：

首先创建一个db.js模块：

const { MongoClient } = require('mongodb');
const connectionUrl = '你的MongoDB连接字符串';
let dbInstance = null;

// 获取数据库实例的异步函数
async function getDatabase() {
  // 如果已经有连接实例，直接返回
  if (dbInstance) {
    return dbInstance;
  }
  // 首次调用时创建连接
  const client = await MongoClient.connect(connectionUrl, {
    useNewUrlParser: true,
    useUnifiedTopology: true,
    // 可以根据需求调整连接池大小，默认是5
    poolSize: 10
  });
  // 保存数据库实例
  dbInstance = client.db('你的数据库名称');
  console.log('MongoDB连接成功');
  return dbInstance;
}

module.exports = getDatabase;

然后在你的Express路由里这样用：

const express = require('express');
const app = express();
const getDb = require('./db');

app.get('/api/data', async (req, res) => {
  try {
    const db = await getDb();
    const result = await db.collection('your-collection').find({}).limit(10).toArray();
    res.status(200).json(result);
  } catch (err) {
    console.error('数据库操作出错:', err);
    res.status(500).json({ message: '服务器内部错误' });
  }
});

app.listen(3000, () => {
  console.log('服务器运行在http://localhost:3000');
});

方案二：将连接挂载到Express的app.locals上 #

这种方式更贴合Express的架构，在服务器启动前就完成数据库连接，把实例挂载到app.locals上，所有路由都能通过req.app.locals.db直接访问：

const express = require('express');
const app = express();
const { MongoClient } = require('mongodb');
const connectionUrl = '你的MongoDB连接字符串';

// 先连接数据库，再启动服务器
MongoClient.connect(connectionUrl, {
  useNewUrlParser: true,
  useUnifiedTopology: true
})
.then(client => {
  console.log('MongoDB连接成功');
  // 把数据库实例挂载到app.locals
  app.locals.db = client.db('你的数据库名称');
  
  // 连接成功后再启动服务器
  app.listen(3000, () => {
    console.log('服务器运行在http://localhost:3000');
  });
})
.catch(err => {
  console.error('MongoDB连接失败:', err);
  // 连接失败直接退出进程，避免服务启动后无法正常工作
  process.exit(1);
});

// 路由中使用数据库实例
app.get('/api/users', (req, res) => {
  const db = req.app.locals.db;
  db.collection('users').find({}).toArray()
    .then(users => res.status(200).json(users))
    .catch(err => {
      console.error('查询用户出错:', err);
      res.status(500).json({ message: '查询失败' });
    });
});

为什么这两种方案更好？ #

• 它们都复用了MongoClient自带的连接池，避免了每次请求新建连接的资源浪费，MongoClient会自动管理连接的创建和复用，性能更稳定。
• 确保整个应用只有一个活跃的连接实例，不会因为连接数过多被MongoDB拒绝（MongoDB默认有连接数限制）。

额外注意事项 #

• 一定要处理连接失败的情况，比如方案二中连接失败就直接退出进程，避免服务启动后处于不可用状态。
• 服务器关闭时，记得调用client.close()关闭MongoDB连接，避免资源泄漏（可以通过监听SIGINT信号实现）。

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