Node.js应用MongoDB连接持续增长未关闭问题咨询

你的问题核心在于每次定时任务都新建了MongoDB连接，没有复用连接池——这也是新手使用MongoDB驱动时常见的误区。MongoDB Node.js驱动本身自带连接池管理，只需要在应用启动时建立一次连接，之后所有数据库操作复用这个连接池即可，完全不需要每次调用都重新连接。

正确的实现思路 #

• 应用启动时一次性建立数据库连接，获取MongoClient实例或者对应的Database对象并保存
• 定时任务中复用已有的连接/数据库实例，直接操作集合
• 应用退出时关闭连接池，释放资源

代码示例 #

假设你的原有代码可能是在getData()里重复调用MongoClient.connect，改成下面的方式：

const { MongoClient } = require('mongodb');

// 提前声明的变量
const uri = 'your-mongodb-uri';
const databaseName = 'your-db-name';
const collectionName = 'your-collection-name';

// 保存全局的数据库实例
let db;

// 初始化数据库连接
async function initDB() {
  try {
    const client = await MongoClient.connect(uri);
    db = client.db(databaseName);
    console.log('数据库连接成功，已建立连接池');
    
    // 连接成功后启动定时任务
    setInterval(getData, 10000);
  } catch (err) {
    console.error('数据库连接失败:', err);
    process.exit(1); // 连接失败直接退出应用
  }
}

// 复用已有的db实例获取数据
async function getData() {
  try {
    const collection = db.collection(collectionName);
    // 执行你的数据库操作，比如查询
    const data = await collection.find({}).limit(10).toArray();
    console.log('获取到数据:', data);
  } catch (err) {
    console.error('查询数据失败:', err);
  }
}

// 应用退出时关闭连接池
process.on('SIGINT', async () => {
  await db.client.close();
  console.log('连接池已关闭，应用退出');
  process.exit(0);
});

// 启动应用时初始化数据库
initDB();

关于database变量的说明 #

你完全需要保存这个db实例（也就是你说的database变量），它是连接到指定数据库后的核心对象，所有集合操作、事务等都依赖它。通过复用这个实例，所有数据库操作都会走同一个连接池，不会每次新建连接，自然也就不会出现连接数持续增长的问题。

为什么之前的方式会导致连接数增长？ #

如果你的原有代码是在getData()内部每次都调用MongoClient.connect，那么每次定时任务都会创建一个新的连接（或者新的连接池），而旧的连接如果没有主动关闭，驱动可能不会立即回收，导致连接数不断累积，最终可能耗尽数据库的连接配额或者导致性能问题。

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