详解Node.js：events事件模块
Nodejs的大部分核心API都是基于异步事件驱动设计的，所有可以分发事件的对象都是EventEmitter类的实例。
大家知道，由于nodejs是单线程运行的，所以nodejs需要借助事件轮询，不断去查询事件队列中的事件消息，然后执行该事件对应的回调函数，有点类似windows的消息映射机制。至于更细的实现环节，可以另行查找资料。
下面介绍EventEmitter的使用。
1、监听事件和分发事件
EventEmitter实例可以使用on或addListener监听事件，emit()方法分发事件，如下所示：
const events = require('events'),
EventEmitter = events.EventEmitter,
util = require('util');
function myEmiter(){
EventEmitter.call(this);
};
util.inherits(myEmiter,EventEmitter);//继承EventEmitter类
const myEmitterIns = new myEmiter();
myEmitterIns.on('data',(o)=>{
console.log('receive the data:'+o.a);
});
或者使用class类
class myEmiter extends EventEmitter{}//继承EventEmitter类
const myEmitterIns = new myEmiter();
myEmitterIns.on('data',(o)=>{
console.log('receive the data:'+o.a);
});
myEmitterIns.emit('data',{a:1});
执行结果如下：
E:\developmentdocument\nodejsdemo>node event-example.js
receive the data:1
2、向事件监听回调函数传递参数
从上面的例子可以看出，emit()方法可以传递任意的参数集合给回调函数，需要注意的一点是this关键字指向的是调用emit方法的EventEmiter实例，但在箭头函数中例外，this指向的是全局this，因为箭头函数中的this是在定义时绑定。如下所示：
class myEmiter extends EventEmitter{}
const myEmitterIns = new myEmiter();
myEmitterIns.on('data',function(data){
console.log("普通回调函数中this：");
console.log(this);
});
myEmitterIns.on('data1',(data1)=>{
console.log("箭头回调函数中this：");
console.log(this);
});
myEmitterIns.emit('data',{a:1});
myEmitterIns.emit('data1',{a:1});
执行结果如下：
E:\developmentdocument\nodejsdemo>node event-example.js
普通回调函数中this：
myEmiter {
domain: null,
_events: { data: [Function], data1: [Function] },
_eventsCount: 2,
_maxListeners: undefined }
箭头回调函数中this：
{}
这里讲到箭头函数中的this，就顺便说一下，为什么箭头函数能够实现定义时绑定this，就是因为箭头函数内部根本就没有绑定this的机制，它使用的是外层作用域的this，因此它也不能作为构造函数。
3、事件监听程序的执行顺序
EventEmiter实例可以绑定多个事件，当我们顺序触发这些事件时，EventEmiter会以同步模式执行，既第一个事件处理函数没有完成，便不会触发下一个事件，如下所示：
class myEmiter extends EventEmitter{}
const myEmitterIns = new myEmiter();
myEmitterIns.on('data',function(data){
console.time('data事件执行了');
for(var i = 0 ; i< 100000; i++)
for(var j = 0 ; j< 100000; j++)
;
console.timeEnd('data事件执行了');
});
myEmitterIns.on('data1',(data1)=>{
console.log("data1事件开始执行...");
});
myEmitterIns.emit('data',{a:1});
myEmitterIns.emit('data1',{a:1});
执行结果如下：
E:\developmentdocument\nodejsdemo>node event-example.js
data事件执行了: 4721.401ms
data1事件开始执行...
当然我们可以在回调函数中使用异步操作，例如setTimeout，setImmediate或者process.nextTick()等，从而实现异步的效果，如下所示：
myEmitterIns.on('data',function(data){
setImmediate(()=>{
console.log('data事件执行了...');
});
});
执行结果如下：
E:\developmentdocument\nodejsdemo>node event-example.js
data1事件执行了...
data事件执行了...
4、一次性事件监听
EventEmiter可以使用once监听某个事件，则该事件处理程序只会触发一次，之后emit该事件都会被忽略，因为监听程序被注销了，如下所示：
myEmitterIns.once('one',(data)=>{
console.log(data);
});
myEmitterIns.emit('one','this is first call!');
myEmitterIns.emit('one','this is second call!');
执行结果如下：
E:\developmentdocument\nodejsdemo>node event-example.js
this is first call!
从上面的结果看出，'one'事件只执行了一次。
5、移除事件绑定
类似DOM事件监听，EventEmiter也可以移除事件绑定，利用removeListener(eventName,listener)方法解除某个事件的绑定，因此回调函数listener必须是命名函数，要不然找不到该函数，因为函数是引用型类型，就算函数体是一样，也不是同一个函数，如下所示：
myEmitterIns.on('data',function(e){
console.log(e);
});
myEmitterIns.removeListener('data',function(e){
console.log(e);
});
myEmitterIns.emit('data','hello data!');
function deal(e){
console.log(e);
}
myEmitterIns.on('data1',deal);
myEmitterIns.removeListener('data1',deal);
myEmitterIns.emit('data1','hello data1!');
执行结果如下：
E:\developmentdocument\nodejsdemo>node event-example.js
hello data!
E:\developmentdocument\nodejsdemo>
从执行结果可以看出，data事件使用的是匿名函数，因此没有被移除掉，而data1事件则成功解除绑定了。这里需要注意一点的是emit触发某个事件后，所有跟该事件绑定的回调函数都会被调用，即使你在某个回调函数中使用removeListener函数移除掉另一个回调也没有用，但是随后的事件队列是移除了该回调的。如下所示：
function dealData1(e){
console.log('data事件执行了...A');
}
myEmitterIns.on('data',function(e){
console.log(e);
myEmitterIns.removeListener('data',dealData1);//这里解除dealData1的绑定
});
myEmitterIns.on('data',dealData1);
myEmitterIns.emit('data','data事件执行了...B');
/*执行结果为：
data事件执行了...B
data事件执行了...A
*/
//再次触发该事件时,dealData1回调已经被解除绑定了
myEmitterIns.emit('data','data事件执行了...');
//data事件执行了...
另外可以使用removeAllListeners()解除所有事件的绑定。
6、获取事件监听数量和监听函数
使用emitter.listenerCount(eventName)函数获取指定事件的监听数量，函数emitter.listeners(eventName)则可以用来获取指定事件的所有监听函数，使用如下所示：
var cbA = ()=>{},
cbB = ()=>{};
var emitter = new myEmiter();
emitter.on('data',cbA);
emitter.on('data',cbB);
console.log('emitter实例的data事件绑定了%d个回调函数',emitter.listenerCount('data'));
console.log('它们是：',emitter.listeners('data'));
执行结果如下：
E:\developmentdocument\nodejsdemo>node event-example.js
emitter实例的data事件绑定了2个回调函数
它们是： [ [Function: cbA], [Function: cbB] ]
7、获取和设置emitter的最大监听数量
nodejs对同一事件的监听数量建议不宜超过10个，这个可以查看EventEmitter.defaultMaxListeners属性便可得知，如下所示：
console.log(EventEmitter.defaultMaxListeners);//结果为10个
emitter通过getMaxListeners()方法获取最大监听数量以及setMaxListeners(n)方法设置最大监听数量,如下所示：
var cbA = ()=>{},
cbB = ()=>{};
var emitter = new myEmiter();
emitter.setMaxListeners(1);
emitter.on('data',cbA);
emitter.on('data',cbB);
console.log(emitter.getMaxListeners());
执行结果如下：
E:\developmentdocument\nodejsdemo>node event-example.js
emitter的事件最大监听数是：1
(node:6808) Warning: Possible EventEmitter memory leak detected. 2 data listener
s added. Use emitter.setMaxListeners() to increase limit
如上结果所示，如果设置了最大监听数量，则同一事件的监听最好不要超过该最大值，否则很可能发送内存泄漏。
events模块便介绍到这。希望对大家的学习有所帮助，也希望大家多多支持脚本之家。
相关文章
本文给大家分享的是使用node.js实现开发微博的实例，主要是看了nodejs开发指南之后发现书上的代码很多已经不能用了，原因是express版本升级了，所以今天就尝试着吧开发微博的实例也升下级，推荐给大家。2015-03-03
使用nodejs中httpProxy代理时候出现404异常的解决方法
下面小编就为大家带来一篇使用nodejs中httpProxy代理时候出现404异常的解决方法。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧2016-08-08
在每一次的实际开发过程中我们都会下载相关的依赖包,最官方的是 npm,但是该服务器对于国内开发者来说,下载起来是比较慢的,所以我们需要换源,下面这篇文章主要给大家介绍了关于NPM如何换源的相关资料,需要的朋友可以参考下2023-02-02
Node.js使用CommonJS模块格式,通过require语句加载模块,源码分析了require语句的内部运行机制,包括基本用法、Module构造函数、模块实例的require方法、模块的绝对路径、加载模块等,本文介绍node.js的require()及基本用法,感兴趣的朋友一起看看吧2025-02-02
本篇文章主要介绍了Node接收电子邮件，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2017-07-07
这篇文章主要介绍了node.js中的fs.appendFile方法使用说明,本文介绍了fs.appendFile方法说明、语法、接收参数、使用实例和实现源码,需要的朋友可以参考下2014-12-12
使用pkg将Node.js项目打包为可执行文件时,可能会遇到一些常见的错误,如未指定目标平台、在远程缓存中找不到基础Node.js二进制文件等,本文介绍了如何通过配置package.json中的bin入口、手动下载指定版本的Node.js二进制文件到本地.pkg-cache目录解决这些问题2024-11-11
这篇文章是根据自己的经验及实际操作介绍nodejs和npm的卸载及安装，相信对很多人会有帮助，有需要的可以参考学习。2016-08-08
今天小编就为大家分享一篇nodeJS服务器的创建和重新启动的实现方法，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2018-05-05
让nodeJS支持ES6的词法----babel的安装和使用方法
这篇文章主要介绍了让nodeJS支持ES6的词法----babel的安装和使用方法，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2017-07-07
最新评论