如何在PM2管理的不同Node.js进程之间实现跨进程emit数据

可以实现跨进程的类emit事件传递，PM2托管的不同Node.js进程属于独立操作系统进程，没有默认的事件通信通道，可根据业务场景选择以下方案：

方案1：PM2内置IPC通信（最便捷，无需额外依赖） #

PM2原生提供了进程间消息路由能力，直接调用Node.js内置的process.send()方法即可实现消息定向发送：

• 配置要求：在PM2的ecosystem.config.js中为两个进程开启send_message: true配置，且两个进程的name属性唯一可识别。
• 发送端（app1.js）代码示例：

// 封装消息发送方法
const emitToProcess = (targetProcessName, eventName, payload) => {
  process.send({
    msgType: 'cross-event',
    event: eventName,
    data: payload,
    target: targetProcessName
  })
}

// 调用示例：向app2发送custom-event事件，携带数据
emitToProcess('app2', 'custom-event', { userId: 123, content: 'test' })

• 接收端（app2.js）代码示例：

// 监听PM2转发的进程消息
process.on('message', (packet) => {
  // 过滤自定义的跨进程事件消息
  if (packet.msgType === 'cross-event' && packet.event === 'custom-event') {
    const receivedData = packet.data
    // 这里执行对应事件的处理逻辑
    console.log('收到来自app1的事件数据：', receivedData)
  }
})

方案2：Redis Pub/Sub（适配多实例/跨服务器扩展场景） #

如果后续有进程跨服务器部署、一对多事件广播的需求，可以用Redis的发布订阅能力做事件中转：

• 依赖要求：需要安装Redis客户端，比如ioredis或redis
• 发送端（app1.js）代码示例：

const Redis = require('ioredis')
const redisClient = new Redis()

// 发布事件到公共频道
const emitCrossProcess = (eventName, payload) => {
  redisClient.publish('global-event-channel', JSON.stringify({
    event: eventName,
    data: payload
  }))
}

// 调用示例
emitCrossProcess('custom-event', { userId: 123, content: 'test' })

• 接收端（app2.js）代码示例：

const Redis = require('ioredis')
const redisClient = new Redis()

// 订阅公共频道
redisClient.subscribe('global-event-channel', (err) => {
  if (err) throw new Error('频道订阅失败')
})

// 监听频道消息
redisClient.on('message', (channel, msg) => {
  const { event, data } = JSON.parse(msg)
  if (event === 'custom-event') {
    console.log('收到跨进程事件数据：', data)
  }
})

方案3：本地套接字通信（无依赖极简场景） #

如果不想依赖PM2特性或第三方服务，可以自己在两个进程之间建立本地TCP/UDP套接字连接，直接传输事件数据，适合仅本地部署的小型项目。

内容的提问来源于stack exchange，提问作者Ilijanovic