Node/Express服务器重启前调用函数及MySQL连接池释放问题咨询

我之前也被这个问题折腾过好一阵子！服务器意外宕机后，MySQL端的连接数被残留的进程占满，重启服务就触发max_user_connections错误，单纯用connection.release()确实没用——毕竟宕机时进程直接挂了，根本没机会执行释放逻辑。下面是我亲测有效的几个方案，结合起来用基本能解决问题：

1. 捕获进程终止信号，优雅关闭连接池 #

当服务器收到终止信号（比如系统的SIGTERM、用户按Ctrl+C的SIGINT），我们可以主动调用连接池的end()方法，让它优雅关闭所有空闲连接，并且等待正在执行的查询完成后再退出进程。这样MySQL端就不会残留无效连接。

示例代码：

// 假设你的连接池实例是pool
const cleanupPool = () => {
  console.log('正在关闭MySQL连接池...');
  pool.end((err) => {
    if (err) {
      console.error('关闭连接池失败:', err);
      process.exit(1);
    }
    console.log('连接池已关闭，进程退出');
    process.exit(0);
  });
};

// 监听系统终止信号
process.on('SIGTERM', cleanupPool);
// 监听Ctrl+C信号
process.on('SIGINT', cleanupPool);
// 监听未捕获的异常，避免进程挂掉时没处理连接池
process.on('uncaughtException', (err) => {
  console.error('未捕获的异常:', err);
  cleanupPool();
});

2. 配置连接池的自动回收与超时参数 #

通过调整连接池的配置，让它自动回收空闲过久的连接，同时限制总连接数不超过MySQL的max_user_connections限制。这样即使有少量残留连接，MySQL也会在超时后主动释放它们。

示例配置：

const mysql = require('mysql'); // 或mysql2
const pool = mysql.createPool({
  host: 'your-db-host',
  user: 'your-user',
  password: 'your-password',
  database: 'your-db',
  connectionLimit: 8, // 不要超过MySQL的max_user_connections（可通过SHOW VARIABLES LIKE 'max_user_connections'查看）
  idleTimeoutMillis: 30000, // 空闲30秒后自动回收连接
  acquireTimeout: 60000, // 获取连接的超时时间，避免无限等待
  waitForConnections: false, // 连接池满时直接拒绝新请求，防止排队导致更多残留
});

3. 捕获连接错误，主动销毁异常连接 #

当连接出现异常（比如服务器离线导致的ECONNRESET、PROTOCOL_CONNECTION_LOST错误），不要将这个连接放回连接池（release()），而是直接销毁它，避免污染连接池导致后续请求复用无效连接。

示例代码（回调版本）：

pool.getConnection((err, connection) => {
  if (err) {
    console.error('获取连接失败:', err);
    return;
  }

  connection.query('SELECT * FROM your_table', (queryErr, results) => {
    if (queryErr) {
      // 识别连接相关的错误码
      const connectionErrors = ['ECONNRESET', 'PROTOCOL_CONNECTION_LOST', 'PROTOCOL_ENQUEUE_AFTER_FATAL_ERROR'];
      if (connectionErrors.includes(queryErr.code)) {
        connection.destroy();
        console.error('连接异常，已销毁');
      } else {
        connection.release();
      }
      console.error('查询失败:', queryErr);
      return;
    }

    // 正常情况释放连接回池
    connection.release();
    console.log('查询结果:', results);
  });
});

如果用mysql2/promise的异步写法，代码会更简洁：

async function fetchData() {
  let connection;
  try {
    connection = await pool.getConnection();
    const [results] = await connection.query('SELECT * FROM your_table');
    return results;
  } catch (err) {
    const connectionErrors = ['ECONNRESET', 'PROTOCOL_CONNECTION_LOST'];
    if (connection && connectionErrors.includes(err.code)) {
      connection.destroy();
      console.error('异常连接已销毁');
    }
    throw err;
  } finally {
    if (connection && connection.state !== 'destroyed') {
      connection.release();
    }
  }
}

总结 #

把这三个方案结合起来用：

• 用信号监听保证进程正常终止时优雅关闭连接池；
• 配置超时参数让MySQL和连接池自动清理空闲连接；
• 捕获异常连接并销毁，避免污染连接池。

这样基本就能解决服务器宕机后残留连接导致的max_user_connections问题了。

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