摘要：事件的監(jiān)聽與事件的觸發(fā)事件一事件機制的實現(xiàn)中大部分的模塊，都繼承自模塊。從另一個角度來看，事件偵聽器模式也是一種事件鉤子的機制，利用事件鉤子導出內(nèi)部數(shù)據(jù)或狀態(tài)給外部調(diào)用者。的核心就是事件發(fā)射與事件監(jiān)聽器功能的封裝。

nodejs事件(Events)

一、事件機制的實現(xiàn)

Node.js中大部分的模塊，都繼承自Event模塊（http://nodejs.org/docs/latest... ）。Event模塊（events.EventEmitter）是一個簡單的事件監(jiān)聽器模式的實現(xiàn)。具有addListener/on，once，removeListener，removeAllListeners，emit等基本的事件監(jiān)聽模式的方法實現(xiàn)。它與前端DOM樹上的事件并不相同，因為它不存在冒泡，逐層捕獲等屬于DOM的事件行為，也沒有preventDefault()、stopPropagation()、 stopImmediatePropagation() 等處理事件傳遞的方法。
從另一個角度來看，事件偵聽器模式也是一種事件鉤子（hook）的機制，利用事件鉤子導出內(nèi)部數(shù)據(jù)或狀態(tài)給外部調(diào)用者。Node.js中的很多對象，大多具有黑盒的特點，功能點較少，如果不通過事件鉤子的形式，對象運行期間的中間值或內(nèi)部狀態(tài)，是我們無法獲取到的。這種通過事件鉤子的方式，可以使編程者不用關注組件是如何啟動和執(zhí)行的，只需關注在需要的事件點上即可。

二、事件觸發(fā)

events 模塊只提供了一個對象： events.EventEmitter。EventEmitter的核心就是事件發(fā)射與事件監(jiān)聽器功能的封裝。EventEmitter的每個事件由一個事件名和若干個參數(shù)組成，事件名是一個字符串，通常表達一定的語義。對于每個事件，EventEmitter支持若干個事件監(jiān)聽器。當事件發(fā)射時，注冊到這個事件的事件監(jiān)聽器被依次調(diào)用，事件參數(shù)作為回調(diào)函數(shù)參數(shù)傳遞。

　　讓我們以下面的例子解釋這個過程：

//引入事件模塊
var events = require("events");

//創(chuàng)建事件監(jiān)聽的一個對象
var  emitter = new events.EventEmitter();

//監(jiān)聽事件some_event
emitter.addListener("some_event",function(){
    console.log("事件觸發(fā)，調(diào)用此回調(diào)函數(shù)");
});

//觸發(fā)事件some_event
emitter.emit("some_event");

　運行結(jié)果：事件觸發(fā)，調(diào)用此回調(diào)函數(shù)

　例子：

var events = require("events");
var emitter = new events.EventEmitter();
emitter.on("someEvent", function(arg1, arg2) {
console.log("listener1", arg1, arg2);
});
emitter.on("someEvent", function(arg1, arg2) {
console.log("listener2", arg1, arg2);
});
emitter.emit("someEvent", "byvoid", 1991);

　運行的結(jié)果是：

　　listener1 byvoid 1991

  listener2 byvoid 1991

　　以上例子中，emitter 為事件 someEvent 注冊了兩個事件監(jiān)聽器，然后發(fā)射了someEvent事件。運行結(jié)果中可以看到兩個事件監(jiān)聽器回調(diào)函數(shù)被先后調(diào)用。這就是EventEmitter最簡單的用法。接下來我們介紹一下EventEmitter常用的API。
　　 EventEmitter.on(event, listener) 為指定事件注冊一個監(jiān)聽器，接受一個字符串 event 和一個回調(diào)函數(shù)listener。EventEmitter.emit(event, [arg1], [arg2], [...]) 發(fā)射 event事件，傳遞若干可選參數(shù)到事件監(jiān)聽器的參數(shù)表。
　　EventEmitter.once(event, listener) 為指定事件注冊一個單次監(jiān)聽器，即監(jiān)聽器最多只會觸發(fā)一次，觸發(fā)后立刻解除該監(jiān)聽器。
　　EventEmitter.removeListener(event, listener) 移除指定事件的某個監(jiān)聽器，listener 必須是該事件已經(jīng)注冊過的監(jiān)聽器。
　　EventEmitter.removeAllListeners([event]) 移除所有事件的所有監(jiān)聽器，如果指定 event，則移除指定事件的所有監(jiān)聽器。
　　更詳細的 API 文檔參見 http://nodejs.org/api/events....。

　想想其實跟jquery自定義事件很相似:

//給element綁定hello事件
element.on("hello",function(){
  alert("hello world!");
});
//觸發(fā)hello事件
element.trigger("hello");

三、事件機制的進階應用

繼承event.EventEmitter

實現(xiàn)一個繼承了EventEmitter類是十分簡單的，以下是Node.js中流對象繼承EventEmitter的例子：

var util = require("util");

var events = require("events");

//創(chuàng)建構(gòu)造事件對象的構(gòu)造函數(shù)
function Stream(){
    events.EventEmitter.call(this);
}
util.inherits(Stream, events.EventEmitter);

//實例創(chuàng)建事件監(jiān)聽的一個對象
var elem = new Stream();

//監(jiān)聽事件
elem.addListener("one_event",function(){
    console.log("事件觸發(fā)，調(diào)用此回調(diào)函數(shù)");
});

//觸發(fā)事件some_event
elem.emit("one_event");

值得一提的是如果對一個事件添加了超過10個偵聽器，將會得到一條警告，這一處設計與Node.js自身單線程運行有關，設計者認為偵聽器太多，可能導致內(nèi)存泄漏，所以存在這樣一個警告。

實例：

var util = require("util");

var events = require("events");

function Stream(){
    events.EventEmitter.call(this);
}
util.inherits(Stream, events.EventEmitter);

var elem = new Stream();

elem.addListener("我來了",function(arg1,arg2){
    console.log("事件觸發(fā)，調(diào)用此回調(diào)函數(shù)",arg1,arg2,1);
});

elem.addListener("我來了",function(arg1,arg2){
    console.log("事件觸發(fā)，調(diào)用此回調(diào)函數(shù)",arg1,arg2,2);
});

elem.addListener("我來了",function(arg1,arg2){
    console.log("事件觸發(fā)，調(diào)用此回調(diào)函數(shù)",arg1,arg2,3);
});

elem.addListener("我來了",function(arg1,arg2){
    console.log("事件觸發(fā)，調(diào)用此回調(diào)函數(shù)",arg1,arg2,4);
});

elem.addListener("我來了",function(arg1,arg2){
    console.log("事件觸發(fā)，調(diào)用此回調(diào)函數(shù)",arg1,arg2,5);
});

elem.addListener("我來了",function(arg1,arg2){
    console.log("事件觸發(fā)，調(diào)用此回調(diào)函數(shù)",arg1,arg2,6);
});

elem.addListener("我來了",function(arg1,arg2){
    console.log("事件觸發(fā)，調(diào)用此回調(diào)函數(shù)",arg1,arg2,7);
});

elem.addListener("我來了",function(arg1,arg2){
    console.log("事件觸發(fā)，調(diào)用此回調(diào)函數(shù)",arg1,arg2,8);
});

elem.addListener("我來了",function(arg1,arg2){
    console.log("事件觸發(fā)，調(diào)用此回調(diào)函數(shù)",arg1,arg2,9);
});

elem.addListener("我來了",function(arg1,arg2){
    console.log("事件觸發(fā)，調(diào)用此回調(diào)函數(shù)",arg1,arg2,10);
});
elem.addListener("我來了",function(arg1,arg2){
    console.log("事件觸發(fā)，調(diào)用此回調(diào)函數(shù)",arg1,arg2,11);
});
//觸發(fā)事件some_event
elem.emit("我來了","one","two");

我們通過調(diào)用emitter.setMaxListeners(0)，就可以去帶哦限制

emitter.setMaxListeners(0);

一個經(jīng)典的事件監(jiān)聽觸發(fā)，進程通信例子：
master.js　

var childprocess = require("child_process");
var worker = childprocess.fork("./worker.js");

console.log("pid in master:", process.pid);

//監(jiān)聽事件
worker.on("message", function(msg) {
  console.log("1:", msg);
})
process.on("message", function(msg) {
  console.log("2:", msg);
})

worker.send("---");

//觸發(fā)事件 message
process.emit("message", "------");

　　worker.js

console.log("pid in worker:", process.pid);

process.on("message", function(msg) {
  console.log("3:", msg);
});

process.send("===");
process.emit("message", "======");

　　運行結(jié)果：

$ node master.js


pid in master: 22229      // 主進程創(chuàng)建后打印其 pid
2: ------                 // 主進程收到給自己發(fā)的消息
pid in worker: 22230      // 子進程創(chuàng)建后打印其 pid
3: ======                 // 子進程收到給自己發(fā)的消息 
1: ===                    // 主進程收到來自子進程的消息
3: ---                    // 子進程收到來自主進程的消息

其中有兩個有趣的點：

　　在主進程中，使用 worker.on("message", ...) 監(jiān)聽來自子進程的消息，使用 process.on("message", ...) 監(jiān)聽給自己發(fā)的消息。但是在子進程中，只有 process.on("message", ...) 一種消息監(jiān)聽方式，無法區(qū)分消息來源。

如果有給自己發(fā)消息的情況，則必須將對應的消息監(jiān)聽的代碼放在消息發(fā)送代碼前面，否則無法監(jiān)聽到該消息發(fā)送。例如將 master.js 的最后一行代碼 process.emit("message", "------"); 放置到該文件第一行，則運行結(jié)果不會輸出 2: ------。

如果不能控制消息監(jiān)聽代碼和消息發(fā)送代碼的先后順序，可將給自己發(fā)送消息的代碼改寫為 setImmediate(process.emit.bind(process, "message", {{message}}));

　參考資料:

　　http://www.cnblogs.com/zhongw...（很多實例）

　　http://www.infoq.com/cn/artic...

　　http://www.toolmao.com/nodejs...

　　http://www.ynpxrz.com/n691854...

　　http://www.jb51.net/article/6...