深入聊聊node.js中的EventEmitter

這篇文章帶大家了解一下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

更多node相關知識，請訪問：nodejs 教程！

以上是深入聊聊node.js中的EventEmitter的詳細內容。更多資訊請關注PHP中文網其他相關文章！