Node.js
Cluster Module

Syntax

• const cluster = kräva ("cluster")
• cluster.fork ()
• cluster.isMaster
• cluster.isWorker
• cluster.schedulingPolicy
• cluster.setupMaster (inställningar)
• cluster.settings
• cluster.worker // i arbetare
• cluster.workers // i master

Anmärkningar

Hej världen

Detta är din 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')();
}

Detta är din huvudsakliga 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;
}

I det här exemplet är vi värd för en grundläggande webbserver, men vi spinnar upp arbetare (barnprocesser) med den inbyggda klustermodulen . Antalet processer som går ihop beror på antalet tillgängliga CPU-kärnor. Detta gör att en Node.js-applikation kan dra fördel av flerkärniga CPU: er, eftersom en enda instans av Node.js körs i en enda tråd. Applikationen kommer nu att dela porten 8000 över alla processer. Last kommer automatiskt att fördelas mellan arbetare som använder Round-Robin-metoden som standard.

Klusterexempel

En enda instans av Node.js körs i en enda tråd. För att dra fördel av flerkärniga system kan applikationer startas i ett kluster av Node.js-processer för att hantera belastningen.

I cluster kan du enkelt skapa underordnade processer som alla delar serverportar.

Följande exempel skapar arbetarbarnsprocessen i huvudprocessen som hanterar belastningen över flera kärnor.

Exempel

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);
}