mongoDB を使用して単純な node.js サーバーからの同時要求を処理するのに問題があります。
私がやっていることは、mongo シェル形式でクエリを送信し、それらを解析して、mongoDB からデータを送り返すことです。
しかし、何らかの理由で同時に複数のリクエストを処理できないようです..（ところで、ローカルで使用しています）
編集:クライアントアプリでこのエラーが発生することがあります:
"Stream Error. URL: http://localhostlink:1337"
サーバーが実行されていないときにも取得します...
EDIT2: db.close ステートメントを削除しました。
クラスターは本当に適切なソリューションですか?アプリをアップグレードして 4 つの同時要求を処理するだけですが、まだ十分ではありません。
他の方法でサーバーを完全にリファクタリングする必要がありますか? mongoDB からのデータに対する複数の要求を処理できるようにしたいだけです。
EDIT3：
最初にサーバーを作成してからmongoに接続しても問題ありませんか、それともMongoClient.connect(...)関数内でサーバーを作成する必要がありますか?
これは私の（最適化されていない）サーバーのコードです：
var http = require('http');
var qs = require('querystring');
var mongo =require('mongodb');
var MongoClient = mongo.MongoClient;
var result;
var response;
var ObjectId = require('mongodb').ObjectID;
var myDb;
http.createServer(function (request, res) {
console.log("creating server...");
MongoClient.connect("mongodb://127.0.0.1:27017/lalal", function(err, db) {
if(err) { return console.dir(err); }
if (request.method == 'POST') {
var body = '';
response = res;
request.on('data', function (data) {
body += data;
// 1e6 === 1 * Math.pow(10, 6) === 1 * 1000000 ~~~ 1MB
if (body.length > 1e6) {
// FLOOD ATTACK OR FAULTY CLIENT, NUKE REQUEST
request.connection.destroy();
}
});
request.on('end', function () {
var clientData = qs.parse(body);
var parts = clientData.data.split(".");
var collectionName = parts.shift();
var queryBig = parts.join(".");
var queryParts = queryBig.split("(");
var method = queryParts[0];
var query = queryParts.join("(");
console.log("query:"+query);
console.log("method:"+method);
console.log("collection:"+collectionName);
var callback;
switch(method){
case 'find':
callback = '.toArray(findCallback);';
break;
case 'insert':
query = query.substring(0, query.length - 1);
callback = ',insertCallback);';
break;
case 'remove':
query = query.substring(0, query.length - 1);
callback = ',removeCallback);'
break;
case 'save':
query = query.substring(0, query.length - 1);
callback = ',saveCallback);'
break;
case 'update':
query = query.substring(0, query.length - 1);
callback = ',updateCallback);'
break;
}
if(query.indexOf('"_id"') != -1)
{
var indexHelper = query.indexOf('"_id"')+7;
var s = query.substring(indexHelper, query.length);
var indexOfQuote = s.indexOf('"')
var restOfQuery = s.substring(indexOfQuote+1,s.length);
var key = s.substring(0,indexOfQuote);
query = query.substring(0,indexHelper-1) + 'new ObjectId("'+key +'")'+restOfQuery;
}
// Connect to the db
// myDb = db;
var collection = db.collection(collectionName);
var command = 'collection.'+query+callback;
console.log("command:"+command);
eval(command);
function findCallback(err, items){
console.log(items);
response.writeHead(200, {'Content-Type': 'text/plain'});
response.end(JSON.stringify(items));
}
function insertCallback(err, objects) {
console.log(objects);
if (err) console.warn(err.message);
if (err && err.message.indexOf('E11000 ') !== -1) {
response.writeHead(200, {'Content-Type': 'text/plain'});
response.end('"error":"_id already exists"');
}
else{
response.writeHead(200, {'Content-Type': 'text/plain'});
response.end(JSON.stringify(objects));
}
}
function removeCallback(err, numberOfRemovedDocs) {
response.writeHead(200, {'Content-Type': 'text/plain'});
response.end(JSON.stringify(numberOfRemovedDocs));
}
function saveCallback(err, result) {
response.writeHead(200, {'Content-Type': 'text/plain'});
response.end(JSON.stringify(result));
}
function updateCallback(err, numberOfUpdatedDocs) {
response.writeHead(200, {'Content-Type': 'text/plain'});
response.end(JSON.stringify(numberOfUpdatedDocs));
}
});
}
});
}).listen(1337, '127.0.0.1');
console.log('Server running at http://127.0.0.1:1337/');