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，響應超時。[強忍住不留下委屈的眼淚]
好吧，繼續看哪裏有問題吧。
參考了這個文檔：https://github.com/mysqljs/mysql

而後繼續改代碼：

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"
    }
}

哪裏說得不對，望拍磚。望指教。

附上個人Vue項目：

Vue 全家桶 + Express 實現的博客（後端API所有本身手寫，很適合剛學習vue以及express的小夥伴學習）