Node.js
Кластерный модуль
Поиск…
Синтаксис
- const cluster = require ("cluster")
- cluster.fork ()
- cluster.isMaster
- cluster.isWorker
- cluster.schedulingPolicy
- cluster.setupMaster (настройки)
- cluster.settings
- cluster.worker // у рабочего
- cluster.workers // в master
замечания
Обратите внимание, что cluster.fork()
дочерний процесс, который начинает выполнять текущий скрипт с самого начала, в отличие от системного вызова fork()
в C, который клонирует текущий процесс и продолжается из инструкции после системного вызова как в родительском, так и в дочерний процесс.
Документация Node.js содержит более полное руководство по кластерам здесь
Привет, мир
Это ваш 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);
}