Node之在多个子进程中运行Node.js应用程序

一个Node.js应用程序只能使用在一个线程中。最近,为了充分发挥多核CPU的优势,Node.js中提供了一个cluster模块,允许在多个子进程中运行不同的Node.js应用程序。

使用fork方法创建worker对象

在cluster模块中,可以使用fork方法开启多个子进程,在每个子进程中创建一个Node.js应用程序的实例,并且在该应用程序中运行一个模块文件

cluster.fork([env]
  • env:为一个对象,用于以“键名/键值”的形式为子进程指定环境变量。

fork方法返回一个隐式创建的worker对象,代表使用fork方法开启的子进程中运行的Node.js应用程序实例对象。

另外,在cluster模块中,分别提供了一个isMaster属性与一个isWorker属性,这两个属性的属性值均为一个布尔值。

  • 如果Node.js应用程序的实例对象运行在主进程中,则isMaster属性值为true。
  • 如果Node.js应用程序的实例对象运行在子进程中,则isWorker属性值为true。

在cluster模块中,可以通过workers属性值获取所有子进程中运行的worker对象

//对workers属性值进行遍历
for (var index in cluster.workers) {
    console.log(cluster.workers[index]);
}

在子进程运行的Node.js应用程序中,可以通过cluster.worker属性值获取当前子进程中运行的Node.js应用程序实例对象,还可以通过cluster.worker.id属性值获取cluster.worker对象的ID值

if (cluster.isMaster) {
    cluster.fork();
}
else if (cluster.isWorker) {
    console.log('I am worker #' + cluster.worker.id);
}

在子进程运行的Node.js应用程序中,可以通过cluster.worker.process属性值获取当前子进程,

if (cluster.isWorker) {
    worker.process.stdout.write('hello');
}

fork方法实例

var cluster = require('cluster');
var http = require('http');
if (cluster.isMaster) {
    cluster.fork();
    console.log('这段代码被运行在主进程中。');
}
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("这段代码被运行在子进程中。");
        }
    }).listen(1337);
}

当使用fork方法开启子进程时,将同时触发fork事件,可以通过对该事件进行监听并指定事件回调函数的方法指定子进程开启时所要执行的处理

cluster.on('fork', function(worker) {
    //事件回调函数代码略
});

在使用fork方法开启一个新的用于运行Node.js应用程序的子进程后,该应用程序将会向主进程发送一个反馈信息,当主进程接收到该反馈信息后,触发online事件。可以通过对该事件进行监听并指定事件回调函数的方法指定当子进程中的Node.js应用程序向主进程发送反馈信息后所要执行的处理

cluster.on('online', function(worker) {
    //事件回调函数代码略
});

在online事件回调函数中,使用一个参数,参数值为使用fork方法开启子进程后返回的worker对象。

当在子进程中运行的Node.js应用程序中调用服务器的listen方法后,该服务器开始对指定地址及端口进行监听,同时触发listening事件。

cluster.on('listening', function(worker,address) {
    //事件回调函数代码略
});
  • worker:为使用fork方法开启子进程后返回的worker对象,
  • address:为一个对象,该对象具有如下所示的属性及属性值。
    • address:属性值为子进程中的服务器监听的地址。
    • port:属性值为子进程中的服务器监听的端口号。
    • addressType:属性值为服务器监听的地址类型。属性值为4时,表示该地址为IPv4地址;属性值为6时,表示该地址为IPv6地址。

setupMaster

子进程中的Node.js应用程序默认运行当前正在运行的Node.js应用程序中的主模块文件,可以使用setupMaster方法修改子进程中运行的模块文件或修改子进程中运行的Node.js应用程序的其他默认行为。

cluster.setupMaster([settings])
  • settings:在setupMaster方法中使用一个可选参数,参数值为一个用于设置子进程中运行的Node.js应用程序各种默认行为的对象,在该对象中可以使用的属性及属性值
    • exec:属性值为子进程中运行模板文件的完整路径及文件名,默认属性值为当前正在运行的Node.js应用程序中的主模块文件的完整路径文件名。
    • args:属性值为一个数组,其中存放了所有运行子进程中的Node.js应用程序时需要使用的参数,默认属性值为一个存放了由所有当前正在运行的Node.js应用程序所使用的参数构成的数组。
    • silent:属性值为一个布尔值。当属性值为false时,子进程对象与主进程对象共享标准输入/输出;当属性值为true时,子进程对象与主进程对象不共享标准输入/输出。默认属性值为false。

worker对象的方法与事件

在使用fork方法开启一个新的用于运行Node.js应用程序的子进程后,该应用程序将会向主进程发送一个反馈信息,当主进程接收到该反馈信息后,触发fork方法返回worker对象的online事件。可以通过对该事件进行监听并指定事件回调函数的方法指定当子进程中的Node.js应用程序向主进程发送反馈信息后所要执行的处理,在该回调函数中不使用任何参数。

var cluster = require('cluster');
var http = require('http');
if (cluster.isMaster) {
var worker=cluster.fork();
    console.log('这段代码被运行在主进程中。');
    worker.on('online', function() {
        console.log("已接收到子进程"+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("这段代码被运行在子进程中。");
        }
    }).listen(1337);
}

当在子进程中运行的Node.js应用程序中调用服务器的listen方法后,该服务器开始对指定地址及端口进行监听,同时触发用于开启该子进程的worker对象的listening事件。可以通过对该事件进行监听并指定事件回调函数的方法指定子进程中运行的服务器开始监听时所要执行的处理

worker.on('listening', function(address) {
    //事件回调函数代码略
});
  • address:参数值为一个对象,该对象具有如下所示的属性及属性值。
    • address:属性值为子进程中的服务器监听的地址。
    • port:属性值为子进程中的服务器监听的端口号。
    • addressType:属性值为服务器监听的地址类型。属性值为4时,表示该地址为IPv4地址;属性值为6时,表示该地址为IPv6地址。

当使用fork方法开启子进程后,可以使用fork方法所返回的worker对象的send方法在主进程中向子进程发送消息,在子进程中也可以使用进程对象的send方法向主进程发送消息,在Node.js内部,这两个方法事实上是同一种方法。该方法的使用方式如下所示。

worker.send(message,[sendHandle]) //在主进程中向子进程发送消息
process.send(message,[sendHandle]) //在子进程中向主进程发送消息
  • message:用于指定需要发送的消息。
  • sendHandle:定为一个当接收到对方发送消息后执行的回调函数,也可以为一个服务器对象或socket端口对象,以达到在主进程与子进程之间共享该对象的目的。

强制关闭子进程

worker.kill([signal])
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 204,445评论 6 478
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,889评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 151,047评论 0 337
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,760评论 1 276
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,745评论 5 367
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,638评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,011评论 3 398
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,669评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,923评论 1 299
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,655评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,740评论 1 330
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,406评论 4 320
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,995评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,961评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,197评论 1 260
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 45,023评论 2 350
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,483评论 2 342

推荐阅读更多精彩内容