Nodejs 多进程：子进程与父进程如何进行消息的传递

Nodejs 多进程：子进程与父进程如何进行消息的传递

通过使用cluster库，我fork了几个进程，现在想让主进程每隔多少分钟显示一次子进程的内存使用情况，请问如何将子进程的消息传递给父进程呢？

5 回复

当然可以。在Node.js中，你可以使用内置的child_process模块来创建子进程，并通过IPC（进程间通信）来实现子进程与父进程之间的消息传递。下面是一个简单的例子，展示了如何实现这一功能。

示例代码

父进程（主进程）

const cluster = require('cluster');
const http = require('http');

if (cluster.isMaster) {
    console.log(`Master process is running with PID: ${process.pid}`);

    // Fork a worker
    const worker = cluster.fork();

    // Set up an interval to check memory usage every minute
    setInterval(() => {
        if (worker.isConnected()) {
            worker.send({ action: 'memory' });
        }
    }, 60000); // 每隔60秒发送一次消息

    // Listen for messages from the worker
    worker.on('message', (msg) => {
        if (msg.action === 'memory') {
            console.log(`Worker ${worker.process.pid} Memory Usage: ${msg.memoryUsage}`);
        }
    });
} else {
    // Worker process
    const memoryInterval = setInterval(() => {
        process.send({
            action: 'memory',
            memoryUsage: process.memoryUsage().heapUsed / 1024 / 1024
        });
    }, 5000); // 每隔5秒向父进程报告一次内存使用情况

    process.on('disconnect', () => {
        clearInterval(memoryInterval);
    });
}

解释

  1. 父进程：

    • 使用cluster.fork()方法创建一个子进程。
    • 使用setInterval定时器每60秒向子进程发送一个消息，请求内存使用信息。
    • 监听来自子进程的消息，当接收到包含内存使用信息的消息时，打印出来。

  2. 子进程：

    • 每隔5秒计算并发送一次当前内存使用情况。
    • 当接收到父进程的disconnect事件时，清理定时器。

关键点

  • 使用process.send()方法发送消息。
  • 使用process.on('message')监听来自父进程的消息。
  • 使用worker.send()方法向子进程发送消息。
  • 使用worker.on('message')监听来自子进程的消息。

这样，你就可以通过IPC机制实现在父进程和子进程之间传递消息。


自己先顶一下

使用cluster自带的send方法向主进程发送消息。具体参考：http://nodejs.org/api/cluster.html#cluster_worker_send_message_sendhandle

好的，谢啦

在Node.js中，可以通过child_process模块中的process.send()方法和监听message事件来实现子进程与父进程之间的通信。cluster模块实际上就是基于child_process模块来实现多进程管理的。

以下是一个简单的例子，展示如何让父进程每隔一段时间获取子进程的内存使用情况：

const cluster = require('cluster');
const os = require('os');

if (cluster.isMaster) {
  const numCPUs = os.cpus().length;

  for (let i = 0; i < numCPUs; i++) {
    cluster.fork();
  }

  setInterval(() => {
    cluster.workers.forEach((worker) => {
      worker.send('getMemoryUsage');
    });
  }, 60000); // 每隔1分钟发送一次消息

  process.on('message', (msg) => {
    if (msg === 'memoryUsage') {
      console.log(`Worker ${worker.id} memory usage: ${msg.memoryUsage}`);
    }
  });

} else { // 子进程
  process.on('message', (msg) => {
    if (msg === 'getMemoryUsage') {
      process.send({
        workerId: cluster.worker.id,
        memoryUsage: process.memoryUsage()
      });
    }
  });
}

在这个例子中：

  1. 父进程使用cluster.fork()方法创建了多个子进程。
  2. 使用setInterval函数每分钟向每个子进程发送一条消息（'getMemoryUsage'）。
  3. 子进程监听到消息后，使用process.send()方法将自身的内存使用情况发送回父进程。
  4. 父进程监听子进程发送过来的消息，并打印子进程的内存使用情况。

这样就可以实现子进程与父进程之间的信息传递。

回到顶部