引
一個(gè)Node.js應(yīng)用程序只能使用在一個(gè)線(xiàn)程中。最近皆刺，為了充分發(fā)揮多核CPU的優(yōu)勢(shì)少辣，Node.js中提供了一個(gè)cluster模塊，允許在多個(gè)子進(jìn)程中運(yùn)行不同的Node.js應(yīng)用程序羡蛾。
使用fork方法創(chuàng)建worker對(duì)象
在cluster模塊中漓帅，可以使用fork方法開(kāi)啟多個(gè)子進(jìn)程，在每個(gè)子進(jìn)程中創(chuàng)建一個(gè)Node.js應(yīng)用程序的實(shí)例林说，并且在該應(yīng)用程序中運(yùn)行一個(gè)模塊文件
cluster.fork([env]
- env：為一個(gè)對(duì)象煎殷，用于以“鍵名/鍵值”的形式為子進(jìn)程指定環(huán)境變量屯伞。
fork方法返回一個(gè)隱式創(chuàng)建的worker對(duì)象腿箩，代表使用fork方法開(kāi)啟的子進(jìn)程中運(yùn)行的Node.js應(yīng)用程序?qū)嵗龑?duì)象。
另外劣摇，在cluster模塊中珠移，分別提供了一個(gè)isMaster屬性與一個(gè)isWorker屬性，這兩個(gè)屬性的屬性值均為一個(gè)布爾值末融。
- 如果Node.js應(yīng)用程序的實(shí)例對(duì)象運(yùn)行在主進(jìn)程中钧惧，則isMaster屬性值為true。
- 如果Node.js應(yīng)用程序的實(shí)例對(duì)象運(yùn)行在子進(jìn)程中勾习，則isWorker屬性值為true浓瞪。
在cluster模塊中，可以通過(guò)workers屬性值獲取所有子進(jìn)程中運(yùn)行的worker對(duì)象
//對(duì)workers屬性值進(jìn)行遍歷
for (var index in cluster.workers) {
console.log(cluster.workers[index]);
}
在子進(jìn)程運(yùn)行的Node.js應(yīng)用程序中巧婶，可以通過(guò)cluster.worker屬性值獲取當(dāng)前子進(jìn)程中運(yùn)行的Node.js應(yīng)用程序?qū)嵗龑?duì)象乾颁，還可以通過(guò)cluster.worker.id屬性值獲取cluster.worker對(duì)象的ID值
if (cluster.isMaster) {
cluster.fork();
}
else if (cluster.isWorker) {
console.log('I am worker #' + cluster.worker.id);
}
在子進(jìn)程運(yùn)行的Node.js應(yīng)用程序中涂乌，可以通過(guò)cluster.worker.process屬性值獲取當(dāng)前子進(jìn)程，
if (cluster.isWorker) {
worker.process.stdout.write('hello');
}
fork方法實(shí)例
var cluster = require('cluster');
var http = require('http');
if (cluster.isMaster) {
cluster.fork();
console.log('這段代碼被運(yùn)行在主進(jìn)程中英岭。');
}
else {
http.createServer(function(req, res) {
if(req.url!=="/favicon.ico"){
res.writeHead(200, {'Content-Type': 'text/html'});
res.write('<head><meta charset="utf-8"/></head>');
res.end('你好\n');
console.log("這段代碼被運(yùn)行在子進(jìn)程中湾盒。");
}
}).listen(1337);
}
當(dāng)使用fork方法開(kāi)啟子進(jìn)程時(shí)，將同時(shí)觸發(fā)fork事件诅妹，可以通過(guò)對(duì)該事件進(jìn)行監(jiān)聽(tīng)并指定事件回調(diào)函數(shù)的方法指定子進(jìn)程開(kāi)啟時(shí)所要執(zhí)行的處理
cluster.on('fork', function(worker) {
//事件回調(diào)函數(shù)代碼略
});
在使用fork方法開(kāi)啟一個(gè)新的用于運(yùn)行Node.js應(yīng)用程序的子進(jìn)程后罚勾，該應(yīng)用程序?qū)?huì)向主進(jìn)程發(fā)送一個(gè)反饋信息，當(dāng)主進(jìn)程接收到該反饋信息后吭狡，觸發(fā)online事件尖殃。可以通過(guò)對(duì)該事件進(jìn)行監(jiān)聽(tīng)并指定事件回調(diào)函數(shù)的方法指定當(dāng)子進(jìn)程中的Node.js應(yīng)用程序向主進(jìn)程發(fā)送反饋信息后所要執(zhí)行的處理
cluster.on('online', function(worker) {
//事件回調(diào)函數(shù)代碼略
});
在online事件回調(diào)函數(shù)中划煮，使用一個(gè)參數(shù)分衫，參數(shù)值為使用fork方法開(kāi)啟子進(jìn)程后返回的worker對(duì)象。
當(dāng)在子進(jìn)程中運(yùn)行的Node.js應(yīng)用程序中調(diào)用服務(wù)器的listen方法后般此，該服務(wù)器開(kāi)始對(duì)指定地址及端口進(jìn)行監(jiān)聽(tīng)蚪战，同時(shí)觸發(fā)listening事件。
cluster.on('listening', function(worker,address) {
//事件回調(diào)函數(shù)代碼略
});
- worker：為使用fork方法開(kāi)啟子進(jìn)程后返回的worker對(duì)象铐懊，
- address：為一個(gè)對(duì)象邀桑，該對(duì)象具有如下所示的屬性及屬性值。
- address：屬性值為子進(jìn)程中的服務(wù)器監(jiān)聽(tīng)的地址科乎。
- port：屬性值為子進(jìn)程中的服務(wù)器監(jiān)聽(tīng)的端口號(hào)壁畸。
- addressType：屬性值為服務(wù)器監(jiān)聽(tīng)的地址類(lèi)型。屬性值為4時(shí)茅茂，表示該地址為IPv4地址捏萍；屬性值為6時(shí)，表示該地址為IPv6地址空闲。
setupMaster
子進(jìn)程中的Node.js應(yīng)用程序默認(rèn)運(yùn)行當(dāng)前正在運(yùn)行的Node.js應(yīng)用程序中的主模塊文件令杈，可以使用setupMaster方法修改子進(jìn)程中運(yùn)行的模塊文件或修改子進(jìn)程中運(yùn)行的Node.js應(yīng)用程序的其他默認(rèn)行為。
cluster.setupMaster([settings])
- settings：在setupMaster方法中使用一個(gè)可選參數(shù)碴倾，參數(shù)值為一個(gè)用于設(shè)置子進(jìn)程中運(yùn)行的Node.js應(yīng)用程序各種默認(rèn)行為的對(duì)象逗噩，在該對(duì)象中可以使用的屬性及屬性值
- exec：屬性值為子進(jìn)程中運(yùn)行模板文件的完整路徑及文件名，默認(rèn)屬性值為當(dāng)前正在運(yùn)行的Node.js應(yīng)用程序中的主模塊文件的完整路徑文件名跌榔。
- args：屬性值為一個(gè)數(shù)組异雁，其中存放了所有運(yùn)行子進(jìn)程中的Node.js應(yīng)用程序時(shí)需要使用的參數(shù)，默認(rèn)屬性值為一個(gè)存放了由所有當(dāng)前正在運(yùn)行的Node.js應(yīng)用程序所使用的參數(shù)構(gòu)成的數(shù)組僧须。
- silent：屬性值為一個(gè)布爾值纲刀。當(dāng)屬性值為false時(shí)，子進(jìn)程對(duì)象與主進(jìn)程對(duì)象共享標(biāo)準(zhǔn)輸入/輸出；當(dāng)屬性值為true時(shí)劳跃，子進(jìn)程對(duì)象與主進(jìn)程對(duì)象不共享標(biāo)準(zhǔn)輸入/輸出蚀瘸。默認(rèn)屬性值為false静稻。
worker對(duì)象的方法與事件
在使用fork方法開(kāi)啟一個(gè)新的用于運(yùn)行Node.js應(yīng)用程序的子進(jìn)程后逆害，該應(yīng)用程序?qū)?huì)向主進(jìn)程發(fā)送一個(gè)反饋信息凶杖，當(dāng)主進(jìn)程接收到該反饋信息后顽染，觸發(fā)fork方法返回worker對(duì)象的online事件慰安∨璧ⅲ可以通過(guò)對(duì)該事件進(jìn)行監(jiān)聽(tīng)并指定事件回調(diào)函數(shù)的方法指定當(dāng)子進(jìn)程中的Node.js應(yīng)用程序向主進(jìn)程發(fā)送反饋信息后所要執(zhí)行的處理蹋砚，在該回調(diào)函數(shù)中不使用任何參數(shù)。
var cluster = require('cluster');
var http = require('http');
if (cluster.isMaster) {
var worker=cluster.fork();
console.log('這段代碼被運(yùn)行在主進(jìn)程中摄杂。');
worker.on('online', function() {
console.log("已接收到子進(jìn)程"+worker.id.toString()+"的反饋信息坝咐。");
});
}
else {
http.createServer(function(req, res) {
if(req.url!=="/favicon.ico"){
res.writeHead(200, {'Content-Type': 'text/html'});
res.write('<head><meta charset="utf-8"/></head>');
res.end('你好\n');
console.log("這段代碼被運(yùn)行在子進(jìn)程中。");
}
}).listen(1337);
}
當(dāng)在子進(jìn)程中運(yùn)行的Node.js應(yīng)用程序中調(diào)用服務(wù)器的listen方法后析恢，該服務(wù)器開(kāi)始對(duì)指定地址及端口進(jìn)行監(jiān)聽(tīng)墨坚，同時(shí)觸發(fā)用于開(kāi)啟該子進(jìn)程的worker對(duì)象的listening事件∮彻遥可以通過(guò)對(duì)該事件進(jìn)行監(jiān)聽(tīng)并指定事件回調(diào)函數(shù)的方法指定子進(jìn)程中運(yùn)行的服務(wù)器開(kāi)始監(jiān)聽(tīng)時(shí)所要執(zhí)行的處理
worker.on('listening', function(address) {
//事件回調(diào)函數(shù)代碼略
});
- address：參數(shù)值為一個(gè)對(duì)象泽篮，該對(duì)象具有如下所示的屬性及屬性值。
- address：屬性值為子進(jìn)程中的服務(wù)器監(jiān)聽(tīng)的地址柑船。
- port：屬性值為子進(jìn)程中的服務(wù)器監(jiān)聽(tīng)的端口號(hào)帽撑。
- addressType：屬性值為服務(wù)器監(jiān)聽(tīng)的地址類(lèi)型。屬性值為4時(shí)鞍时，表示該地址為IPv4地址亏拉；屬性值為6時(shí)，表示該地址為IPv6地址逆巍。
當(dāng)使用fork方法開(kāi)啟子進(jìn)程后及塘，可以使用fork方法所返回的worker對(duì)象的send方法在主進(jìn)程中向子進(jìn)程發(fā)送消息，在子進(jìn)程中也可以使用進(jìn)程對(duì)象的send方法向主進(jìn)程發(fā)送消息锐极，在Node.js內(nèi)部笙僚，這兩個(gè)方法事實(shí)上是同一種方法。該方法的使用方式如下所示溪烤。
worker.send(message,[sendHandle]) //在主進(jìn)程中向子進(jìn)程發(fā)送消息
process.send(message,[sendHandle]) //在子進(jìn)程中向主進(jìn)程發(fā)送消息
- message：用于指定需要發(fā)送的消息味咳。
- sendHandle：定為一個(gè)當(dāng)接收到對(duì)方發(fā)送消息后執(zhí)行的回調(diào)函數(shù)庇勃，也可以為一個(gè)服務(wù)器對(duì)象或socket端口對(duì)象檬嘀，以達(dá)到在主進(jìn)程與子進(jìn)程之間共享該對(duì)象的目的。
強(qiáng)制關(guān)閉子進(jìn)程
worker.kill([signal])
