深入聊聊node.js中的EventEmitter

青灯夜游
發布: 2022-05-09 21:33:59
轉載
2147 人瀏覽過

這篇文章帶大家了解一下node中的EventEmitter,簡單聊聊一下非同步操作、error事件、EventEmitter類,希望對大家有幫助!

深入聊聊node.js中的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();//实例化EventEmitter event.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的詳細內容。更多資訊請關注PHP中文網其他相關文章!

相關標籤:
來源:juejin.cn
本網站聲明
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn
最新下載
更多>
網站特效
網站源碼
網站素材
前端模板
關於我們 免責聲明 Sitemap
PHP中文網:公益線上PHP培訓,幫助PHP學習者快速成長!