Node.js
Кластерный модуль

Синтаксис

• const cluster = require ("cluster")
• cluster.fork ()
• cluster.isMaster
• cluster.isWorker
• cluster.schedulingPolicy
• cluster.setupMaster (настройки)
• cluster.settings
• cluster.worker // у рабочего
• cluster.workers // в master

замечания

Привет, мир

Это ваш 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;
}

В этом примере мы размещаем базовый веб-сервер, однако мы разворачиваем рабочих (дочерние процессы) с помощью встроенного кластерного модуля. Количество обработчиков процессов зависит от количества доступных ядер процессора. Это позволяет приложению Node.js использовать многоядерные процессоры, поскольку один экземпляр Node.js работает в одном потоке. Теперь приложение будет передавать порт 8000 во все процессы. Погрузки автоматически распределяются между работниками, используя метод Round-Robin по умолчанию.

Пример кластера

Один экземпляр Node.js работает в одном потоке. Чтобы использовать многоядерные системы, приложение может быть запущено в кластере процессов Node.js для обработки нагрузки.

Модуль cluster позволяет вам легко создавать дочерние процессы, которые используют общий доступ к портам сервера.

В следующем примере создайте дочерний процесс worker в основном процессе, который обрабатывает нагрузку через несколько ядер.

пример

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