引

一个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])
文章目录