如何让MongoDB自动终止执行超1分钟的查询？

针对你的Audit Trail集合查询超时问题，以下是几种可行的后端实现方案：

1. 直接使用MongoDB原生maxTimeMS()限制查询时长 #

MongoDB内置查询超时控制能力，通过maxTimeMS()可指定查询的最大执行毫秒数（这里设为60000即1分钟），超过时长后MongoDB会自动终止查询并返回超时错误。在Mongoose中可直接在Query链上调用该方法：

const Audit = mongoose.model('Audit', auditSchema);

// 查询示例：自动设置1分钟超时
Audit.find({/* 查询条件 */})
  .maxTimeMS(60000)
  .exec()
  .then(results => {
    // 处理查询结果
  })
  .catch(err => {
    if (err.name === 'MongoError' && err.code === 50) {
      // 捕获查询超时错误，返回提示给前端
      console.error('查询超时，请缩小查询范围');
      // 这里可抛出自定义错误或返回HTTP响应
    } else {
      // 处理其他数据库错误
      console.error(err);
    }
  });

注意：MongoDB v3.6.8支持maxTimeMS()，错误码50对应查询超时场景。

2. 应用层用Promise.race实现超时控制 #

如果需要更灵活的超时逻辑（比如在查询启动时就开始计时，不受数据库驱动影响），可通过Promise.race将查询Promise与延迟拒绝的Promise绑定，超时后主动终止查询流程：

const Audit = mongoose.model('Audit', auditSchema);

// 封装超时工具函数
const withTimeout = (promise, timeoutMs) => {
  const timeoutPromise = new Promise((_, reject) => {
    setTimeout(() => reject(new Error('查询超时，请缩小时间范围')), timeoutMs);
  });
  return Promise.race([promise, timeoutPromise]);
};

// 使用示例
const query = Audit.find({/* 查询条件 */}).exec();
withTimeout(query, 60000)
  .then(results => {
    // 处理结果
  })
  .catch(err => {
    console.error(err.message);
    // 返回对应错误响应
  });

注意：应用层触发超时后，数据库端的查询可能仍在执行，建议结合maxTimeMS()一起使用，双重保障。

3. 全局Mongoose中间件统一设置超时 #

如果希望所有Audit Trail的查询都自动应用超时限制，无需每个查询手动添加，可通过Mongoose预查询中间件实现：

// 在定义schema后添加中间件
auditSchema.pre(['find', 'findOne', 'countDocuments', 'aggregate'], function(next) {
  // 给查询设置1分钟超时
  this.maxTimeMS(60000);
  next();
});

const Audit = mongoose.model('Audit', auditSchema);

该中间件会作用于find、findOne、countDocuments、aggregate等常用查询方法，确保所有相关查询都带有超时限制。

4. 辅助优化：添加索引减少查询耗时 #

除了超时控制，给常用查询字段添加索引能大幅缩短查询时间，从根源减少超时触发概率。比如针对when（时间范围查询）、who_type、who等字段创建索引：

// 在schema中定义索引
const auditSchema = mongoose.Schema({
  who: { type: String, index: true },
  what: { type: String },
  when: { type: Date, index: true },
  who_id: { type: Schema.Types.ObjectId, index: true },
  who_type: { type: String, index: true }
});

// 或者手动创建复合索引（如果有常用的组合查询条件）
// Audit.collection.createIndex({ when: 1, who_type: 1 });

索引能让MongoDB快速定位数据，避免全表扫描，大幅降低查询耗时。

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