nodejs 中模拟实现 emmiter 自定义事件

下面是详细讲解 "nodejs 中模拟实现 emitter 自定义事件" 的完整攻略。

1. 什么是 emitter 自定义事件

在 nodejs 中，EventEmitter 是一个非常重要的模块。其作用是提供了处理事件的基本机制，可以用于实现自定义事件。

实际上，EventEmitter 可以理解为用于注册和监听事件的中介。我们可以通过它来注册自定义事件，并在事件被触发时，执行我们预设的处理函数。这种设计模式非常符合现实生活的开发需求。

2. EventEmitter 实现原理

如果我们要模拟实现一个类似的 EventEmitter，首先可以考虑使用 JavaScript 的一个基础特性：Object。

我们可以使用对象来存储自定义事件的名称与对应的处理函数，具体如下：

function EventEmitter() {
  // 存储事件及其处理函数集合的对象
  this.events = {};
}

接下来，我们需要实现 "on" 和 "emit" 两个方法。"on" 方法用于注册事件和事件处理函数；"emit" 方法用于触发事件以及执行注册的处理函数。

具体实现可以参考下面的代码示例：

function EventEmitter() {
  // 存储事件及其处理函数集合的对象
  this.events = {};
}

// 实现注册事件的方法
EventEmitter.prototype.on = function (eventName, callback) {
  if (this.events[eventName] === undefined) {
    // 如果该事件名称没有对应的处理函数，则需要新建一个数组来存储处理函数
    this.events[eventName] = [];
  }

  // 将当前处理函数添加到事件的处理函数数组中
  this.events[eventName].push(callback);
};

// 实现调用事件处理函数的方法
EventEmitter.prototype.emit = function (eventName) {
  if (this.events[eventName] === undefined) {
    // 如果该事件名称没有对应的处理函数，则直接返回
    return;
  }

  // 依次调用该事件的所有处理函数
  var args = Array.prototype.slice.call(arguments, 1);
  this.events[eventName].forEach(function (callback) {
    callback.apply(null, args);
  });
};

上述代码中，"on" 方法使用了一个数组，用于存储对应事件名称的所有处理函数。"emit" 方法使用了 Array.prototype.slice.call() 来获取传入的参数，并通过 forEach 遍历事件的所有处理函数，依次执行它们。

3. 如何使用 emitter 自定义事件

我们已经成功地实现了一个基本的 EventEmitter，并且拥有 "on" 和 "emit" 两个方法。现在，我们来看看如何使用它。

我们可以定义一个实例对象，然后添加一些自定义的事件以及事件对应的处理函数。例如下面的代码：

var eventEmitter = new EventEmitter();
eventEmitter.on('some_event', function() {
  console.log('some event triggered');
});

完成上述操作之后，我们已经成功地定义了一个自定义事件，并且为它添加了一个对应的处理函数。

当我们需要触发该事件时，可以调用 emit 方法，并传入事件名称。例如下面的代码：

eventEmitter.emit('some_event');

运行后，控制台上将打印出 "some event triggered"。

4. 实现上的注意点

在实现 EventEmitter 的过程中，需要注意一些细节问题。例如，当触发事件时，可能会传入多个参数。为了保持良好的兼容性，我们需要使用 Array.prototype.slice.call() 来获取参数数组。

另外，我们还需要对于未注册的事件进行处理，以免出现不必要的报错。

5. 示例说明

下面，我们来看两个例子，更好地理解 EventEmitter 如何实现和如何使用。

示例1：自定义事件触发

var EventEmitter = require('events');

function MyEmitter() {
  EventEmitter.call(this);
}

// 继承 EventEmitter
MyEmitter.prototype = Object.create(EventEmitter.prototype);
MyEmitter.prototype.constructor = MyEmitter;

// 定义自定义事件以及事件处理函数
MyEmitter.prototype.log = function (message) {
  console.log('log message:' + message);
}

var myEmitter = new MyEmitter();

// 注册自定义事件以及相应的处理函数
myEmitter.on('myEvent', function (arg1, arg2) {
  console.log('myEvent was emitted');
  console.log(arg1, arg2);
});

// 触发自定义事件，并传入参数
myEmitter.emit('myEvent', 'foo', 'bar');

// 调用自定义事件的处理函数
myEmitter.log('this is a log message');

上述代码中，我们自定义了一个事件 "myEvent"，并注册了一个处理函数。在调用 emit 方法时，传入了两个参数，分别为 'foo' 和 'bar'。执行后，控制台会打印出：

myEvent was emitted
foo bar
log message:this is a log message

示例2：链式调用

var EventEmitter = require('events');

function MyEmitter() {
  EventEmitter.call(this);
}

// 继承 EventEmitter
MyEmitter.prototype = Object.create(EventEmitter.prototype);
MyEmitter.prototype.constructor = MyEmitter;

var myEmitter = new MyEmitter();

// 注册自定义事件，使用链式调用方式
myEmitter
  .on('event', function (message) {
    console.log('event captured:', message);
  })
  .on('log', function (message) {
    console.log('log message:', message);
  });

// 触发事件
myEmitter.emit('event', 'some message');
myEmitter.emit('log', 'this is a log message');

在上述代码中，我们使用了链式调用方式，一次性注册了多个事件的处理函数。执行后，控制台会打印出：

event captured: some message
log message: this is a log message

通过这两个例子，我们可以更全面地了解了 EventEmitter 的实现和应用。