PM2进程间通信实现指南

本文将详细介绍如何在PM2管理的Node.js进程之间实现通信。PM2作为Node.js应用的生产环境进程管理器，提供了进程间通信（IPC）机制，允许不同进程之间交换数据和消息。

## PM2进程间通信的核心机制

PM2的进程间通信主要基于两种方式：
1. **主进程向子进程发送数据**：使用`pm2.sendDataToProcessId()`方法
2. **子进程向主进程或其他进程发送数据**：使用Node.js内置的`process.send()`方法

## 实现代码示例

### 主进程代码（pm2-master.js）

主进程负责发送数据到指定的子进程。它需要引入pm2包，可以在PM2内部或外部运行：

```javascript
const pm2 = require('pm2');
const neighborIds = [];

pm2.connect(function () {
  // 列出正在运行的进程并获取它们的名称/ID
  pm2.list(function (err, processes) {
    for (const i in processes) {
      console.log('Id:', processes[i].pm_id, 'Name:', processes[i].name);
      if (processes[i].name === 'pm2-slave') {
        neighborIds.push(processes[i].pm_id);
      }
    }
    console.log('neighborIds: ', neighborIds);
    
    // 将信息发送到指定进程
    pm2.sendDataToProcessId(
      neighborIds[0],
      {
        type: 'process:msg',
        data: {
          some: 'data',
        },
        topic: true,
      },
      function (err, res) {
        console.log('callback', err, res);
      }
    );
  });
});

// 接收信息
pm2.launchBus(function (err, pm2_bus) {
  pm2_bus.on('process:msg', function (packet) {
    console.log('pm2-master launchBus', packet);
  });
});
```

### 子进程代码（pm2-slave.js）

子进程负责接收来自主进程的消息并响应。注意：子进程不需要引用pm2包，但必须在PM2中运行：

```javascript
const sendMsgToMaster = () => {
  process.send({
    type: 'process:msg',
    data: {
      success: true,
      num: Math.random(),
    },
  });
};

process.on('message', function (packet) {
  console.log('got message from pm2-master', packet);
  setTimeout(sendMsgToMaster, 2 * 1000);
});
```

### PM2配置文件（ecosystem.config.js）

PM2配置文件定义了应用的结构和运行参数：

```javascript
module.exports = {
  apps: [
    // pm2-master 可以不用 pm2 运行
    // {
    //   name: 'pm2-master',
    //   script: './pm2-master.js',
    //   instances: 1,
    //   watch: ['pm2-master.js'],
    //   merge_logs: true,
    //   exec_mode: 'cluster',
    //   max_memory_restart: '600M',
    //   instance_var: 'NODE_APP_INSTANCE'
    // },
    {
      name: 'pm2-slave',
      script: './pm2-slave.js',
      watch: ['pm2-slave.js'],
      exec_mode: 'cluster',
    },
  ],
};
```

## 关键技术要点

### 1. 进程识别与定位
- 使用`pm2.list()`获取所有运行中进程的详细信息
- 通过进程名称（如'pm2-slave'）筛选目标进程
- 获取进程的`pm_id`作为通信标识符

### 2. 数据发送机制
- `pm2.sendDataToProcessId()`：主进程向特定子进程发送数据
- 消息格式包含`type`、`data`和`topic`字段
- 支持回调函数处理发送结果

### 3. 数据接收机制
- `pm2.launchBus()`：创建消息总线监听器
- `pm2_bus.on()`：监听特定类型的消息
- `process.on('message')`：子进程接收消息的标准方式

### 4. 双向通信模式
- 主进程发送消息后，子进程可以响应
- 使用`process.send()`从子进程向主进程发送数据
- 支持异步响应和定时触发

## 应用场景

PM2进程间通信适用于以下场景：
- 多进程应用的状态同步
- 进程间的任务分配与协调
- 实时数据共享和更新
- 分布式系统中的进程协作

## 注意事项

1. **运行环境要求**：主进程可以在PM2内部或外部运行，但子进程必须在PM2中运行
2. **进程标识**：确保正确识别目标进程的ID
3. **消息格式**：遵循PM2要求的消息格式规范
4. **错误处理**：正确处理通信过程中的可能错误

通过以上机制，PM2提供了灵活而强大的进程间通信能力，使得基于Node.js的分布式应用开发更加便捷高效。

评论已关闭

本文目录

分类

最新文章