Node.js使用MySQL连接池出现PROTOCOL_ENQUEUE_AFTER_FATAL_ERROR错误求助

问题描述 #

我运行多个Node.js应用，使用连接限制为100的MySQL连接池。应用运行超过一天后，查询开始抛出以下错误：

Error: Cannot enqueue Query after fatal error.
    at Protocol._validateEnqueue (/root/app/node_modules/mysql/lib/protocol/Protocol.js:212:16)
    at Protocol._enqueue (/root/app/node_modules/mysql/lib/protocol/Protocol.js:138:13)
    at PoolConnection.query (/root/app/node_modules/mysql/lib/Connection.js:198:25)
    at execute (/root/app/database/database2.js:39:9)
    at /root/app/commands/origin.js:164:5
    at new Promise (<anonymous>)
    at Object.checkExisting (/root/app/commands/origin.js:163:28)
    at Object.event (/root/app/commands/origin.js:126:32)
    at Object.init (/root/app/commands/origin.js:52:14)
    at Client.event (/root/app/events/interaction.js:86:18) {
  code: 'PROTOCOL_ENQUEUE_AFTER_FATAL_ERROR',
  fatal: false
}

我已经调研过，查到的方案都是“使用连接池”，但我本身已经在使用连接池，且确保查询完成后将连接释放回池。现在想知道：

1. 是否有方法检测致命错误并重启连接？
2. 还有哪些方向可以排查该问题的成因？

当前数据库配置代码：

//database.js file

let mysql = require(`mysql`);
let cred = require(`../config/config.json`)[`database`];

exports.con = {
    name: `con`,
    init: async function(){     
        return new Promise((resolve, reject) => {   
            let pool = mysql.createPool(this.serverDetails);
                pool.getConnection((error, con) => {
                    if(error){
                        reject();
                    }else{
                        resolve(con);
                    }
                });
        }).catch(e => console.log(e));
    },
    serverDetails: {
        connectionLimit: 100,
        host     : cred[`host`],
        user     : cred[`user`],
        password : cred[`pass`],
        database : cred[`database`],
    },
};

exports.query = {
    bind: c => con = c,
    execute: (statement, details, callback) => {
        if(details){
            con.query(statement, details, function(error, results, fields){
                con.release();
                callback(error, results, fields);
            });
        }else{
            con.query(statement, function(error, results, fields){
                con.release();
                callback(error, results, fields);
            });
        }
    },
};

示例查询代码：

await new Promise(async (resolve) => query(`INSERT INTO \`tableName\` SET ${newString} ON DUPLICATE KEY UPDATE ${newString}`, (e, r, f) => resolve(e ? console.log(e) : 0))).catch(e => console.log(e));

一、检测致命错误并重启连接的方法 #

1. 全局复用连接池并监听错误事件 #

你的当前代码每次调用init都会创建新连接池，这会导致连接管理混乱。改成全局维护一个连接池实例，同时监听错误事件自动处理失效连接：

let mysql = require(`mysql`);
let cred = require(`../config/config.json`)[`database`];

// 全局单例连接池
const pool = mysql.createPool({
    connectionLimit: 100,
    host     : cred[`host`],
    user     : cred[`user`],
    password : cred[`pass`],
    database : cred[`database`],
    idleTimeoutMillis: 30000, // 30秒自动回收闲置连接
    waitForConnections: true // 连接耗尽时等待新连接释放
});

// 监听连接池全局错误
pool.on('error', (err) => {
    console.error('连接池错误:', err);
    // 针对致命连接错误，连接池会自动尝试重建连接，这里只需做日志告警
    if (['PROTOCOL_CONNECTION_LOST', 'PROTOCOL_ENQUEUE_AFTER_FATAL_ERROR'].includes(err.code)) {
        console.warn('检测到致命连接错误，连接池将自动重建连接');
    }
});

exports.query = {
    execute: (statement, details, callback) => {
        // 直接用pool.query，无需手动管理连接（自动获取、释放）
        pool.query(statement, details, callback);
    },
};

2. 单个查询错误中处理失效连接 #

如果需要更精细的控制，可以在查询回调中判断错误码，主动销毁失效连接并重试：

exports.query = {
    execute: (statement, details, callback) => {
        pool.getConnection((connErr, con) => {
            if (connErr) return callback(connErr);
            
            con.query(statement, details, (queryErr, results, fields) => {
                if (queryErr && queryErr.code === 'PROTOCOL_ENQUEUE_AFTER_FATAL_ERROR') {
                    con.destroy(); // 销毁失效连接，避免放回池里
                    // 自动重试一次查询
                    pool.query(statement, details, callback);
                    return;
                }
                con.release();
                callback(queryErr, results, fields);
            });
        });
    },
};

二、问题成因排查方向 #

1. 连接池使用逻辑错误 #

你的当前代码存在两个关键问题：

• 每次init创建新连接池，导致多个池实例共存，连接资源被分散且难以管理
• query模块依赖全局con变量，一旦这个连接失效，所有后续查询都会报错

必须改成全局单例连接池，避免重复创建。

2. MySQL服务器超时配置 #

检查MySQL的wait_timeout和interactive_timeout参数，如果值设置过小（比如默认8小时），MySQL会主动关闭闲置连接，但连接池不会感知到，后续复用该连接就会报错。

• 可以在MySQL中执行SHOW VARIABLES LIKE '%timeout%';查看配置
• 调整为更大的值（比如28800秒，即8小时），或者在连接池配置中通过idleTimeoutMillis让池自动回收闲置连接

3. 未处理的连接错误 #

当网络波动、MySQL重启时，连接会失效，如果没有监听error事件，失效连接会留在池中。后续被复用就会抛出致命错误，必须监听连接池和单个连接的错误事件。

4. SQL查询写法问题 #

你的示例查询用字符串拼接生成SQL，不仅有SQL注入风险，还可能因为拼接错误导致查询失败，进而影响连接状态。必须改用参数化查询：

// 正确的参数化查询示例
await new Promise((resolve) => {
    query.execute(
        'INSERT INTO `tableName` SET ? ON DUPLICATE KEY UPDATE ?',
        [insertData, updateData], // 用对象传递参数，自动转义
        (e, r, f) => resolve(e ? console.log(e) : 0)
    );
}).catch(e => console.log(e));

5. 连接泄漏风险 #

虽然你说会释放连接，但要排查是否存在分支代码中遗漏con.release()的情况（比如错误回调中提前return但未释放）。使用pool.query会自动管理连接生命周期，无需手动调用release，建议优先使用这种方式。

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