NodeJS集群模块

我正在测试NodeJS的集群模块 . 我想要实现以下目标：

• 使用两个集群工作程序启动HTTP服务器 .

• 主站和工作站启动后，主站每隔5秒向工作人员发送一条"check"消息

• 如果工作人员回复，则计数器设置为0

• 如果在下一个"check"消息之前没有消息，则计数器递增 .

• 我检查 Worker 是否在20秒内没有响应然后我杀了 Worker 并让主人开始新 Worker .

我面临的问题是：

• 当我杀死 Worker 时，下一个 Worker 进入重启，杀死，重启，杀死等循环，这意味着在任何时候只有一个 Worker 处于活动状态而另一个 Worker 没有响应，因为它进入循环 .

我的代码是：

var cluster = require('cluster');
var http = require('http');
var numCPUs = 2;
var workerStatus = new Object();

if (cluster.isMaster) {
  // Fork workers.
    for (var i = 0; i < numCPUs; i++) {
        cluster.fork(); 
    }

    cluster.on('exit', function(worker, code, signal) {
        cluster.fork();
        console.log('worker %d died (%s). restarting...', worker.process.pid, signal || code);      
    });


  // Go through all workers
    function eachWorker(callback) {
      for (var id in cluster.workers) {     
        callback(cluster.workers[id],id);
      }
    }
    setInterval(function (){
        eachWorker(function(worker,id) {    
            if (workerStatus[id] == undefined)  workerStatus[id]=-1;
            if (workerStatus[id] < 4){
                workerStatus[id]++;
                console.log("Message Sent : " + id);
                worker.send('check');
            }else{
                delete workerStatus[id]
                console.log("Some Problem with " + id);
                worker.disconnect();
                worker.kill();
            }
        });
    },5000);

    eachWorker(function(worker,id){
        var w_id =id;
        worker.on('message', function(msg){
            workerStatus[w_id]=0;
            console.log("Message Received : " + w_id);
        });
    });

} else {
    process.on('message', function(msg) {
        process.send(msg);
    });

  // Workers can share any TCP connection
  // In this case its a HTTP server
  http.createServer(function(req, res) {
    while (1) {}
    res.writeHead(200);
    res.end("hello world--" + cluster.worker.id);
    //cluster.worker.kill();
  }).listen(8080);
}