如何使用 PM2 实现 Node.js 应用的进程间通信-JavaScript中文网-JavaScript教程资源分享门户

前言

当我们开发 Node.js 应用时，经常会有需要多个进程共同工作的情况，比如多个进程同时部署在不同的服务器上，或者同一台服务器上运行多个进程。此时，进程间通信就是必不可少的。PM2 是一个流行的 Node.js 进程管理工具，可以用来管理多个进程。本文介绍了如何使用 PM2 实现 Node.js 应用的进程间通信。

PM2 简介

PM2 是一个流行的 Node.js 进程管理工具，它可以帮助我们简化 Node.js 进程管理的工作。使用 PM2，我们可以方便地启动、停止、重启、监控和修改 Node.js 进程。PM2 的功能非常强大，它还支持进程负载均衡和自动重启等功能。

进程间通信

进程间通信是指不同进程之间互相通信的过程。Node.js 提供了多个进程间通信的方式，比如共享内存、管道、消息队列和信号等。在使用 PM2 管理 Node.js 应用时，可以使用 PM2 自带的进程间通信机制，实现多个 Node.js 进程之间的通信。

PM2 进程间通信

PM2 进程间通信使用了 Node.js 内置的 IPC 通信机制。在 PM2 中，每一个进程都拥有一个唯一的进程 ID，可以通过「进程名」或「进程 ID」来定位到一个特定的进程。PM2 提供了两种方式来调用到另一个进程的方法，通过「进程名」或「进程 ID」来进行通信，这两种方式都可以实现不同 Node.js 进程之间的互相调用。

通过进程名进行通信

通过进程名进行通信的步骤如下：

在每个进程中初始化一个通信端口：
```
const pm2 = require('pm2');
const port = 3000;

pm2.launchBus(function (err, bus) {
  bus.on('hello', function (data) {
    console.log('Received:', data);
  });
});
```
在这段代码中，我们使用 pm2.launchBus 函数初始化了一个通信端口，并通过 on 方法监听了名为 hello 的事件。当一个事件被触发时，就可以在控制台上看到相应的输出。

向另一个进程发送消息：

-- -------------------- ---- -------
----- --- - ---------------
----- ------- - -------

----------------- ----- ------------ -
  ----- ------------- - ------------------------ -- ------------ --- ---------

  -- ---------------- -
    -------------------- ---------- --- ---------
    -------
  -

  -------------------------------------------- - ----- -------- ----- ------- -- -------- ----- ---- -
    -- ----- -
      -------------------
    -
  ---
---

在这段代码中，我们使用 pm2.list 函数来获取所有的进程列表，并使用 find 方法找到了名为 test 的进程。之后，我们使用 pm2.sendDataToProcessId 函数向指定进程发送了一个消息，消息内容为 { type: 'hello', data: 'world' }。

在另一个进程中，可以通过如下方式接收到消息：

const pm2 = require('pm2');
const port = 3000;

pm2.launchBus(function (err, bus) {
  bus.on('hello', function (data) {
    console.log('Received:', data);
  });
});

通过进程 ID 进行通信

通过进程 ID 进行通信的步骤与通过进程名进行通信类似。具体代码如下：

在每个进程中初始化一个通信端口：

const pm2 = require('pm2');
const port = 3000;

pm2.launchBus(function (err, bus) {
  bus.on('hello', function (data) {
    console.log('Received:', data);
  });
});

向另一个进程发送消息：

const pm2 = require('pm2');
const processId = 0;

pm2.sendDataToProcessId(processId, { type: 'hello', data: 'world' }, function (err, res) {
  if (err) {
    console.error(err);
  }
});

在另一个进程中，可以通过如下方式接收到消息：

const pm2 = require('pm2');
const port = 3000;

pm2.launchBus(function (err, bus) {
  bus.on('hello', function (data) {
    console.log('Received:', data);
  });
});

示例代码

下面是一个使用 PM2 实现进程间通信的示例代码：

-- -------------------- ---- -------
----- --- - ---------------

----- ------- - -------
----- ---- - -----

---------------------- ----- ---- -
  -- ----- -
    -------------------
    -------
  -

  ----- -------------- - -------- ------ ------- -
    --------------------- ------- -- ------------ ------
    ----------------- ------- --- --- -----------
  --

  ----------------- ----------------

  -------------------- -- -
    ----------------- ----- ------------ -
      -- ----- -
        -------------------
        -------
      -

      ----- ------------- - ------------------------ -- ------------ --- ---------

      -- ---------------- -
        -------------------- ---------- --- ---------
        -------
      -

      -------------------------------------------- - ----- -------- ----- ------- -- -------- ----- ---- -
        -- ----- -
          --------------------- -- ---- ------- -----
          -------
        -

        ----------------- ---- ---- -------- ---------------------
      ---
    ---
  -- -------

  ----- --------- - -------- -------- -------- -
    ------------------------------------- - ----- -------- ----- ------- -- -------- ----- ---- -
      -- ----- -
        --------------------- -- ---- -------- -----
        -------
      -

      ------------------ ------- ---------
    ---
  --
---

在这段代码中，我们使用了一个叫做 test 的进程，并且周期性地向这个进程发送消息。当 test 进程接收到消息时，会回复一条消息。另外，我们还监听了 message 事件，可以接收其他进程发送过来的消息。

结论

PM2 是一个非常强大的 Node.js 进程管理工具，可以帮助我们简化 Node.js 进程管理的工作。使用 PM2，我们可以方便地启动、停止、重启、监控和修改 Node.js 进程。在使用 PM2 管理 Node.js 应用时，可以使用 PM2 自带的进程间通信机制，实现多个 Node.js 进程之间的通信。无论是通过进程名还是进程 ID 进行通信，都可以使用 PM2 简单地实现进程间通信的功能。

来源：JavaScript中文网，转载请注明来源 https://www.javascriptcn.com/post/672316282e7021665e0e2eab