nodejs系列（7）事件处理模块events

比眉伴天荒 2021-09-14 15:58 408阅读 0赞

大多数 Node.js 核心 API 都采用惯用的异步事件驱动架构，其中某些类型的对象（触发器）会周期性地触发命名事件来调用函数对象（监听器）。例如，net.Server 对象会在每次有新连接时触发事件；fs.ReadStream 会在文件被打开时触发事件；流对象 会在数据可读时触发事件。所有能触发事件的对象都是 EventEmitter 类的实例。 这些对象开放了一个 eventEmitter.on() 函数，允许将一个或多个函数绑定到会被对象触发的命名事件上。 事件名称通常是驼峰式的字符串，但也可以使用任何有效的 JavaScript 属性名。当 EventEmitter 对象触发一个事件时，所有绑定在该事件上的函数都被同步地调用。 监听器的返回值会被丢弃。

（注）eventEmitter.on() 方法用于注册监听器，eventEmitter.emit() 方法用于触发事件。

下面是一个EventEmitter的例子：

var events = require('events');
    var eventEmitter = new events.EventEmitter();
    
    //定义监听事件1
    var listener1 = function listener1(arg) {
    	console.log("listener1:" + arg);
    }
    //定义监听事件2
    var listener2 = function listener2(arg) {
    	console.log("listener2:" + arg);
    }
    //添加监听
    eventEmitter.on('connection', listener1);
    eventEmitter.on('connection', listener2);
    
    //触发监听
    eventEmitter.emit('connection', '首次触发事件');
    
    //移除监听
    console.log("移除监听");
    eventEmitter.removeListener('connection', listener1); //移除单个事件
    //		eventEmitter.removeAllListeners(['connection']); //移除所有事件
    
    //再次触发监听
    eventEmitter.emit('connection', '再次触发事件');
    
    //结果：
    //listener1:首次触发事件
    //listener2:首次触发事件
    //移除监听
    //listener2:再次触发事件

EventEmitter 定义了一个特殊的事件 error，它包含了错误的语义，我们在遇到异常的时候通常会触发 error 事件。若触发时没有响应的监听器，Node.js 会把它当作异常，退出程序并输出错误信息。error用法通常作为强行退出程序的保护机制。

eventEmitter.emit('error');

大多数时候我们不会直接使用 EventEmitter，而是在对象中继承它。包括 fs、net、 http 在内的，只要是支持事件响应的核心模块都是 EventEmitter 的子类。为什么要这样做呢？原因有两点：  
首先，具有某个实体功能的对象实现事件符合语义， 事件的监听和发生应该是一个对象的方法。  
其次 JavaScript 的对象机制是基于原型的，支持 部分多重继承，继承 EventEmitter 不会打乱对象原有的继承关系。

继承实现的例子如下：

//定义监听事件1
    var listener1 = function listener1(arg) {
    	console.log("listener1:" + arg);
    }
    
    //原型链实现继承
    var EventEmitter = require('events').EventEmitter;
    function Client() {}
    Client.prototype.a = function() {
    	console.log("a");
    }
    Client.prototype.__proto__ = EventEmitter.prototype;
    var client = new Client();
    client.a();
    client.on('extend', listener1)
    client.emit('extend', "Hello World");
    
    //结果：
    // a
    // listener1:Hello World