利用Node.js的EventEmitter实现自定义事件

<p>EventEmitter是Node.js中实现事件驱动编程的核心工具，通过继承可为对象添加监听与触发事件能力。首先从events模块导入：const { EventEmitter } = require(‘events’);，接着创建类继承EventEmitter以使用on、emit、once等方法。例如定义OrderProcessor类处理订单： </p><pre>class OrderProcessor extends EventEmitter { constructor() { super(); } placeOrder(orderId) {console.log(`订单 ${orderId} 已提交`);
this.emit(‘orderPlaced’, orderId);} shipOrder(orderId) {console.log(`订单 ${orderId} 正在发货`);
this.emit(‘orderShipped’, orderId);}}</pre><p>实例化后用on注册持续监听事件： </p><pre>const processor = new OrderProcessor();processor.on(‘orderPlaced’, (orderId) => { console.log(监听到：订单 ${orderId} 已创建，准备支付);});processor.on(‘orderShipped’, (orderId) => { console.log(通知用户：订单 ${orderId} 已发货);});</pre><p>使用once可监听仅执行一次的事件： </p><pre>processor.once(‘orderPlaced’, (orderId) => { console.log(这是第一次也是最后一次提示：${orderId});});</pre><p>可通过命名回调函数并调用removeListener手动移除监听： </p><pre>function on</pre>

在Node.js中，EventEmitter 是一个核心模块，位于 events 模块中，它提供了一种简单而强大的方式来实现事件驱动编程。通过继承 EventEmitter，我们可以为自定义对象添加事件监听和触发能力，从而实现松耦合的模块通信。

引入并使用 EventEmitter

要使用 EventEmitter，首先需要从 events 模块中导入它：

const { EventEmitter } = require(‘events’);

接着可以创建一个类来继承 EventEmitter，以便拥有事件相关的方法，如 on、emit 和 once。

例如，创建一个表示“订单处理”的自定义类：

class OrderProcessor extends EventEmitter {
  constructor() {
    super();
  }

  shipOrder(orderId) {
    console.log(`订单 ${orderId} 正在发货`);
    this.emit(‘orderShipped’, orderId);
  }
}

监听自定义事件

实例化 OrderProcessor 后，可以通过 on 方法注册事件监听器，当事件被触发时执行对应逻辑。

const processor = new OrderProcessor();
processor.on(‘orderPlaced’, (orderId) => {
  console.log(`监听到：订单 ${orderId} 已创建，准备支付`);
});
processor.on(‘orderShipped’, (orderId) => {
  console.log(`通知用户：订单 ${orderId} 已发货`);
});

当调用 placeOrder() 或 shipOrder() 时，对应的事件会被触发，所有绑定的回调函数将依次执行。

PatentPal专利申请写作

AI软件来为专利申请自动生成内容

13

查看详情

一次性事件与移除监听

如果希望某个事件只响应一次，可以使用 once 方法：

processor.once(‘orderPlaced’, (orderId) => {
  console.log(`这是第一次也是最后一次提示：${orderId}`);
});

此外，若需手动移除监听器，可将回调函数命名后通过 removeListener 移除：

function onShipped(orderId) {
  console.log(`特殊处理：${orderId}`);
}
processor.on(‘orderShipped’, onShipped);
processor.removeListener(‘orderShipped’, onShipped);

EventEmitter 让我们能轻松实现观察者模式，提升代码的可维护性和扩展性。只要合理设计事件名称和数据传递结构，就能在复杂应用中实现清晰的模块间通信。

基本上就这些，不复杂但容易忽略细节，比如记得继承和正确 emit 事件名。