前段时间做的项目中,要用到 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"
}
}
哪里说得不对,望拍砖。望指教。