AWS Serverless环境下Express对接MongoDB Atlas连接无法正常关闭问题

核心根因 #

你遇到的连接堆积问题本质是对 AWS Lambda 执行环境生命周期 和 MongoClient 实例特性 的认知偏差导致的，具体有3个直接触发点：

• Lambda 响应返回后不会直接销毁进程，只会将进程冻结留待后续热启动复用，进程持有的 MongoDB 连接不会主动断开，Mongo Atlas 侧会一直保留该连接直到TCP超时
• 现有路由代码没有覆盖异常分支的连接关闭逻辑：请求抛出错误进入catch分支后直接调用next(error)，完全没有执行close()操作，这部分是泄漏的主要来源
• 全局初始化的MongoClient实例关闭后无法复用：你的client在模块顶层初始化，调用close()后该实例就会进入不可用状态，后续请求调用connect()时也无法基于该实例重建有效连接，会频繁生成新的连接实例

可快速落地的修复方案 #

方案1：修复现有每次请求关闭连接的逻辑 #

1. 先修改Mongo连接管理代码，每次新建连接时重新生成MongoClient实例：

const MongoClient = require('mongodb').MongoClient
const config = require('../config')

let cachedClient = null;
let cachedDb = null;

module.exports.connect = async () => {
  if (cachedDb) return cachedDb;
  // 每次新建连接时生成新的Client实例，避免关闭后无法复用
  const MONGODB_URI = config.stage === 'test' ?
    global.__MONGO_URI__ :
    `mongodb+srv://${config.mongodb.username}:${config.mongodb.password}@${config.mongodb.host}/admin?retryWrites=true&w=majority`;
  cachedClient = new MongoClient(MONGODB_URI);
  await cachedClient.connect();
  const dbName = config.stage === 'test' ? global.__MONGO_DB_NAME__ : config.stage;
  cachedDb = cachedClient.db(dbName)
  return cachedDb;
}

module.exports.close = async () => {
  if (!cachedClient) return;
  await cachedClient.close();
  cachedClient = null;
  cachedDb = null;
}

2. 修复路由的全路径关闭逻辑，不要阻塞响应返回：

router.get('/website/:id/page', async (req, res, next) => {
  try {
    const pages = await pageDataProvider.findByWebsite(req.params.id);
    res.json(pages);
    // 监听响应发送完成后再关闭连接，不影响用户侧响应速度
    res.on('finish', async () => {
      await mongodbDataProvider.close();
    })
  } catch (error) {
    // 异常场景也必须关闭连接
    await mongodbDataProvider.close();
    next(error)
  }
})

3. 确保Lambda配置context.callbackWaitsForEmptyEventLoop = true（默认值就是true，如果你之前手动改成了false要改回来），保证响应发送后的关闭逻辑能执行完成再冻结进程。

方案2：更高效的连接复用方案（推荐） #

不需要每次请求关闭连接，利用Lambda热启动特性复用连接，从根源降低连接数：

1. 保留全局的MongoClient实例，移除所有路由里的主动close()调用
2. 在Mongo连接串中添加两个参数：maxPoolSize=1&maxIdleTimeMS=30000，设置每个Lambda环境最多1个连接，闲置30秒后自动断开
3. 按需调整Lambda并发限制到400以内（低于Mongo Atlas 500连接的上限）
   这个方案不仅不会出现连接堆积，还能避免每次请求新建连接的开销，降低接口延迟。

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