MySQL 连接异常导致的 ECONNRESET 错误处理与连接池最佳实践-js教程-PHP中文网

MySQL 连接异常导致的 ECONNRESET 错误处理与连接池最佳实践

Node.js 应用连接 MySQL 后自动抛出 read ECONNRESET 错误，通常由网络中断、服务端主动断连或连接空闲超时引起；本文详解错误成因、错误捕获机制及推荐使用连接池实现健壮、自动恢复的数据库连接。

node.js 应用连接 mysql 后自动抛出 `read econnreset` 错误，通常由网络中断、服务端主动断连或连接空闲超时引起；本文详解错误成因、错误捕获机制及推荐使用连接池实现健壮、自动恢复的数据库连接。

read ECONNRESET 是 Node.js 中典型的底层 TCP 连接重置错误，表示客户端在尝试读取数据时，远程服务器（此处为 MySQL）已意外关闭连接。该错误并非发生在查询执行阶段，而常出现在连接空闲一段时间后——例如 MySQL 服务端配置了 wait_timeout（默认通常为 28800 秒，即 8 小时），当连接无任何活动超过此阈值，服务端会主动终止连接；此时若应用仍尝试复用该已失效 socket，便触发 ECONNRESET。

✅ 正确做法：避免崩溃 + 主动容错

首要原则是绝不让未捕获的连接错误导致进程崩溃。MySQL 官方驱动（如 mysql 或 mysql2）的连接对象是 EventEmitter，需显式监听 'error' 事件：

const mysql = require('mysql');

const connection = mysql.createConnection({ /* config */ });

connection.on('error', (err) => {
  if (err.code === 'PROTOCOL_CONNECTION_LOST') {
    console.warn('MySQL connection lost. Reconnecting...');
    // 可在此触发重连逻辑（不推荐手动管理）
  } else if (err.code === 'ECONNRESET') {
    console.warn('MySQL connection reset by peer.');
  } else {
    console.error('Unexpected MySQL error:', err);
  }
});

connection.connect((err) => {
  if (err) {
    console.error('Initial connection failed:', err);
  } else {
    console.log('Connected to MySQL');
  }
});

⚠️ 注意：仅监听 'error' 不足以覆盖所有场景（如查询中连接中断），因此更推荐配合 try-catch（针对 async/await 场景）或 .catch()（Promise 链）：

// 使用 mysql2（支持 Promise）示例
const mysql = require('mysql2/promise');

const pool = mysql.createPool({
  host: 'localhost',
  user: 'root',
  password: 'pass',
  database: 'test',
  waitForConnections: true,
  connectionLimit: 10,     // 推荐设为 >1 以提升并发能力
  queueLimit: 0,
  acquireTimeout: 60000
});

// 安全执行查询
async function safeQuery(sql, params = []) {
  let conn;
  try {
    conn = await pool.getConnection();
    const [rows] = await conn.execute(sql, params);
    return rows;
  } catch (err) {
    console.error('Database operation failed:', err);
    throw err; // 或按业务逻辑降级处理
  } finally {
    if (conn) conn.release(); // 必须释放，否则连接泄漏
  }
}