主页 / 问题 / 983899
Accepted
Артём Ионаш
Asked:2020-05-21 19:52:50 +0000 UTC2020-05-21 19:52:50 +0000 UTC

如何在 Node.js 中正确组织多进程应用程序？

  • 772

源代码如下所示：

const listener = new Listener();

listener.start();

process.on('SIGTERM', () => {
  listener.stop();
});

有必要除以Listener二，以便在子进程中取出类似的结构（例如，在处理器内核之间划分负载）。

使用 Node.js 执行此操作的正确方法是什么？

javascript

1 个回答

  1. Best Answer

    1. 异构子进程

    据我了解，子进程处理程序必须放在单独的文件中，而 Node.js 目前不提供另一种解决方案：

    ./index.js

    const { fork } = require('child_process');

const processHandlers = [
  './subprocess/process1.js',
  './subprocess/process2.js',
];

const processes = processHandlers.map((h) => fork(h, []));

process.on('SIGTERM', () => {
  processes.forEach((process) => process.send('stop'));
});

    ./subprocess/process1.js

    const listener = new Listener1();    
listener.start();

process.on('message', (m) => {
  if (m === 'stop') {
    listener.stop();
    process.disconnect();
  }
});

    ./subprocess/process2.js

    const listener = new Listener2();
listener.start();

process.on('message', (m) => {
  if (m === 'stop') {
    listener.stop();
    process.disconnect();
  }
});

    2. 同构子进程

    如果孩子是同类竞争计算单元，您可以使用集群模块：

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

if (cluster.isMaster) {
  // Обработчик ведущего процесса

  // Запуск дочерних процессов
  for (let i = 0; i < numCPUs; i++) {
    cluster.fork();
  }

  cluster.on('exit', (worker, code, signal) => {
    console.log(`worker ${worker.process.pid} died`);
  });
} else {
  // Обработчик дочерних процессов
  console.log(`Worker ${process.pid} started`);
}
    • 5

相关问题