Nodejs的大部分核心API都是基于異步事件驅(qū)動設計的，所有可以分發(fā)事件的對象都是EventEmitter類的實例。

大家知道，由于nodejs是單線程運行的，所以nodejs需要借助事件輪詢，不斷去查詢事件隊列中的事件消息，然后執(zhí)行該事件對應的回調(diào)函數(shù)，有點類似windows的消息映射機制。至于更細的實現(xiàn)環(huán)節(jié)，可以另行查找資料。

下面介紹EventEmitter的使用。

1、監(jiān)聽事件和分發(fā)事件

EventEmitter實例可以使用on或addListener監(jiān)聽事件，emit()方法分發(fā)事件，如下所示：

const events = require('events'),
   EventEmitter = events.EventEmitter,
   util = require('util');
function myEmiter(){
  EventEmitter.call(this);
};
util.inherits(myEmiter,EventEmitter);//繼承EventEmitter類
const myEmitterIns = new myEmiter();
myEmitterIns.on('data',(o)=>{
  console.log('receive the data:'+o.a);
});

或者使用class類

class myEmiter extends EventEmitter{}//繼承EventEmitter類
const myEmitterIns = new myEmiter();

myEmitterIns.on('data',(o)=>{
  console.log('receive the data:'+o.a);
});
myEmitterIns.emit('data',{a:1});

執(zhí)行結果如下：

E:\developmentdocument\nodejsdemo>node event-example.js
receive the data:1

2、向事件監(jiān)聽回調(diào)函數(shù)傳遞參數(shù)

從上面的例子可以看出，emit()方法可以傳遞任意的參數(shù)集合給回調(diào)函數(shù)，需要注意的一點是this關鍵字指向的是調(diào)用emit方法的EventEmiter實例，但在箭頭函數(shù)中例外，this指向的是全局this，因為箭頭函數(shù)中的this是在定義時綁定。如下所示：

class myEmiter extends EventEmitter{}
const myEmitterIns = new myEmiter();
myEmitterIns.on('data',function(data){
  console.log("普通回調(diào)函數(shù)中this：");
  console.log(this);
});
myEmitterIns.on('data1',(data1)=>{
  console.log("箭頭回調(diào)函數(shù)中this：");
  console.log(this);
});
myEmitterIns.emit('data',{a:1});
myEmitterIns.emit('data1',{a:1});

執(zhí)行結果如下：

E:\developmentdocument\nodejsdemo>node event-example.js
普通回調(diào)函數(shù)中this：
myEmiter {
domain: null,
_events: { data: [Function], data1: [Function] },
_eventsCount: 2,
_maxListeners: undefined }
箭頭回調(diào)函數(shù)中this：
{}

這里講到箭頭函數(shù)中的this，就順便說一下，為什么箭頭函數(shù)能夠?qū)崿F(xiàn)定義時綁定this，就是因為箭頭函數(shù)內(nèi)部根本就沒有綁定this的機制，它使用的是外層作用域的this，因此它也不能作為構造函數(shù)。

3、事件監(jiān)聽程序的執(zhí)行順序

EventEmiter實例可以綁定多個事件，當我們順序觸發(fā)這些事件時，EventEmiter會以同步模式執(zhí)行，既第一個事件處理函數(shù)沒有完成，便不會觸發(fā)下一個事件，如下所示：

class myEmiter extends EventEmitter{}
const myEmitterIns = new myEmiter();
myEmitterIns.on('data',function(data){
  console.time('data事件執(zhí)行了');
  for(var i = 0 ; i< 100000; i++)
    for(var j = 0 ; j< 100000; j++)
      ;
  console.timeEnd('data事件執(zhí)行了');
});
myEmitterIns.on('data1',(data1)=>{
  console.log("data1事件開始執(zhí)行...");
});
myEmitterIns.emit('data',{a:1});
myEmitterIns.emit('data1',{a:1});

執(zhí)行結果如下：

E:\developmentdocument\nodejsdemo>node event-example.js
data事件執(zhí)行了: 4721.401ms
data1事件開始執(zhí)行...

當然我們可以在回調(diào)函數(shù)中使用異步操作，例如setTimeout，setImmediate或者process.nextTick()等，從而實現(xiàn)異步的效果，如下所示：

myEmitterIns.on('data',function(data){
  setImmediate(()=>{
    console.log('data事件執(zhí)行了...');
  });
});

執(zhí)行結果如下：

E:\developmentdocument\nodejsdemo>node event-example.js
data1事件執(zhí)行了...
data事件執(zhí)行了...

4、一次性事件監(jiān)聽

EventEmiter可以使用once監(jiān)聽某個事件，則該事件處理程序只會觸發(fā)一次，之后emit該事件都會被忽略，因為監(jiān)聽程序被注銷了，如下所示：

myEmitterIns.once('one',(data)=>{
  console.log(data);
});
myEmitterIns.emit('one','this is first call!');
myEmitterIns.emit('one','this is second call!');

執(zhí)行結果如下：

E:\developmentdocument\nodejsdemo>node event-example.js
this is first call!

從上面的結果看出，'one'事件只執(zhí)行了一次。

5、移除事件綁定

類似DOM事件監(jiān)聽，EventEmiter也可以移除事件綁定，利用removeListener(eventName,listener)方法解除某個事件的綁定，因此回調(diào)函數(shù)listener必須是命名函數(shù)，要不然找不到該函數(shù)，因為函數(shù)是引用型類型，就算函數(shù)體是一樣，也不是同一個函數(shù)，如下所示：

myEmitterIns.on('data',function(e){
  console.log(e);
});
myEmitterIns.removeListener('data',function(e){
  console.log(e);
});
myEmitterIns.emit('data','hello data!');
function deal(e){
  console.log(e);
}
myEmitterIns.on('data1',deal);
myEmitterIns.removeListener('data1',deal);
myEmitterIns.emit('data1','hello data1!');

執(zhí)行結果如下：

E:\developmentdocument\nodejsdemo>node event-example.js
hello data!
E:\developmentdocument\nodejsdemo>

從執(zhí)行結果可以看出，data事件使用的是匿名函數(shù)，因此沒有被移除掉，而data1事件則成功解除綁定了。這里需要注意一點的是emit觸發(fā)某個事件后，所有跟該事件綁定的回調(diào)函數(shù)都會被調(diào)用，即使你在某個回調(diào)函數(shù)中使用removeListener函數(shù)移除掉另一個回調(diào)也沒有用，但是隨后的事件隊列是移除了該回調(diào)的。如下所示：

function dealData1(e){
  console.log('data事件執(zhí)行了...A');
}
myEmitterIns.on('data',function(e){
  console.log(e);
  myEmitterIns.removeListener('data',dealData1);//這里解除dealData1的綁定
});
myEmitterIns.on('data',dealData1);
myEmitterIns.emit('data','data事件執(zhí)行了...B');
/*執(zhí)行結果為：
 data事件執(zhí)行了...B
 data事件執(zhí)行了...A
*/
//再次觸發(fā)該事件時,dealData1回調(diào)已經(jīng)被解除綁定了
myEmitterIns.emit('data','data事件執(zhí)行了...');
//data事件執(zhí)行了...

另外可以使用removeAllListeners()解除所有事件的綁定。

6、獲取事件監(jiān)聽數(shù)量和監(jiān)聽函數(shù)

使用emitter.listenerCount(eventName)函數(shù)獲取指定事件的監(jiān)聽數(shù)量，函數(shù)emitter.listeners(eventName)則可以用來獲取指定事件的所有監(jiān)聽函數(shù)，使用如下所示：

var cbA = ()=>{},
  cbB = ()=>{};
var emitter = new myEmiter();
emitter.on('data',cbA);
emitter.on('data',cbB);
console.log('emitter實例的data事件綁定了%d個回調(diào)函數(shù)',emitter.listenerCount('data'));
console.log('它們是：',emitter.listeners('data'));

執(zhí)行結果如下：

E:\developmentdocument\nodejsdemo>node event-example.js
emitter實例的data事件綁定了2個回調(diào)函數(shù)
它們是： [ [Function: cbA], [Function: cbB] ]

7、獲取和設置emitter的最大監(jiān)聽數(shù)量
nodejs對同一事件的監(jiān)聽數(shù)量建議不宜超過10個，這個可以查看EventEmitter.defaultMaxListeners屬性便可得知，如下所示：

console.log(EventEmitter.defaultMaxListeners);//結果為10個

emitter通過getMaxListeners()方法獲取最大監(jiān)聽數(shù)量以及setMaxListeners(n)方法設置最大監(jiān)聽數(shù)量,如下所示：

var cbA = ()=>{},
  cbB = ()=>{};
var emitter = new myEmiter();
emitter.setMaxListeners(1);
emitter.on('data',cbA);
emitter.on('data',cbB);
console.log(emitter.getMaxListeners());

執(zhí)行結果如下：

E:\developmentdocument\nodejsdemo>node event-example.js
emitter的事件最大監(jiān)聽數(shù)是：1
(node:6808) Warning: Possible EventEmitter memory leak detected. 2 data listener
s added. Use emitter.setMaxListeners() to increase limit

如上結果所示，如果設置了最大監(jiān)聽數(shù)量，則同一事件的監(jiān)聽最好不要超過該最大值，否則很可能發(fā)送內(nèi)存泄漏。

events模塊便介紹到這。希望對大家的學習有所幫助，也希望大家多多支持腳本之家。

最新評論