nodejs使用mysql模块自动断开

背景

第二天早上来的时候，发现接口返回异常Cannot enqueue Query after fatal error

从日志看上去，接口是正常运行的，搜索一下之后发现是数据库的问题，连接断开了

原因

MySQL中有一个名叫wait_timeout的变量，表示操作超时时间，当连接超过一定时间没有活动后，会自动关闭该连接，这个值默认为28800（即8小时）。对于这种普通连接的方式，在正式线上可能会遇到连接丢失的问题(No reconnection after connection lost错误日志)，连接丢失后不会自动重新连接，会触发error事件。

解决方案

我从网上尝试了好几种，有些自测不行，有些可以，我都列出来

连接配置中增加useConnectionPooling: true，这个我尝试了不行

let dbconfig = {host: "db_host",user: "db_user",password: "db_pass",database: "db_name",useConnectionPooling: true,debug: true,
};

捕获全局异常，判断code为PROTOCOL_CONNECTION_LOST，然后进行重启mysql，这个我也尝试了不行

process.on("uncaughtException", function (err) {if (err.code == "PROTOCOL_CONNECTION_LOST") {mysql.restart();}
});

适用于还有另一个报错的情况，Error: Connection lost The server closed the connection

监听连接报错，然后重连，这个可以

function handleError(err) {if (err) {// 如果是连接断开，自动重新连接if (err.code === "PROTOCOL_CONNECTION_LOST") {connect();} else {console.error(err.stack || err);}}
}// 连接数据库
function connect() {db = mysql.createConnection(config);db.connect(handleError);db.on("error", handleError);
}var db;
connect();

使用连接池的方式，每次查询完成之后释放连接池，这个也可行（我最后使用的是这种）

var mysql = require("mysql");
var pool = mysql.createPool(config);pool.getConnection(function (err, connection) {connection.query("SELECT something FROM sometable", function (err, rows) {connection.end();});
});

实际代码

// pool.js
const mysql = require("mysql");
const { logger } = require(process.cwd() + "/middleware/log.js");
const configObj = require("./config");const pool = mysql.createPool({connectionLimit: 10, // 设置连接池限制...configObj,
});pool.on("connection", (connection) => {console.log("数据库连接成功！");
});pool.on("error", (err) => {logger(JSON.stringify({msg: "数据库错误",error: err.message,}));if (err.code === "PROTOCOL_CONNECTION_LOST") {console.log("数据库连接丢失，尝试重新连接...");pool.on("connection");} else {throw err; // 未处理的错误}
});module.exports = pool;

// sql.js
const { logger } = require(process.cwd() + "/middleware/log.js");
const pool = require("./pool");function RunSQL(query, params) {return new Promise((resolve, reject) => {pool.getConnection((err, connection) => {if (err) {reject(err);return;}connection.query(query, params, (err, results) => {connection.release();if (err) {reject(err);return;}resolve(results);});connection.on("error", (err) => {console.error("数据库连接错误: ", err);if (err.code === "PROTOCOL_CONNECTION_LOST") {console.log("数据库连接丢失，尝试重新连接...");logger(JSON.stringify({msg: "数据库连接失败",error: err.message,}));pool.on("connection");}});});});
}module.exports = RunSQL;