Node.js事件發(fā)射器

在Node很多對象發(fā)出事件，例如net.Server每個同級連接到它，一個fs.readStream發(fā)出打開文件事件時，每次都發(fā)出一個事件。 它發(fā)出事件的所有對象都是events.EventEmitter的實例。

EventEmitter 類

正如我們已經(jīng)看到在上一節(jié)，EventEmitter類在于事件的模塊。它是通過通俗易懂的語法如下：

// Import events module
var events = require('events');
// Create an eventEmitter object
var eventEmitter = new events.EventEmitter();

EventEmitter實例對任何錯誤，它會發(fā)出一個“error”事件。當(dāng)新的偵聽器被添加，“newListener'事件被觸發(fā)，當(dāng)一個偵聽器被刪除，'removeListener”事件被觸發(fā)。

EventEmitter提供多種性能如在發(fā)射。On屬性用于綁定事件函數(shù)，發(fā)射用于觸發(fā)一個事件。

方法

類方法

事件

例子

創(chuàng)建一個名為main.js，使用以下Node.js的代碼js文件：

var events = require('events');
var eventEmitter = new events.EventEmitter();

// listener #1
var listner1 = function listner1() {
   console.log('listner1 executed.');
}

// listener #2
var listner2 = function listner2() {
  console.log('listner2 executed.');
}

// Bind the connection event with the listner1 function
eventEmitter.addListener('connection', listner1);

// Bind the connection event with the listner2 function
eventEmitter.on('connection', listner2);

var eventListeners = require('events').EventEmitter.listenerCount(eventEmitter,'connection');
console.log(eventListeners + " Listner(s) listening to connection event");

// Fire the connection event 
eventEmitter.emit('connection');

// Remove the binding of listner1 function
eventEmitter.removeListener('connection', listner1);
console.log("Listner1 will not listen now.");

// Fire the connection event 
eventEmitter.emit('connection');

eventListeners = require('events').EventEmitter.listenerCount(eventEmitter,'connection');
console.log(eventListeners + " Listner(s) listening to connection event");

console.log("Program Ended.");

現(xiàn)在運行main.js看到的結(jié)果：

$ node main.js

驗證輸出

2 Listner(s) listening to connection event
listner1 executed.
listner2 executed.
Listner1 will not listen now.
listner2 executed.
1 Listner(s) listening to connection event
Program Ended.