Node.js
クラスタモジュール

構文

• const cluster = require（ "cluster"）
• cluster.fork（）
• cluster.isMaster
• cluster.isWorker
• cluster.schedulingPolicy
• cluster.setupMaster（設定）
• cluster.settings
• cluster.worker //ワーカー
• cluster.workers //マスターに

備考

こんにちは世界

これはあなたのcluster.jsです：

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

if (cluster.isMaster) {
  // 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
  require('./server.js')();
}

これがメインのserver.jsです：

const http = require('http');

function startServer() {
    const server = http.createServer((req, res) => {
      res.writeHead(200);
      res.end('Hello Http');
    });

    server.listen(3000);
}

if(!module.parent) {
    // Start server if file is run directly
    startServer();
} else {
    // Export server, if file is referenced via cluster
    module.exports = startServer;
}

この例では、基本Webサーバーをホストしていますが、組み込みのクラスタモジュールを使用して作業者（子プロセス）をスピンアップします 。 forkerプロセスの数は、利用可能なCPUコアの数に依存します。これにより、Node.jsの単一のインスタンスが単一のスレッドで実行されるため、Node.jsアプリケーションでマルチコアCPUを利用することができます。アプリケーションは、すべてのプロセスでポート8000​​を共有します。負荷は、既定でRound-Robinメソッドを使用してワーカー間で自動的に分散されます。

クラスタの例

Node.js単一のインスタンスは、単一のスレッドで実行されます。マルチコアシステムを利用するには、Node.jsプロセスのクラスタでアプリケーションを起動して負荷を処理します。

clusterモジュールを使用すると、すべてのサーバーポートを共有する子プロセスを簡単に作成できます。

次の例では、複数のコアにわたる負荷を処理するメインプロセスでワーカーの子プロセスを作成します。

例

const cluster = require('cluster');
const http = require('http');
const numCPUs = require('os').cpus().length; //number of CPUS

if (cluster.isMaster) {
  // Fork workers.
  for (var i = 0; i < numCPUs; i++) {
    cluster.fork();    //creating child process
  }

  //on exit of cluster
  cluster.on('exit', (worker, code, signal) => {
      if (signal) {
        console.log(`worker was killed by signal: ${signal}`);
      } else if (code !== 0) {
        console.log(`worker exited with error code: ${code}`);
      } else {
        console.log('worker success!');
      }
  });
} 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(3000);
}