博客

可以通过使用child_process来实现node的多进程，但是在实现多进程架构时，需要处理许多细节（比如建立监听事件，对于stdin、stdout 和 stderr 的管道处理之类的），这导致整个过程会相对较困难。为此Node提供了Cluster这个API。

Cluster模块可以轻松解决多核CPU的利用率问题，用于处理进程的健壮性问题。

var cluster = require('cluster');

cluster.setupMaster({
    exec: "worker.js"
});


var cpus = require('os').cpus();
for(var i = 0; i < cups.length; i++){
    cluster.fork();
}

官方文档给的代码

const cluster = require('cluster');
const http = require('http');
const numCPUs = require('os').cpus().length;
const process = require('process');

if (cluster.isPrimary) {
  console.log(`Primary ${process.pid} is running`);

  // Fork workers.
  for (let i = 0; i < numCPUs; i++) {
    cluster.fork();
  }

  cluster.on('exit', (worker, code, signal) => {
    console.log(`worker ${worker.process.pid} died`);
  });
} else {
  // Workers can share any TCP connection
  // In this case it is an HTTP server
  http.createServer((req, res) => {
    res.writeHead(200);
    res.end('hello world\n');
  }).listen(8000);

  console.log(`Worker ${process.pid} started`);
}

从代码可读性出现，应该区分cluster是master还是worker

通过cluster.setupMaster()创建子进程而不是使用cluster.fork()。使得代码的可读性更加高。

Cluster 工作原理

实际上就是

child_process和net模块的组合应用。

cluster启动时，会在内部启动TCP服务器，在cluster.fork()子进程时，将这个TCP服务器端socket的文件描述符发送给工作进程。如果工作进程中存在listen()侦听网络端口的调用，它将拿到该文件描述符，通过SO_REUSEADDR端口重用，从而实现多个子进程共享端口。对于普通方式启动的进程，则不存在文件描述符传递共享等事情。