NodeJS 集群全局变量

Question

我需要为所有工人有一个共同的计数器，每个人都可以增加它，并且所有工人都知道计数器已经增加了。 我怎样才能做到这一点 ？ 所有工作人员只能看到局部变量，并且只能看到静态全局变量。

Answer 1

要实现这一点，您需要使用 Node.js 中的 cluster 模块在工作线程和主线程之间发送消息。

示例代码

这是我刚刚整理的一个工作示例。我正在使用官方网站（9.3.0）上提供的最新版本的 Node.js。

const cluster = require('cluster');
const INCREMENT = 'INCREMENT';
const COUNTER = 'COUNTER';


if (cluster.isMaster) {

  cluster.fork();
  cluster.fork();

  let counter = 0;

  cluster.on('message', (worker, msg, handle) => {
    if (msg.topic && msg.topic === INCREMENT) {
      // here we increment the counter
      counter++;
      for (const id in cluster.workers) {
        // Here we notify each worker of the updated value
        cluster.workers[id].send({
          topic: COUNTER,
          value: counter
        });
      }
    }
  });

} else if (cluster.isWorker) {

  console.log(`Worker id: ${cluster.worker.id}`);
  // Here is a function that requests the counter be updated in the master from a worker.
  function incrementCounter() {
    process.send({ topic: INCREMENT });
  }

  // A dummy timeout to call the incrementCounter function
  setTimeout(incrementCounter, 1000 * cluster.worker.id);

  // Handle the counter update
  process.on('message', (msg) => {
    if (msg.topic && msg.topic === COUNTER) {
      console.log(`${cluster.worker.id}/${process.pid}: ${msg.topic} ${msg.value}`);
    }
  });

}

示例输出

Worker id: 1
Worker id: 2
1/1632: COUNTER 1
2/6200: COUNTER 1
2/6200: COUNTER 2
1/1632: COUNTER 2

官方文档

Here is the documentation for worker.send(message[, sendHandle][, callback])