什麼可能的原因會導致nodejs中的mysql隊列限制問題

Question

我有一個nodeJs應用程序，它接收每分鐘0-3000個請求（不規則，無模式）的請求。大約80％-90％的請求導致mysql插入或更新操作。

節點版本 - 4.2.2
MySQL版本 - 14.14 DISTRIB 44年5月5日，使用readline的Debian的Linux-GNU（x86_64的）6.2
使用的框架的NodeJS是的RESTify

我得到的連接從一個大小爲20的mysql連接池。

我時間到了（零星）看到「mysql queue limit reached」的問題。什麼都不可能（從以下原因分開）導致此問題？

1. 連接沒有正確關閉
2. 隊列大小是不夠的（我怎樣才能確定最佳隊列的大小？）
3. 問題用的NodeJS或MySQL版本（可使用什麼版本來解決這個？）在MySQL查詢
4. 問題（可能在此問題相關的查詢是有什麼可能的問題？）
5. 萬阿英，蔣達清與使用的NodeJS框架（會使用expressJs解決這個？）

EDIT1 這裏是一個框架我是如何查詢的數據庫

connectionPool.getConnection(function (err, conn) { 
    if (err) { 
     return callback(err); 
    } else { 
     let args = [param1, param2]; 
     let query = "SELECT..."; 

     conn.query(query, args, function (err, rows) { 
      conn.release(); 
      if (err) { 
       return callback(err); 
      } else { 
       return callback(null, rows); 
      } 
     }); 
    } 
}); 

EDIT2 這裏是mysql的配置我到現在爲止。我對這些價值觀沒有太多的想法。他們很好嗎？

{ 
    "connectionLimit": 10, 
    "acquireTimeout": 60000, 
    "host": "*****", 
    "port": "3306", 
    "user": "*****", 
    "password": "****", 
    "database": "*****", 
    "charset": "UTF8_GENERAL_CI", 
    "debug": false, 
    "waitForConnections" : true, 
    "queueLimit" : 15000 
} 

Answer 1

正是從性能的角度來看最好先用所謂的「連接池」。

連接池是維護數據庫連接緩存的機制，以便連接在釋放後可以重新使用。在Node.js MySQL池中可以直接使用來處理多個連接和更重要的 - 重用連接。例如：

var express = require("express"); 
var mysql  = require('mysql'); 
var app  = express(); 

var pool  = mysql.createPool({ 
    connectionLimit : 100, //important 
    host  : 'localhost', 
    user  : '***', 
    password : '***', 
    database : 'database_name', 
    debug : false 
}); 

function db_connect(req,res) {  
    pool.getConnection(function(err,connection){ 
     if (err) { 
      res.json({"code" : "error", "status" : "Error in database connection."}); 
      return; 
     }  
     console.log('Connection ID: ' + connection.threadId); 
     connection.query("SELECT * FROM `table1`",function(err,rows){ 
      connection.release(); 
      if(!err) { 
       res.json(rows); 
      }   
     });  
     connection.on('error', function(err) {  
       res.json({"code" : "error", "status" : "Error in database connection."}); 
     return;  
     }); 
    }); 
}  
app.get("/",function(req,res){ 
     db_connect(req,res); 
}); 
//Run on port 3000 
app.listen(3000);