使用node.js一次處理10,000個併發請求

我正在研究一個node.js應用程序，該應用程序必須向大約10,000個用戶提供實時服務器推送。我的目標是最小化第一個接收器和最後一個接收器之間的時間差。現在，我正在我的機器上進行本地開發。使用node.js一次處理10,000個併發請求

我使用一個循環來生成請求，然後阻止服務器響應，直到它達到10,0000個請求。我希望服務器能夠一次廣播所有請求並測量差異。

request.js

var http = require('http') 
, a = http.getAgent('127.0.0.1', 9202); 

var util = require('util'); 
var connections = []; 
var NUM_CONCURR = 1000; 

// Max and Min 
Array.prototype.max = function(){ 
    var max = this[0]; 
    var len = this.length; 
    for(var i=0; i<len;i++) 
    if(this[i]>max) 
    max = this[i]; 
    return max; 
}; 

Array.prototype.min = function(){ 
    var min = this[0]; 
    var len = this.length; 
    for(var i=0; i<len; i++) 
    if(this[i]<min) 
     min = this[i]; 
    return min; 
}; 

// Number of socket tested 
a.maxSockets = Infinity; 

for(var i =0; i<NUM_CONCURR; i++){ 
    http.get({ 
    agent: a, 
    path: '/', 
    port: 9202, 
    host: '127.0.0.1' 
    },function(res){ 
    connections.push(microtime(true)); 

    }); 

    util.log("Connected Clients: "+i); 
} 

util.log("Server running at port 9202"); 


setInterval(function(){ 
    util.log("Total Diff Time = "+(connections.max()-connections.min())); 
    connections =[]; 
}, 1000*10); 

// Time function 
function microtime(get_as_float) { 
    var now = new Date().getTime()/1000; 
    var s = parseInt(now); 
    return (get_as_float) ? now : (Math.round((now - s) * 1000)/1000) + ' ' + s; 
}

server.js

var http = require('http'), 
    HOST = 'localhost', 
    PORT = '9202'; 

var connections = [], i; 
var server = http.createServer(function(req, res){ 
    connections[connections.length] = {req:req, res:res}; 
    console.log('established connections: '+ ++i); 
}); 

// Send msg to stored connections 

function message(){ 
    var i = connections.length, 
     connection; 

    while(i--){ 
    connection = connections[i]; 
    connection.res.writeHead(200); 
    connection.res.write('weeeee'); 
    } 
}; 

//Broadcast after 40 sec 

setTimeout(function(){ 
    message(); 
}, 1000*40); 

server.listen(PORT); 
console.log('listening on 9202');

這出於某種原因，我沒有工作。有更好的方法嗎？誰能分享他的想法？你有什麼時差？謝謝。

來源

2011-06-13 K Lin

當你說它不適合你時，意味着什麼？你期望什麼產出，你收到了什麼？ – BCG 2011-06-15 23:02:28

取決於各種事情。您不想在真實世界的perf中在同一個盒子上測試這樣的請求/客戶端和服務器端代碼。你也可以很容易地用完插座。例如，MacOS有一個人爲的限制，一旦它被擊中，將會把所有東西都捆綁起來。

此外，關於客戶端，我想我會使用Apache工作臺，它具有併發性和分析內置的工具。http://httpd.apache.org/docs/2.0/programs/ab.html

來源

2011-06-15 22:54:34 Josh

如何增加對Mac套接字的限制？ – Cristian 2012-02-10 06:51:35

您可以使用AB基準爲喬希建議，或去npmjs .org，有一個寫在節點中的負載測試工具。否則，你可以使用JMeter。

來源

2011-06-17 23:37:27 murvinlai

使用node.js一次處理10,000個併發請求

回答

相關問題