Node.js中如何用Mongoose高效连接多个MongoDB集群？

你的核心问题是每次请求都重新建立MongoDB连接导致速度慢——mongoose.connect每次都会发起完整的握手、认证流程，开销极大。针对多集群场景，下面是几个可行的优化方案：

1. 缓存已建立的Mongoose连接实例 #

不要每次请求都调用mongoose.connect，而是用全局缓存存储已连接的集群实例，以用户密钥或集群唯一标识为key，复用现有连接：

// 全局缓存连接实例
const connectionCache = new Map();

async function getClusterConnection(clusterConfig, secret) {
  // 用集群连接字符串+密钥生成唯一缓存key
  const cacheKey = `${clusterConfig.uri}-${secret}`;
  
  if (connectionCache.has(cacheKey)) {
    const conn = connectionCache.get(cacheKey);
    // 检查连接是否可用，不可用则移除缓存并重建
    if (conn.readyState === 1) {
      return conn;
    } else {
      connectionCache.delete(cacheKey);
    }
  }

  // 创建新连接并缓存
  const conn = await mongoose.createConnection(clusterConfig.uri, {
    auth: {
      username: clusterConfig.username,
      password: clusterConfig.password
    },
    poolSize: 5, // 根据业务并发量调整连接池大小
    connectTimeoutMS: 10000,
    socketTimeoutMS: 45000,
    keepAlive: true
  });

  // 监听连接断开事件，自动清理失效缓存
  conn.on('disconnected', () => {
    connectionCache.delete(cacheKey);
  });

  connectionCache.set(cacheKey, conn);
  return conn;
}

// 使用示例
async function writeToUserCluster(secret, data) {
  // 从自有数据库获取用户的集群配置
  const userCluster = await UserCluster.findOne({ secret });
  const conn = await getClusterConnection(userCluster, secret);
  // 必须在对应连接实例上定义模型，避免绑定到默认连接
  const UserDataModel = conn.model('UserData', userDataSchema);
  await UserDataModel.create(data);
}

2. 直接使用原生MongoDB驱动 #

如果不需要Mongoose的ODM特性，用原生mongodb驱动更轻量，连接管理开销更低：

const { MongoClient } = require('mongodb');
const clientCache = new Map();

async function getMongoClient(clusterConfig, secret) {
  const cacheKey = `${clusterConfig.uri}-${secret}`;
  if (clientCache.has(cacheKey)) {
    const client = clientCache.get(cacheKey);
    if (client.isConnected()) {
      return client;
    } else {
      clientCache.delete(cacheKey);
    }
  }

  const client = new MongoClient(clusterConfig.uri, {
    auth: {
      username: clusterConfig.username,
      password: clusterConfig.password
    },
    maxPoolSize: 5,
    connectTimeoutMS: 10000,
    socketTimeoutMS: 45000
  });

  await client.connect();
  clientCache.set(cacheKey, client);

  // 连接关闭时自动清理缓存
  client.on('close', () => {
    clientCache.delete(cacheKey);
  });

  return client;
}

// 使用示例
async function writeToUserCluster(secret, data) {
  const userCluster = await UserCluster.findOne({ secret });
  const client = await getMongoClient(userCluster, secret);
  const db = client.db(userCluster.dbName);
  await db.collection('userData').insertOne(data);
}

3. 连接池参数调优 #

不管用Mongoose还是原生驱动，合理配置参数能大幅提升连接复用效率：

• poolSize/maxPoolSize: 根据并发量设置连接池大小（建议5-20），避免频繁创建新连接
• keepAlive: 启用TCP长连接，减少握手开销
• connectTimeoutMS: 缩短连接超时时间，快速失败重试
• socketTimeoutMS: 设置socket超时，避免挂起的连接占用资源

4. 可选：连接预热 #

如果业务允许，可以在用户注册完成时主动创建并缓存连接，让第一次请求直接复用。但要注意配合超时销毁机制（比如定时清理超过24小时未使用的连接），避免资源浪费。

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