Node.jsCluster模块的应用与性能测试分析

首先安装async包

用到的有http、cluster包

http和cluster都会node自带的包，无需安装

1：创建cluster.js，代码如下，更具cpu创建多个进程

var cluster = require("cluster");
var http = require("http");
var
numCPUs = require(‘os‘).cpus().length;

if(cluster.isMaster){

    console.log("[master] " + "start master......");

    var data = 0;

    for(var i=0; i

        var work_process =
cluster.fork();

    }

    cluster.on("listening", function(worker, address){

        console.log("[master] " +
"listening: worker "+worker.id + ", pid:"+worker.process.pid + ",Address:" +
address.address + ":" + address.port);

    });

    cluster.on("exit", function(worker, code, signal){

        console.log(‘worker ‘ +
worker.process.pid + ‘ died‘);

    });

}else{

    http.createServer(function(req, res){

        console.log("worker" +
cluster.worker.id);

        res.end("worker" +
cluster.worker.id);

    }).listen(30001);

}

执行该文件会看到有多个进程现在

2：创建httpClient.js用来请求刚才创建的30001端口的服务

var http = require("http");

var optiOns= {

    hostname: ‘localhost‘,

    port: 30001,

    path: ‘/‘,

    method: ‘GET‘

};

module.exports = function(callback){

    var req = http.request(options, function(res) {

        res.on(‘data‘, function (chunk)
{

           
callback(chunk.toString());

        });

    });

    req.on(‘error‘, function(e) {

        console.log(‘problem with request:
‘ + e.message);

    });

    req.end();

};

3：创建test.js测试同步跑多个请求，最后统计出各个进程走的请求数量

var async = require("async");
var httpClient =
require("./httpClient");

var sum = 10;
var t = {"1":0, "2":0,"3":0, "4":0};
var c=0;

for(var i=0; i   
async.series([
       
function(cb){
           
httpClient(function(str){
               
if(str ===
"worker1")
                   
t["1"] = parseInt(t["1"] || 0) +
1;
               
if(str ===
"worker2")
                   
t["2"] = parseInt(t["2"] || 0) +
1;
               
if(str ===
"worker3")
                   
t["3"] = parseInt(t["3"] || 0) +
1;
               
if(str ===
"worker4")
                   
t["4"] = parseInt(t["4"] || 0) +
1;
               
cb();
           
});
        }
    ],
function(err, result){
       
if(err){
           
console.log(err);
       
}
       
c++;
        if(c ==
sum){
           
console.log(t);
       
}
    });
}

node cluster模块的使用和测试,布布扣,bubuko.com