可能性のある理由は、nodejsのmysqlキュー制限の到達問題を引き起こす可能性があります

Question

私は毎分0〜3000リクエスト（不規則、パターンなし）からのリクエストを受け取るnodeJsアプリケーションを持っています。リクエストの約80％〜90％がmysqlの挿入操作または更新操作を引き起こします。

ノードのバージョン - 使用nodejsフレームワークは、私は接続を取得していますRestify

でreadlineの6.2
を使用して、Debian-のlinux-gnuのための14.14按分5.5.44、（x86_64版） - 4.2.2
MySQLバージョンサイズのmysql接続プールから。

私は時間（散発的） "mysqlキューの限界に達した"問題を参照してください。何が、おそらく、この問題を引き起こす可能性があります？（別に以下の原因から）

1. 接続が適切に閉じられていない
2. キューのサイズが十分ではありません（私は、最適なキューのサイズを決定するにはどうすればよい？）nodejsと
3. 問題
4. mysqlクエリの問題（この問題に関するクエリには、どのような問題がありますか？）
5. ノードjsフレームワークを使用したProbelmを使用する（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);