Koa+Mongoose连接MongoDB副本集重连后查询请求挂起问题

你遇到的是Mongoose 4.x版本在副本集网络波动后，连接池未正确恢复导致的查询挂起问题，结合Koa 1.x的generator异步机制，根源主要集中在旧版本Mongoose的副本集重连bug、不合理的socket超时配置，以及无效连接占用。下面是针对性的解决方案：

1. 修复MongoDB连接配置，避免无限超时 #

你当前设置的socketTimeoutMS: 0会让连接永远不超时——网络恢复后，失效的socket连接会留在连接池中，查询请求会一直等待无效连接响应，最终导致请求挂起返回空响应。调整配置如下：

const options = {
  socketOptions: { 
    socketTimeoutMS: 30000, // 设置30秒超时，避免无限等待
    keepAlive: true,
    keepAliveInitialDelay: 30000
  },
  auto_reconnect: true,
  reconnectTries: Number.MAX_VALUE,
  reconnectInterval: 1000 // 每秒尝试重连一次
};

mongoose.connect(MONGO_URL, { 
  server: options, 
  replset: {
    ...options,
    connectWithNoPrimary: true // 允许主节点暂时不可用时连接副本集，提升容错性
  } 
});

2. 监听连接事件，主动清理无效连接 #

当MongoDB重连成功后，主动清除连接池中的旧连接，确保后续查询使用新的有效连接：

mongoose.connection.on('disconnected', () => {
  console.log('MongoDB连接已断开');
});

mongoose.connection.on('reconnected', () => {
  console.log('MongoDB重新连接成功');
  // 销毁连接池中的所有旧连接，强制后续查询使用新连接
  if (mongoose.connection.db?.serverConfig?.pool) {
    mongoose.connection.db.serverConfig.pool.destroyAll();
  }
});

3. 给查询添加超时处理，避免请求挂起 #

在Koa的generator函数中，给数据库查询加上超时包装，确保即使出现异常情况，请求也能及时返回错误而不是无限挂起：

// 封装一个带超时的Promise工具函数
function timeoutPromise(promise, timeoutMs) {
  return new Promise((resolve, reject) => {
    const timer = setTimeout(() => {
      reject(new Error(`查询超时（${timeoutMs}ms）`));
    }, timeoutMs);

    promise
      .then(result => {
        clearTimeout(timer);
        resolve(result);
      })
      .catch(err => {
        clearTimeout(timer);
        reject(err);
      });
  });
}

function *example() {
  let data;
  try {
    // 给查询设置10秒超时，记得调用.exec()返回Promise
    data = yield timeoutPromise(model.findOne({}).exec(), 10000);
  } catch (e) {
    console.error('数据库查询失败:', e);
    this.status = 500;
    this.body = { error: '数据查询异常，请稍后重试' };
    return;
  }
  this.body = data;
}

4. 升级Mongoose版本（最推荐的根本解决方案） #

你使用的Mongoose 4.7.3是2016年的旧版本，存在大量副本集重连和连接池相关的已知bug。建议升级到4.x系列的最新稳定版（比如4.13.21），或者直接升级到5.x+版本——新版本彻底重构了连接池和重连逻辑，能从根源上避免这类问题。

关于单实例MongoDB崩溃的问题 #

单实例场景下，网络断开后未捕获的连接错误会导致Node.js进程崩溃，你可以通过全局异常监听来避免：

process.on('uncaughtException', (err) => {
  console.error('未捕获异常:', err);
  // 这里可以添加服务重启逻辑，比如调用process.exit(1)让PM2等进程管理器重启服务
});

// 同时监听Mongoose的连接错误
mongoose.connection.on('error', (err) => {
  console.error('MongoDB连接错误:', err);
});

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