当前位置: 代码迷 >> 综合 >> node环境下使用MYSQL数据库池断线后无法连接的解决办法
  详细解决方案

node环境下使用MYSQL数据库池断线后无法连接的解决办法

热度:39   发布时间:2024-02-27 16:06:59.0

1. 使用环境说明

    1.1 node 环境 5.0以上

    1.2 依赖库为: generic-pool(数据库连接池)  mysql(数据库连接库)

 

2. 原因说明: 由于generic-pool仅限于管理连接,对于连接状态是不管理的,我们需要在进行调用数据库连接的时候 进行状态判断,如果是断开连接的错误 则释放这个连接,那么再次调用的时候就可以重新创建一个新的连接,从而达到重连数据库的目的。

 

3.代码说明

var _poolModule = require('generic-pool');
var CONNECTIOMERROR = ["PROTOCOL_ENQUEUE_AFTER_FATAL_ERROR", "ECONNREFUSED"];/** Create mysql connection pool.*/
var createMysqlPool = function () {return _poolModule.Pool({name: 'mysql',create: function (callback) {var mysql = require('mysql');var client = mysql.createConnection({host: 'localhost',user: 'root',password: '123456',database: 'fishjoy',port: 3306});callback(null, client);},destroy: function (client) {client.end();},max: 10,idleTimeoutMillis: 30000,log: false});
};var poolRead = createMysqlPool();//定时查询数据库 模拟真实情况
setInterval(() => {poolRead.acquire(function (err, client) {if (!!err) {console.error('[sqlqueryErr] ' + err.stack);return;}var sql = "select * from user limit 1";client.query(sql, [], function (err, res) {//在连接这边进行判断 如果该连接失效则释放 直到连接正常 从而达到重连的目的if (!!err && CONNECTIOMERROR.indexOf(err.code) != -1) {poolRead.destroy(client);} else {poolRead.release(client);}if (err) {console.error(err.code);}});});}, 1000);// 在mysql库中认为连接断开是个致命的错误会直接抛出错误中断运行,这里需要进行捕获错误让程序运行下去
process.on('uncaughtException', function (err) {console.error(' Caught exception: ' + err.stack);
});

 

  相关解决方案