和cluster.on('message')事件类似，但针对特定的工作进程。

在工作进程内，可以使用process.on('message')

详见 process event: 'message'.

在下面这个例子中，我们使用message机制来实现主进程统计cluster中请求数量的功能。

const cluster = require('cluster');const http = require('http');if (cluster.isMaster) {  // 跟踪 http 请求  let numReqs = 0;  setInterval(() => {    console.log(`numReqs = ${numReqs}`);  }, 1000);  // 计算请求数目  function messageHandler(msg) {    if (msg.cmd && msg.cmd === 'notifyRequest') {      numReqs += 1;    }  }  // 启动 worker 并监听包含 notifyRequest 的消息  const numCPUs = require('os').cpus().length;  for (let i = 0; i < numCPUs; i++) {    cluster.fork();  }  for (const id in cluster.workers) {    cluster.workers[id].on('message', messageHandler);  }} else {  // Worker 进程有一个http服务器  http.Server((req, res) => {    res.writeHead(200);    res.end('hello world\n');    // 通知 master 进程接收到了请求    process.send({ cmd: 'notifyRequest' });  }).listen(8000);}

Event: 'online'#

和cluster.on('online')事件类似，但针对特定的工作进程。

cluster.fork().on('online', () => {  // Worker is online});

本事件不会在工作进程内部被触发。

worker.disconnect()#

• Returns: 一个 worker 的引用。

在一个工作进程内，调用此方法会关闭所有的server，并等待这些server的 'close'事件执行，然后关闭IPC管道。

在主进程内，会给工作进程发送一个内部消息，导致工作进程自身调用.disconnect()。

会设置.exitedAfterDisconnect 。

需要注意的是，当一个server关闭后，它将不再接收新的连接，但新连接会被其他正在监听的工作进程接收。已建立的连接可以正常关闭。当所有连接都关闭后，通往该工作进程的IPC管道将会关闭，允许工作进程优雅地死掉，详见 server.close()。

以上情况只针对服务端连接，工作进程不会自动关闭客户端连接，disconnect方法在退出前并不会等待客户端连接关闭。

需要注意的是，我们这里的方法是disconnect，同时还有一个不一样的方法process.disconnect，大家不要混淆了。

由于长时间运行的服务端连接可能导致工作进程的disconnect方法阻塞，我们可以采用发送消息的方法，让应用采取相应的动作来关闭连接。也可以通过设置timeout，当'disconnect'事件在某段时间后仍没有触发时关闭工作进程。

if (cluster.isMaster) {  const worker = cluster.fork();  let timeout;  worker.on('listening', (address) => {    worker.send('shutdown');    worker.disconnect();    timeout = setTimeout(() => {      worker.kill();    }, 2000);  });  worker.on('disconnect', () => {    clearTimeout(timeout);  });} else if (cluster.isWorker) {  const net = require('net');  const server = net.createServer((socket) => {    // 连接永远不会结束  });  server.listen(8000);  process.on('message', (msg) => {    if (msg === 'shutdown') {      // 将所有与服务器的连接优雅关闭    }  });}

worker.exitedAfterDisconnect#

当调用 .kill() 或者 .disconnect()方法时被设置，在这之前都是 undefined。

worker.exitedAfterDisconnect可以用于区分自发退出还是被动退出，主进程可以根据这个值决定是否重新衍生新的工作进程。

cluster.on('exit', (worker, code, signal) => {  if (worker.exitedAfterDisconnect === true) {    console.log('Oh, it was just voluntary – no need to worry');  }});// 关闭 workerworker.kill();

worker.id#

每一个新衍生的工作进程都会被赋予自己独一无二的编号，这个编号就是储存在id里面。

当工作进程还存活时，id可以作为在cluster.workers中的索引。

worker.isConnected()#

当工作进程通过IPC管道连接至主进程时，这个方法返回true，否则返回false。

一个工作进程在创建后会自动连接到它的主进程，当'disconnect' 事件被触发时才会断开连接。

worker.isDead()#

当工作进程被终止时（包括自动退出或被发送信号），这个方法返回true ，否则返回false。

worker.kill([signal='SIGTERM'])#

• signal 被发送kill信号的工作进程名称。

这个方法将会kill工作进程。在主进程中，通过断开与worker.process的连接来实现，一旦断开连接后，通过signal来杀死工作进程。在工作进程中，通过断开IPC管道来实现，然后以代码0退出进程。

将导致.exitedAfterDisconnect被设置。

为向后兼容，这个方法与worker.destroy()等义。

需要注意的是，在工作进程中有一个方法process.kill() ，这个方法本方法不同，本方法是kill。

worker.process#

所有的工作进程都是通过child_process.fork()来创建的，这个方法返回的对象被存储为.process。在工作进程中， process属于全局对象。

详见：Child Process module

需要注意：当process上发生 'disconnect'事件，并且.exitedAfterDisconnect的值不是true时，工作进程会调用 process.exit(0)。这样就可以防止连接意外断开。

worker.send(message[, sendHandle][, callback])#

• message