nodejs后台mysql数据库连接失败自动重连

2019-01-11  本文已影响19人  SimpleCXD

由于mysql的连接超时时间默认为8个小时,假设nodejs打开一个mysql的连接,如果超过8小时没有对mysql进行操作,那么此连接会自动断开。
因此,我们需要实现当mysql连接超时时,nodejs进行自动重连,并且每隔1个小时,nodejs自动ping一次数据库,刷新mysql的超时计算时间,代码如下:
(注意:以下代码没有使用mysql的连接池,采用连接池的超时重连方法类似)

const mysql = require('mysql');

// mysql 连接配置
const mysqlConf = {
  host: 'localhost',
  user: 'root',
  password: 'xxxxxx',
  database: 'myDb',
  dateStrings: true
}
// 用于保存数据连接实例
var db = null;

var pingInterval;

// 如果数据连接出错,则重新连接
function handleError(err) {
  logger.info(err.stack || err);
  connect();
}

// 建立数据库连接
function connect() {
  if (db !== null) {
    db.destroy();
    db = null;
  }

  db = mysql.createConnection(mysqlConf);
  db.connect(function (err) {
    if (err) {
      logger.info("error when connecting to db,reConnecting after 2 seconds:", err);
      setTimeout(connect, 2000);
    }
  });
  db.on("error", handleError);

  // 每个小时ping一次数据库,保持数据库连接状态
  clearInterval(pingInterval);
  pingInterval = setInterval(() => {
    console.log('ping...');
    db.ping((err) => {
      if (err) {
        console.log('ping error: ' + JSON.stringify(err));
      }
    });
  }, 3600000);
}

connect();
上一篇 下一篇

猜你喜欢

热点阅读