EventEmitter3 原理剖析，与你探讨事件订阅机制的奥秘

2024-02-12 08:19:04

事件订阅机制：传递信息的桥梁

在软件开发中，事件订阅机制是一种常见的通信方式，它允许对象之间进行松散耦合的交互。当某个对象的状态发生改变时，它会触发一个事件，并通知所有订阅该事件的对象。订阅者可以根据自己的需要对事件进行处理，从而实现复杂的业务逻辑。

EventEmitter3 正是一款基于观察者模式的事件库，它提供了简单的 API，允许开发者轻松地创建、订阅和触发事件。EventEmitter3 的核心思想是：事件的发布者和订阅者之间不存在直接的耦合关系，订阅者只需要注册对特定事件的监听，即可在事件发生时收到通知并执行相应的操作。

EventEmitter3 源码分析

EventEmitter3 的源码简洁而优雅，它将事件订阅机制的精髓浓缩于数百行代码中。在 EventEmitter3 中，事件的发布和订阅通过两个核心方法来实现：on() 和 emit()。

1. on() 方法：订阅事件

on() 方法用于订阅一个事件。它接受两个参数：事件名和事件处理函数。当事件发生时，事件处理函数将被调用。

EventEmitter3.prototype.on = function(event, listener) {
  if (typeof event !== 'string' || typeof listener !== 'function') {
    throw new Error('Invalid arguments: event must be a string and listener must be a function');
  }

  // 获取事件监听器数组，如果不存在则创建
  var listeners = this._listeners[event];
  if (!listeners) {
    listeners = [];
    this._listeners[event] = listeners;
  }

  // 将事件监听器添加到数组中
  listeners.push(listener);

  return this;
};

2. emit() 方法：发布事件

emit() 方法用于发布一个事件。它接受两个参数：事件名和事件数据。当事件被发布时，所有订阅该事件的事件处理函数都将被调用。

EventEmitter3.prototype.emit = function(event, data) {
  // 获取事件监听器数组
  var listeners = this._listeners[event];

  // 如果事件监听器数组存在，则遍历并调用每个事件处理函数
  if (listeners) {
    for (var i = 0, len = listeners.length; i < len; i++) {
      listeners[i](data);
    }
  }

  return this;
};