浅谈 Node 的事件机制

1. Node.js 事件机制简介

Node.js 的事件机制是基于观察者模式实现的，包含两个主要部分：事件的触发器（EventEmitter）和事件的监听器（Listener）。

其中 EventEmitter 是具有发布-订阅（publish-subscribe）模式功能的对象，用来触发事件和传递数据，而 Listener 则是负责监听事件的处理函数。在 Node.js 中，事件机制被广泛应用于各个模块之间的通信，以及处理异步操作的回调函数。

2. EventEmitter 类的常用API

在 Node.js 中，EventEmitter 类的常用 API 如下：

• eventEmitter.on(eventName, listener)：为指定事件注册一个监听器，该监听器会在事件被触发时被调用。eventName为事件名称，listener为处理函数。
• eventEmitter.emit(eventName[, arg1][, arg2][, ...])：触发指定事件，并将参数传递给处理函数。
• eventEmitter.once(eventName, listener)：为指定事件注册一个单次监听器，该监听器会在第一次事件被触发时，被调用后自动被移除。
• eventEmitter.removeListener(eventName, listener)：停止监听指定事件。
• eventEmitter.removeAllListeners([eventName])：移除所有或指定事件的所有监听器。
• eventEmitter.listeners(eventName)：返回指定事件的监听器数组。

3. 示例

示例 1：服务器响应请求

以下示例演示了如何基于 Node.js EventEmiiter 类实现一个简单的服务器，并响应 HTTP 请求：

const http = require('http');
const EventEmitter = require('events');

const server = http.createServer();
const eventEmitter = new EventEmitter();

eventEmitter.on('request', (req, res) => {
  res.writeHead(200, {'Content-Type': 'text/plain'});
  res.write('Hello World!');
  res.end();
});

server.on('request', (req, res) => {
  eventEmitter.emit('request', req, res);
});

server.listen(3000, () => {
  console.log('Server running at http://localhost:3000/');
});

在此示例中，我们创建了一个 http 服务器，并创建了一个名为 eventEmitter 的 EventEmitter 实例，使用 eventEmitter 对象的 on 方法为 request 事件添加了一个处理函数，然后在服务器对象上添加了一个 request 事件，当触发这个事件时，我们通过 eventEmitter 对象来调用响应的处理函数。

示例 2：自定义事件

以下示例演示了如何自定义事件，并通过异步操作触发和监听事件：

const EventEmitter = require('events');

class MyEmitter extends EventEmitter {}

const myEmitter = new MyEmitter();

myEmitter.on('event', (a, b) => {
  console.log(a, b, this);
});

setTimeout(() => {
  myEmitter.emit('event', 'Hello', 'World');
}, 1000);

在此示例中，我们定义了 MyEmitter 类，该类继承了 EventEmitter，然后我们实例化了 myEmitter 对象并为 event 事件添加了一个处理函数，该处理函数会在事件被触发时被调用，并将参数 a 和 b 打印到控制台上。然后我们使用 setTimeout 函数来延迟 1 秒触发事件，并传递 'Hello' 和 'World' 作为参数。

4. 总结

Node.js 事件机制是其异步编程的核心之一，其中 EventEmitter 类是事件驱动架构的核心实现。熟悉 Node.js 的事件机制可以帮助开发者更好地处理异步任务，提升应用程序的性能和稳定性。