MongoDB M0集群连接数超限问题排查及解决方案咨询

问题背景 #

收到MongoDB告警：

You are receiving this alert email because connections to your cluster(s) have exceeded 500, and is nearing the connection limit for the M0 cluster HSDevCluster in the Project Halal Spisesteder Development within Organization YouBen. Please restart your application or login to your Atlas account to see some suggested solutions.

对应的数据库配置代码：

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

// MongoDB connection string
const mongoURI = process.env.MONGODB_URI;
const dbName = process.env.DATABASE_NAME;

// Create a new MongoClient instance
const client = new MongoClient(mongoURI);

async function connectToMongoDB() {
  try {
    // Connect to the MongoDB server
    await client.connect();

    // Get the database instance
    const db = client.db(dbName);

    return db;
  } catch (error) {
    console.error('MongoDB connection error:', error);
    throw error;
  }
}

module.exports = {
  connectToMongoDB,
};

路由代码：

const express = require('express');
const router = express.Router();
const { connectToMongoDB } = require('../../database/database'); // Import the MongoDB connection function

// Define an endpoint to fetch restaurant data
router.get('/restaurants', async (req, res) => {
    try {
        const db = await connectToMongoDB();
        const restaurants = await db
            .collection('restaurants')
            .find({ registrationStatus: "Active" })
            .sort({ averageRating: -1, numberOfReviews: -1 })
            .toArray();
           console.log("fetch successful");
        res.json(restaurants);
    } catch (error) {
        console.error(error);
        res.status(500).json({ error: 'Internal server error' });
    }
});

module.exports = router;

问题原因 #

并非直接是“连接使用后未关闭”导致，而是连接池复用逻辑错误：

1. 你创建了全局的MongoClient实例，但每次HTTP请求都会调用connectToMongoDB执行await client.connect()。虽然重复调用connect()不会创建新连接池，但请求峰值时会导致连接池中的连接被大量占用，快速逼近M0集群500的连接上限。
2. 没有在应用启动阶段一次性完成连接初始化，而是每次请求都触发连接逻辑，导致连接池无法高效复用连接，连接数随请求量增长快速累积。

解决方法 #

方案一：全局初始化连接，复用DB实例（推荐） #

修改数据库配置代码，在应用启动时完成一次连接，后续所有请求直接复用已初始化的DB实例：

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

const mongoURI = process.env.MONGODB_URI;
const dbName = process.env.DATABASE_NAME;

const client = new MongoClient(mongoURI);
let dbInstance = null;

// 应用启动时初始化MongoDB连接
async function initMongoDB() {
  try {
    await client.connect();
    dbInstance = client.db(dbName);
    console.log('MongoDB 连接成功');
  } catch (error) {
    console.error('MongoDB 初始化失败:', error);
    process.exit(1); // 初始化失败直接终止应用
  }
}

// 获取已初始化的DB实例
function getDB() {
  if (!dbInstance) {
    throw new Error('MongoDB 未初始化，请先调用 initMongoDB');
  }
  return dbInstance;
}

module.exports = {
  initMongoDB,
  getDB
};

修改路由代码，直接调用getDB()获取实例：

const express = require('express');
const router = express.Router();
const { getDB } = require('../../database/database');

router.get('/restaurants', async (req, res) => {
    try {
        const db = getDB();
        const restaurants = await db
            .collection('restaurants')
            .find({ registrationStatus: "Active" })
            .sort({ averageRating: -1, numberOfReviews: -1 })
            .toArray();
        console.log("fetch successful");
        res.json(restaurants);
    } catch (error) {
        console.error(error);
        res.status(500).json({ error: 'Internal server error' });
    }
});

module.exports = router;

最后在应用入口文件（如app.js）中启动时初始化连接：

const { initMongoDB } = require('./database/database');
const express = require('express');
const app = express();

async function startApp() {
  await initMongoDB();
  // 挂载路由等其他逻辑
  app.use('/api', require('./routes/restaurants'));
  
  app.listen(3000, () => {
    console.log('服务运行在端口 3000');
  });
}

startApp();

方案二：限制连接池大小（临时缓解） #

如果暂时无法重构代码，可以在MongoDB连接字符串中添加maxPoolSize参数，限制单实例的连接池大小，避免超过M0的连接上限（例如设置为100，根据实际请求量调整）：

mongodb+srv://<用户名>:<密码>@cluster.mongodb.net/?maxPoolSize=100&retryWrites=true&w=majority

额外建议 #

• 登录MongoDB Atlas控制台查看连接数监控，确认连接增长的规律，排查是否存在慢查询导致连接长时间占用
• 对高并发请求做限流处理，避免短时间内发起大量请求
• 应用重启时确保MongoClient连接被正确关闭（可以在process.on('SIGINT')事件中调用client.close()）

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