クラスターを使用してノードサーバーをマルチスレッドのserver_node.jsに拡張します。

if (cluster.isMaster) {
// フォークワーカー。
for (var i = 0; i cluster.fork();
}

cluster.on('exit', function(worker, code, signal) {
console.log('ワーカー ' worker.process.pid ' が死亡しました');
});
} else {
// ワーカーは任意の TCP 接続を共有できます
// この場合は HTTP サーバーです
http.createServer(function(req, res) {
res.writeHead(200);
res.end("hello worldn");
}).listen(8000);
}

if (cluster.isMaster) {

var ワーカー=[];
// 新しいワーカーを作成します
関数 newWorker(){
var worker=cluster.fork();

//情報を聞き、その種類がブロードキャストであればブロードキャストと判断します
worker.on('メッセージ', function(msg) {
If(msg.type=='ブロードキャスト'){
varevent=msg.event;
//このブロードキャストをすべてのワーカーに送信します
works.forEach(function(worker){
ワーカー.send(イベント);
})
}
});
従業員を復帰させます;
}

for (var i = 0; i Workers.push(newWorker());
}

cluster.on('online',function(worker){
console.log('ワーカー %d はオンラインです',worker.id);
})
} else {
var worker=cluster.worker;

//ブロードキャストはブロードキャストタイプのメッセージを送信するもので、イベントはブロードキャストの内容です
worker.broadcast=関数(イベント){
worker.send({
タイプ: 'ブロードキャスト'、
イベント:イベント
});
}

//ここではworker.onを使用して返された情報を監視することはできないようです
process.on('メッセージ',function(イベント){
console.log('worker: 'worker.id ' が 'event.workerId からイベントを受け取りました);
})

//ブロードキャストを送信
worker.broadcast({
メッセージ:'オンライン'、
ワーカーID:ワーカー.id
})
}