如何在Node.js中实现事件的Emit与Consume？寻求POC实现方案

Node.js 中处理事件依赖内置的 events 模块，核心是 EventEmitter 类——它提供了触发事件、监听事件的完整能力，是Node.js异步编程的核心模式之一。

核心概念 #

• 触发（emit）：主动向事件系统发送指定事件信号，可携带自定义数据
• 消费（consume）：通过注册监听器，监听特定事件，一旦事件被触发就执行对应逻辑

基础实现步骤 #

1. 导入 events 模块，获取 EventEmitter 类
2. 创建 EventEmitter 实例作为事件载体
3. 用 on()（持续监听）或 once()（仅监听一次）注册事件监听器
4. 用 emit() 方法触发目标事件并传递数据

POC 示例1：基础事件系统 #

// 1. 导入核心模块
const { EventEmitter } = require('events');

// 2. 创建事件发射器实例
const eventBus = new EventEmitter();

// 3. 注册事件监听器（消费事件）
// 持续监听"messageReceived"事件
eventBus.on('messageReceived', (sender, content) => {
  console.log(`收到来自 ${sender} 的消息：${content}`);
});

// 仅监听一次"systemAlert"事件
eventBus.once('systemAlert', (level, msg) => {
  console.log(`【${level}级系统告警】${msg}`);
});

// 4. 触发事件（emit）
eventBus.emit('messageReceived', 'Alice', '今晚一起吃饭？');
eventBus.emit('systemAlert', '紧急', '数据库连接异常');
eventBus.emit('messageReceived', 'Bob', '好的，六点见');
// 第二次触发systemAlert不会有反应，因为是once监听
eventBus.emit('systemAlert', '普通', '备份任务完成');

运行结果：

收到来自 Alice 的消息：今晚一起吃饭？
【紧急级系统告警】数据库连接异常
收到来自 Bob 的消息：好的，六点见

POC 示例2：自定义事件驱动服务 #

实际开发中，通常会通过继承 EventEmitter 封装业务逻辑：

const { EventEmitter } = require('events');

// 自定义用户服务类，继承EventEmitter
class UserService extends EventEmitter {
  // 模拟用户注册逻辑
  register(userInfo) {
    if (!userInfo.username || !userInfo.password) {
      // 触发错误事件
      this.emit('error', new Error('用户名或密码不能为空'));
      return;
    }

    // 模拟数据库写入操作
    console.log(`正在保存用户 ${userInfo.username} 的信息...`);
    // 触发注册成功事件
    this.emit('registered', {
      id: Date.now(), // 模拟用户ID
      username: userInfo.username,
      createdAt: new Date().toLocaleString()
    });
  }
}

// 实例化服务
const userService = new UserService();

// 监听注册成功事件
userService.on('registered', (userData) => {
  console.log('用户注册成功，详情：');
  console.log(userData);
});

// 必须监听error事件，否则触发时会导致进程崩溃
userService.on('error', (err) => {
  console.error('注册失败：', err.message);
});

// 调用注册方法
userService.register({ username: 'Charlie', password: '123456' });
userService.register({ username: 'Dave' }); // 触发错误事件

运行结果：

正在保存用户 Charlie 的信息...
用户注册成功，详情：
{ id: 1718xxxxxxx, username: 'Charlie', createdAt: '2024/6/15 14:30:00' }
注册失败：用户名或密码不能为空

常用扩展技巧 #

• 用 off() 移除指定监听器：eventBus.off('messageReceived', listenerFunction)
• 用 listenerCount() 获取事件的监听器数量：eventBus.listenerCount('messageReceived')
• 事件命名建议用小写下划线风格（如user_registered），避免冲突

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