深入聊聊node.js中的EventEmitter

本篇文章带大家了解一下node中的EventEmitter,简单聊聊一下异步操作、error事件、EventEmitter类,希望对大家有所帮助! events(事件触发器) ev…

本篇文章带大家了解一下node中的EventEmitter,简单聊聊一下异步操作、error事件、EventEmitter类,希望对大家有所帮助!

深入聊聊node.js中的EventEmitter

events(事件触发器)

events是nodejs内置的事件触发器,在node的内置模块里很多都用到了events,比如http.server在每次接受到请求时触发事件,还有stream就是基于事件的使用on来监听对应的事件。 所有触发事件的对象都是EventEmitter实例,这些对象暴露了EventEmitter.on('事件',callback),通常使用EventTmitte.on注册事件,EventEmitter.emit触发事件。

例子:

constevents=require('events');constevent=newevents();//实例化EventEmitterevent.on('data',(a,b)=>{console.log('参数'+a+b)console.log(this,'this')//注意,如果callback是箭头函数的话this指向的是全局对象//如果callback是function(){}形式的话,this会绑定到EventEmitter实例上console.log('emit触发了data事件')})event.emit('data',1,2);//使用emit触发事件

异步操作

因为EventEmitter.on('事件名称',callback)里的callback是同步执行的,但是在某些情况下我们不得不使用异步操作所以我们可以在使用SetImmediate来执行异步操作

constevents=require('events');constevent=newevents();event.on('event',(a,b)=>{setImmediate(()=>{console.log('thishappensasynchronously');});//因为这里的监听器是同步执行的,但是我们可以使用setImediate函数等待监听器里的其他内容执行完再执行});event.emit('event',1,2);

触发一次

我们正常通过emit触发事件时,emit有几个事件就会被触发几次,但是我们可以使用once注册事件,使用once触发的事件只能被触发一次

constEventEmitter=require('events');constMyEventEmitter=newEventEmitter();leta=0;//正常注册事件和触发MyEventEmitter.on('add',()=>{a++console.log(a)})MyEventEmitter.emit('add');//1;MyEventEmitter.emit('add');//2;//使用once注册MyEventEmitter.once('add',()=>{a++console.log(a);})MyEventEmitter.emit('add')//1MyEventEmitter.emit('add')//不生效了

error事件

EventEmitter是没有error事件的,所以当发生错误的时候只能强制退出执行,所以我们必须自己注册一个error事件,以致于在发生错误的时候触发到error事件

constEventEmitter=require('events');constMyEventEmitter=newEventEmitter();MyEvenEmitter.on('error',(err)=>{console.error(err,'报错了')})

除了上面那种方式我们还可以通过errorMonitor在不注册error事件的情况下,来监听emit触发的报错 使用了errorMonitor我们就不必要再去通过手动注册error事件了

const{EventEmitter,errorMonitor}=require('events');constMyEventEmitter=newEventEmitter();MyEventEmitter.on(errorMonitor,(err)=>{console.log(err);})MyEventEmitter('error',newError('报错了'))

EventEmitter类

newListener事件

在我们添加事件监听的时候会触发newListener事件,所以我们可以注册newListener事件用来在添加事件监听的时候做一些事情

const{EventEmitter}=require('events');constMyEvent=newEventEmitter();MyEvent.on('newListener',(name,litener)=>{//name就是正在监听的事件的名称//listener是事件的处理函数MyEvent.on('event',()=>{console.log('在newListener添加的事件')})})MyEvent.on('event',()=>{console.log('正常注册的event事件')})//此时我们再不触发event事件的情况下,newListener事件就会执行,因为我们只要正在注册事件就会触发newListener事件//注意:newListener事件必须要使用EventEmitter.once()注册,因为如果我们在newListener事件里再去添加注册事件的话,而且外边有多个注册事件就会触发多次newListener事件,就会发生堆栈溢出MyEvent.emit('event');//打印的结果//在newListener注册的事件//正常注册的event事件

removeListener事件

removeListener事件用于删除已经注册的事件,但是,removeListener不会阻止掉正在被emit触发的事件

constcallbackB=()=>{console.log('B')}constcallbackA=()=>{console.log('A')event.removeListener('data',callbackB)}event.on('data',callbackA)event.on('data',callbackB)event.emit('data');//在执行callbackA的时候删除了data,但是不会阻止掉下一个emit的触发event.emit('data');//在这里的时候才是真正被删除掉了

addListener 和on的作用一样

eventNames

返回一个数组,数组里包含了所有已经注册的事件的名称

const{EventEmitter}=require('events');constMyEvent=newEventEmitter();MyEvent.on('data',()=>{});MyEvent.on('finish',()=>{});console.log(MyEvent.eventNames());//打印结果['data','finish']

getMaxListeners

返回可以注册的事件的最大数值,默认是10,如果超过10个会有警告 但是我们可以通过setMaxListener(20) 去进行修改

const{EventEmitter}=require('events');constMyEvent=newEventEmitter();console.log(MyEvent.getMaxListener());//10event.setMaxListener(20);console.log(MyEvent.getMaxListener(20));

listenerCount

返回注册的事件的数量

const{EventEmitter}=require('events');constMyEvent=newEventEmitter();MyEvent.on('data',()=>{});MyEvent.on('data',()=>{});MyEvent.on('finish',()={});console.log(MyEvent.listenerCount())//2

产品猿社区致力收录更多优质的商业产品,给服务商以及软件采购客户提供更多优质的软件产品,帮助开发者变现来实现多方共赢;

日常运营的过程中我们难免会遇到各种版权纠纷等问题,如果您在社区内发现有您的产品未经您授权而被用户提供下载或使用,您可按照我们投诉流程处理,点我投诉

本文来自用户发布投稿,不代表产品猿立场 ;若对此文有疑问或内容有严重错误,可联系平台客服反馈;

部分产品是用户投稿,可能本文没有提供官方下下载地址或教程,若您看到的内容没有下载入口,您可以在我们产品园商城搜索看开发者是否有发布商品;若您是开发者,也诚邀您入驻商城平台发布的产品,地址:点我进入

如若转载,请注明出处:https://www.chanpinyuan.cn/28810.html;
(0)
上一篇 2022年12月5日 下午4:18
下一篇 2022年12月5日 下午4:18

相关推荐

发表回复

登录后才能评论
分享本页
返回顶部