MongoDB多租户架构单库插入异常缓慢问题求助

我们基于MongoDB构建了多租户业务模型，采用**单应用部署（Node.js+Mongoose）**连接集群内多数据库，每个租户对应独立数据库且集合结构完全一致。

系统在本地及Atlas集群环境下整体运行正常，但存在异常问题：总有一个数据库的插入操作极慢（空库状态下插入耗时约40秒），重启服务器后该问题会转移到其他数据库，其余数据库操作均正常。

相关连接代码 #

const MONGO_URI = <仅包含集群地址、用户名和密码，无/db后缀>
let databaseCluster = {};
const connect = (db) => {
  mongoose.plugin(forceRunValidators);
  return mongoose.createConnection(
    process.env.MONGO_URI + `/${db}?retryWrites=true&w=majority`,
    {
      useNewUrlParser: true,
      useCreateIndex: true,
      useFindAndModify: false,
      useUnifiedTopology: true,
      autoIndex: true,
    }
  );
};

// 服务器启动时调用一次
exports.connectToCluster = () =>
  new Promise(async (resolve, reject) => {
    try {
      let adminConnection = await connect(process.env.ADMIN_DB);
      let tenants = await Tetants(adminConnection).find({});
      databaseCluster = adminConnection;
      console.log("MongoDB admin Connected");
      tenantsMap = tenants;
      resolve("Tenants cached successfully.");
      console.log("Tenants cached successfully");
    } catch (err) {
      console.error(err);
      reject(err);
      // 失败时退出进程
      process.exit(1);
    }
  });

exports.getConnectionByTenant = (tenantName) => {
  let connection = null;
  connection = databaseCluster.useDb(tenantName, { useCache: true });
  return connection;
};

模型编译与数据操作示例 #

模型构建 #

const connection = getConnectionByTenant("my_tenant");
const ModelBuilder = (connection) => connection.model("collection_name",modelSchema);
const Model = ModelBuilder(connection);

数据操作 #

// 插入操作
const DataObject = new Model({
  property_1:"some_value",
  // ...其他字段
}) 
await dataObject.save();

// 查询操作
const data = await Model.findOne({});

已尝试的排查操作 #

我们使用MongoDB Shell的db.currentOp({"op": "insert"}, true)命令监控插入操作，但返回结果中inprog始终为空数组：

{ inprog: [],
  ok: 1,
  '$clusterTime': 
   { clusterTime: Timestamp(1, 1700042646),
     signature: 
      { hash: BinData(0, "z5Pv/28gd21JtFpYB0bpQBk+NTc="),
        keyId: NumberLong("7244587175163985926") } },
  operationTime: Timestamp(1, 1700042646) }

排查方向与解决方案建议 #

1. 连接池分配与useDb缓存问题 #

当前代码依赖useDb的缓存机制复用连接，但Mongoose的连接池可能存在分配不均的情况。尝试显式配置连接池参数：

// 修改connect函数的配置项
{
  useNewUrlParser: true,
  useCreateIndex: true,
  useFindAndModify: false,
  useUnifiedTopology: true,
  autoIndex: true,
  poolSize: 15, // 根据租户数量调整连接池大小
  maxPoolSize: 30,
  minPoolSize: 5
}

同时在getConnectionByTenant中添加日志，统计每个租户连接的创建次数，排查是否存在连接泄漏或异常重复创建的情况。

2. 自动索引创建的延迟影响 #

配置autoIndex: true会导致首次插入时自动创建索引，空库下的索引创建可能引发延迟。但问题随机转移的特点说明不是单个库的索引问题，建议：

• 生产环境预先为所有租户数据库创建索引，关闭autoIndex配置
• 应用启动时批量执行索引创建脚本，避免首次插入时的开销

3. 全局Mongoose插件的副作用 #

代码中在connect函数里全局调用mongoose.plugin(forceRunValidators)，会影响所有后续连接。改为仅在单个连接实例上注册插件：

const connect = (db) => {
  const conn = mongoose.createConnection(
    process.env.MONGO_URI + `/${db}?retryWrites=true&w=majority`,
    { /* 配置项 */ }
  );
  conn.plugin(forceRunValidators); // 仅为当前连接注册插件
  return conn;
};

4. MongoDB集群路由与节点负载问题 #

重启后问题转移，可能与集群连接路由有关：

• 在连接字符串中显式声明directConnection=false，确保客户端使用集群路由
• 调整readPreference为primaryPreferred，避免连接到负载较高的从节点
• 通过Atlas监控面板或mongostat查看集群节点的CPU、磁盘IO、连接数指标，定位是否有节点负载异常

5. 细化性能监控 #

• 开启Mongoose debug模式，查看慢插入操作的详细执行流程：

  mongoose.set('debug', true);
  

• 针对慢插入的租户数据库，执行db.collection.getPlanCache().clear()清除查询计划缓存后重新测试
• 使用db.serverStatus()查看数据库实例的连接状态与性能指标

内容的提问来源于stack exchange，提问作者Md.Reyad Hossain