本篇文章带大家了解一下node中的eventemitter,简单聊聊一下异步操作、error事件、eventemitter类,希望对大家有所帮助!
events(事件触发器)events是nodejs内置的事件触发器,在node的内置模块里很多都用到了events,比如http.server在每次接受到请求时触发事件,还有stream就是基于事件的使用on来监听对应的事件。所有触发事件的对象都是eventemitter实例,这些对象暴露了eventemitter.on('事件',callback),通常使用eventtmitte.on注册事件,eventemitter.emit触发事件。
例子:
const events= require('events');const event=new events();//实例化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来执行异步操作
const events= require('events');const event=new events();event.on('event', (a, b) => { setimmediate(() => { console.log('this happens asynchronously'); }); //因为这里的监听器是同步执行的,但是我们可以使用setimediate函数等待监听器里的其他内容执行完再执行});event.emit('event',1,2);
触发一次
我们正常通过emit触发事件时,emit有几个事件就会被触发几次,但是我们可以使用once注册事件,使用once触发的事件只能被触发一次
const eventemitter =require('events'); const myeventemitter=new eventemitter(); let a=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') // 1 myeventemitter.emit('add') // 不生效了
error事件
eventemitter是没有error事件的,所以当发生错误的时候只能强制退出执行,所以我们必须自己注册一个error事件,以致于在发生错误的时候触发到error事件
const eventemitter=require('events'); const myeventemitter=new eventemitter(); myevenemitter.on('error',(err)=>{ console.error(err,'报错了') })
除了上面那种方式我们还可以通过errormonitor在不注册error事件的情况下,来监听emit触发的报错使用了errormonitor我们就不必要再去通过手动注册error事件了
const {eventemitter,errormonitor}=require('events'); const myeventemitter=new eventemitter(); myeventemitter.on(errormonitor,(err)=>{ console.log(err); }) myeventemitter('error' , new error('报错了'))
eventemitter类
newlistener事件
在我们添加事件监听的时候会触发newlistener事件,所以我们可以注册newlistener事件用来在添加事件监听的时候做一些事情
const {eventemitter}=require('events'); const myevent=new eventemitter(); 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触发的事件
const callbackb=()=>{ console.log('b')}const callbacka=()=>{ 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'); const myevent=new eventemitter(); myevent.on('data',()=>{}); myevent.on('finish',()=>{}); console.log(myevent.eventnames()); //打印结果 ['data','finish']
getmaxlisteners
返回可以注册的事件的最大数值,默认是10,如果超过10个会有警告但是我们可以通过setmaxlistener(20) 去进行修改
const {eventemitter} =require('events'); const myevent=new eventemitter(); console.log(myevent.getmaxlistener()); //10 event.setmaxlistener(20); console.log(myevent.getmaxlistener(20));
listenercount
返回注册的事件的数量
const {eventemitter} =require('events'); const myevent=new eventemitter(); myevent.on('data',()=>{}); myevent.on('data',()=>{}); myevent.on('finish',()={}); console.log(myevent.listenercount()) // 2
更多node相关知识,请访问:nodejs 教程!
以上就是深入聊聊node.js中的eventemitter的详细内容。