Node 连接 MySQL 遇到的坑以及踩坑总结

前段时间做的项目中,要用到 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"
    }
}

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

    原文作者:MySql
    原文地址: https://juejin.im/entry/5959ddcc6fb9a06bb95ac0a6
    本文转自网络文章,转载此文章仅为分享知识,如有侵权,请联系博主进行删除。
点赞