本篇文章帶大家了解一下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();//實例化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





