前段时间做的项目中，要用到 express+mysql。先看看我最初的实现代码：

 var conn = mysql.createConnection({
  host : 'example.org',
  user : 'bob',
  password : 'secret',
  database : 'my_db',
 port: '3306'
  });
 conn.connect();

没问题啊，能连上数据库，本地测试一切正常。最后，将项目放在服务器上，导致API请求超时，总报504错误。我也很纳闷啊，怎么就504了，服务器上我是用pm2守护node进程的。最后查看了pm2的logs，发现是报错了。我也不知道是哪里出问题了呀，Nginx配置？pm2配置？自身代码问题？

最后分析了下pm2 logs，发现是异常没处理好，查了下，才知道当连接超过一定时间没有活动后，会自动关闭与数据库的连接。因为mysql连接断开，我没有做异常处理，导致错误的代码继续在运行,导致node没有结束进程,所以node进程这些都好着，就是连不上数据库，重启服务就又恢复正常。过那么久又会出现问题。

好吧，那就给代码做异常处理：

function handleError(err) {
    if (err) {
        // 如果是连接异常，自动重新连接
        console.log('err code:' + err.code);
        if (err.code === 'PROTOCOL_CONNECTION_LOST' || err.code === 'PROTOCOL_ENQUEUE_AFTER_FATAL_ERROR' || err.code === 'ETIMEDOUT') {
            connect();
        } else {
            console.error(err.stack || err);
        }
    }
}

function connect() {
    conn = mysql.createConnection(models.mysql);
    conn.connect(handleError);
    conn.on('error', handleError);
}
var conn;
connect();

再来写个接口：

router.use('/addUser', (req, res) => {
    var sql = 'insert into user_info(user_name, user_pwd) values (?,?)';
    var params = req.body;
    console.log(params);
    conn.query(sql, [params.username, params.pwd], function(err, result) {
        if (err) {
            console.log(err);
            connect();
        }
        if (result) {
            jsonWrite(res, result);
        }
    })
});

就这样愉快的放到线上，没问题啊，可是第二天起来,接口又504，响应超时。[强忍住不留下委屈的眼泪]
好吧，继续看哪里有问题吧。
参考了这个文档：github.com/mysqljs/mys…

然后继续改代码：

var jsonWrite = function(res, ret) {
    if (typeof ret === 'undefined') {
        res.json({
            code: '1',
            msg: '操作失败'
        });
    } else {
        res.json(ret);
    }
};

var mysql = require('mysql');
var pool  = mysql.createPool({
   host            : 'example.org',
   user            : 'bob',
   password        : 'secret',
   database        : 'my_db',
   port: '3306'
});
    var sql = 'insert into user_info(user_name, user_pwd) values (?,?)';
    var params = req.body;
    console.log(params);
    pool.query(sql,[params.username, params.pwd], function (error, results, fields) {
    if (error) throw error;
    if (results) {
            console.log(results)
            jsonWrite(res, results);
    }
});

哈哈哈哈哈，完美解决，上线10多天，没有出现任何问题。我也有用pm2去守护node进程，附上我的pm2配置：

{
    "name": "index",
    "cwd": "/usr/share/nginx/html/server",
    "script": "index.js",
    "max_memory_restart": "35M",
    "cron_restart": "1 0 * * *",
    "watch": true,
    "exec_interpreter": "node",
    "exec_mode": "fork",
    "autorestart": true,
    "env": {
        "NODE_ENV": "production"
    }
}

哪里说得不对，望拍砖。望指教。