01收夸、模塊
02蜗顽、關(guān)注學(xué)習(xí)
03布卡、Node.js 回調(diào)函數(shù)
Node.js 異步編程的直接體現(xiàn)就是回調(diào)。
異步編程依托于回調(diào)來(lái)實(shí)現(xiàn)雇盖，但不能說(shuō)使用了回調(diào)后程序就異步化了羽利。
回調(diào)函數(shù)在完成任務(wù)后就會(huì)被調(diào)用，Node 使用了大量的回調(diào)函數(shù)刊懈，Node 所有 API 都支持回調(diào)函數(shù)这弧。
04、Node.js 事件循環(huán)
Node.js 是單進(jìn)程單線程應(yīng)用程序虚汛，但是通過(guò)事件和回調(diào)支持并發(fā)匾浪，所以性能非常高。
Node.js 的每一個(gè) API 都是異步的卷哩，并作為一個(gè)獨(dú)立線程運(yùn)行蛋辈，使用異步函數(shù)調(diào)用，并處理并發(fā)将谊。
Node.js 基本上所有的事件機(jī)制都是用設(shè)計(jì)模式中觀察者模式實(shí)現(xiàn)冷溶。
Node.js 單線程類似進(jìn)入一個(gè)while(true)的事件循環(huán)，直到?jīng)]有事件觀察者退出尊浓，每個(gè)異步事件都生成一個(gè)事件觀察者逞频，如果有事件發(fā)生就調(diào)用該回調(diào)函數(shù).
事件驅(qū)動(dòng)程序
Node.js 使用事件驅(qū)動(dòng)模型，當(dāng)web server接收到請(qǐng)求栋齿，就把它關(guān)閉然后進(jìn)行處理苗胀，然后去服務(wù)下一個(gè)web請(qǐng)求襟诸。
當(dāng)這個(gè)請(qǐng)求完成，它被放回處理隊(duì)列基协，當(dāng)?shù)竭_(dá)隊(duì)列開(kāi)頭歌亲，這個(gè)結(jié)果被返回給用戶。
這個(gè)模型非常高效可擴(kuò)展性非常強(qiáng)澜驮，因?yàn)閣ebserver一直接受請(qǐng)求而不等待任何讀寫(xiě)操作陷揪。（這也被稱之為非阻塞式IO或者事件驅(qū)動(dòng)IO）
在事件驅(qū)動(dòng)模型中，會(huì)生成一個(gè)主循環(huán)來(lái)監(jiān)聽(tīng)事件杂穷，當(dāng)檢測(cè)到事件時(shí)觸發(fā)回調(diào)函數(shù)悍缠。
// 引入 events 模塊
var events = require('events');
// 創(chuàng)建 eventEmitter 對(duì)象
var eventEmitter = new events.EventEmitter();
// 綁定事件及事件的處理程序
eventEmitter.on('eventName', eventHandler);
// 觸發(fā)事件
eventEmitter.emit('eventName');
05、Node 應(yīng)用程序是如何工作的亭畜？
在 Node 應(yīng)用程序中，執(zhí)行異步操作的函數(shù)將回調(diào)函數(shù)作為最后一個(gè)參數(shù)迎卤， 回調(diào)函數(shù)接收錯(cuò)誤對(duì)象作為第一個(gè)參數(shù)拴鸵。
接下來(lái)讓我們來(lái)重新看下前面的實(shí)例，創(chuàng)建一個(gè) input.txt ,文件內(nèi)容如下：
學(xué)術(shù)有專攻
創(chuàng)建 main.js 文件蜗搔，代碼如下：
var fs = require("fs");
fs.readFile('input.txt', function (err, data) {
if (err){
console.log(err.stack);
return;
}
console.log(data.toString());
});
console.log("程序執(zhí)行完畢");
以上程序中 fs.readFile() 是異步函數(shù)用于讀取文件劲藐。 如果在讀取文件過(guò)程中發(fā)生錯(cuò)誤，錯(cuò)誤 err 對(duì)象就會(huì)輸出錯(cuò)誤信息樟凄。
如果沒(méi)發(fā)生錯(cuò)誤聘芜，readFile 跳過(guò) err 對(duì)象的輸出，文件內(nèi)容就通過(guò)回調(diào)函數(shù)輸出缝龄。
06汰现、Node.js EventEmitter
Node.js 所有的異步 I/O 操作在完成時(shí)都會(huì)發(fā)送一個(gè)事件到事件隊(duì)列。
Node.js里面的許多對(duì)象都會(huì)分發(fā)事件：一個(gè)net.Server對(duì)象會(huì)在每次有新連接時(shí)分發(fā)一個(gè)事件叔壤， 一個(gè)fs.readStream對(duì)象會(huì)在文件被打開(kāi)的時(shí)候發(fā)出一個(gè)事件瞎饲。 所有這些產(chǎn)生事件的對(duì)象都是 events.EventEmitter 的實(shí)例
EventEmitter 的每個(gè)事件由一個(gè)事件名和若干個(gè)參數(shù)組成，事件名是一個(gè)字符串炼绘，通常表達(dá)一定的語(yǔ)義嗅战。對(duì)于每個(gè)事件，EventEmitter 支持 若干個(gè)事件監(jiān)聽(tīng)器俺亮。
當(dāng)事件觸發(fā)時(shí)驮捍，注冊(cè)到這個(gè)事件的事件監(jiān)聽(tīng)器被依次調(diào)用，事件參數(shù)作為回調(diào)函數(shù)參數(shù)傳遞脚曾。
讓我們以下面的例子解釋這個(gè)過(guò)程：
//event.js 文件
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', 'arg1 參數(shù)', 'arg2 參數(shù)');
執(zhí)行以上代碼东且，運(yùn)行的結(jié)果如下：
$ node event.js
listener1 arg1 參數(shù) arg2 參數(shù)
listener2 arg1 參數(shù) arg2 參數(shù)
以上例子中，emitter 為事件 someEvent 注冊(cè)了兩個(gè)事件監(jiān)聽(tīng)器本讥，然后觸發(fā)了 someEvent 事件苇倡。
運(yùn)行結(jié)果中可以看到兩個(gè)事件監(jiān)聽(tīng)器回調(diào)函數(shù)被先后調(diào)用富纸。 這就是EventEmitter最簡(jiǎn)單的用法。
EventEmitter 提供了多個(gè)屬性旨椒，如 on 和 emit晓褪。on 函數(shù)用于綁定事件函數(shù)，emit 屬性用于觸發(fā)一個(gè)事件
07综慎、 EventEmitter 的屬性介紹
序號(hào) 方法 & 描述
1 addListener(event, listener)
為指定事件添加一個(gè)監(jiān)聽(tīng)器到監(jiān)聽(tīng)器數(shù)組的尾部涣仿。
2 on(event, listener)
為指定事件注冊(cè)一個(gè)監(jiān)聽(tīng)器，接受一個(gè)字符串 event 和一個(gè)回調(diào)函數(shù)示惊。
server.on('connection', function (stream) {
console.log('someone connected!');
});
3 once(event, listener)
為指定事件注冊(cè)一個(gè)單次監(jiān)聽(tīng)器好港，即 監(jiān)聽(tīng)器最多只會(huì)觸發(fā)一次，觸發(fā)后立刻解除該監(jiān)聽(tīng)器米罚。
server.once('connection', function (stream) {
console.log('Ah, we have our first user!');
});
4 removeListener(event, listener)
移除指定事件的某個(gè)監(jiān)聽(tīng)器钧汹，監(jiān)聽(tīng)器必須是該事件已經(jīng)注冊(cè)過(guò)的監(jiān)聽(tīng)器。
它接受兩個(gè)參數(shù)录择，第一個(gè)是事件名稱拔莱，第二個(gè)是回調(diào)函數(shù)名稱。
var callback = function(stream) {
console.log('someone connected!');
};
server.on('connection', callback);
// ...
server.removeListener('connection', callback);
5 removeAllListeners([event])
移除所有事件的所有監(jiān)聽(tīng)器隘竭， 如果指定事件塘秦，則移除指定事件的所有監(jiān)聽(tīng)器。
6 setMaxListeners(n)
默認(rèn)情況下动看， EventEmitters 如果你添加的監(jiān)聽(tīng)器超過(guò) 10 個(gè)就會(huì)輸出警告信息尊剔。 setMaxListeners 函數(shù)用于提高監(jiān)聽(tīng)器的默認(rèn)限制的數(shù)量。
7 listeners(event)
返回指定事件的監(jiān)聽(tīng)器數(shù)組菱皆。
8 emit(event, [arg1], [arg2], [...])
按參數(shù)的順序執(zhí)行每個(gè)監(jiān)聽(tīng)器须误，如果事件有注冊(cè)監(jiān)聽(tīng)返回 true，否則返回 false仇轻。
類方法
序號(hào) 方法 & 描述
1 listenerCount(emitter, event)
返回指定事件的監(jiān)聽(tīng)器數(shù)量霹期。
事件
序號(hào) 事件 & 描述
1 newListener
event - 字符串，事件名稱
listener - 處理事件函數(shù)
該事件在添加新監(jiān)聽(tīng)器時(shí)被觸發(fā)拯田。
2 removeListener
event - 字符串历造，事件名稱
listener - 處理事件函數(shù)
從指定監(jiān)聽(tīng)器數(shù)組中刪除一個(gè)監(jiān)聽(tīng)器。需要注意的是船庇，此操作將會(huì)改變處于被刪監(jiān)聽(tīng)器之后的那些監(jiān)聽(tīng)器的索引吭产。
實(shí)例
以下實(shí)例通過(guò) connection（連接）事件演示了 EventEmitter 類的應(yīng)用。
創(chuàng)建 main.js 文件鸭轮，代碼如下：
var events = require('events');
var eventEmitter = new events.EventEmitter();
// 監(jiān)聽(tīng)器 #1
var listener1 = function listener1() {
console.log('監(jiān)聽(tīng)器 listener1 執(zhí)行臣淤。');
}
// 監(jiān)聽(tīng)器 #2
var listener2 = function listener2() {
console.log('監(jiān)聽(tīng)器 listener2 執(zhí)行。');
}
// 綁定 connection 事件窃爷，處理函數(shù)為 listener1
eventEmitter.addListener('connection', listener1);
// 綁定 connection 事件邑蒋，處理函數(shù)為 listener2
eventEmitter.on('connection', listener2);
var eventListeners = require('events').EventEmitter.listenerCount(eventEmitter,'connection');
console.log(eventListeners + " 個(gè)監(jiān)聽(tīng)器監(jiān)聽(tīng)連接事件姓蜂。");
// 處理 connection 事件
eventEmitter.emit('connection');
// 移除監(jiān)綁定的 listener1 函數(shù)
eventEmitter.removeListener('connection', listener1);
console.log("listener1 不再受監(jiān)聽(tīng)。");
// 觸發(fā)連接事件
eventEmitter.emit('connection');
eventListeners = require('events').EventEmitter.listenerCount(eventEmitter,'connection');
console.log(eventListeners + " 個(gè)監(jiān)聽(tīng)器監(jiān)聽(tīng)連接事件医吊。");
console.log("程序執(zhí)行完畢钱慢。");
執(zhí)行結(jié)果：
$ node main.js
2 個(gè)監(jiān)聽(tīng)器監(jiān)聽(tīng)連接事件。
監(jiān)聽(tīng)器 listener1 執(zhí)行卿堂。
監(jiān)聽(tīng)器 listener2 執(zhí)行束莫。
listener1 不再受監(jiān)聽(tīng)。
監(jiān)聽(tīng)器 listener2 執(zhí)行草描。
1 個(gè)監(jiān)聽(tīng)器監(jiān)聽(tīng)連接事件览绿。
程序執(zhí)行完畢。
error 事件
EventEmitter 定義了一個(gè)特殊的事件 error穗慕，它包含了錯(cuò)誤的語(yǔ)義饿敲，我們?cè)谟龅?異常的時(shí)候通常會(huì)觸發(fā) error 事件。
當(dāng) error 被觸發(fā)時(shí)逛绵，EventEmitter 規(guī)定如果沒(méi)有響 應(yīng)的監(jiān)聽(tīng)器怀各，Node.js 會(huì)把它當(dāng)作異常，退出程序并輸出錯(cuò)誤信息暑脆。
我們一般要為會(huì)觸發(fā) error 事件的對(duì)象設(shè)置監(jiān)聽(tīng)器渠啤，避免遇到錯(cuò)誤后整個(gè)程序崩潰狐肢。例如：
var events = require('events');
var emitter = new events.EventEmitter();
emitter.emit('error');
運(yùn)行時(shí)會(huì)顯示以下錯(cuò)誤：
node.js:201
throw e; // process.nextTick error, or 'error' event on first tick
^
Error: Uncaught, unspecified 'error' event.
at EventEmitter.emit (events.js:50:15)
at Object.<anonymous> (/home/byvoid/error.js:5:9)
at Module._compile (module.js:441:26)
at Object..js (module.js:459:10)
at Module.load (module.js:348:31)
at Function._load (module.js:308:12)
at Array.0 (module.js:479:10)
at EventEmitter._tickCallback (node.js:192:40)
繼承 EventEmitter
大多數(shù)時(shí)候我們不會(huì)直接使用 EventEmitter添吗，而是在對(duì)象中繼承它。包括 fs份名、net碟联、 http 在內(nèi)的，只要是支持事件響應(yīng)的核心模塊都是 EventEmitter 的子類僵腺。
為什么要這樣做呢鲤孵？原因有兩點(diǎn)：
首先，具有某個(gè)實(shí)體功能的對(duì)象實(shí)現(xiàn)事件符合語(yǔ)義辰如， 事件的監(jiān)聽(tīng)和發(fā)射應(yīng)該是一個(gè)對(duì)象的方法普监。
其次 JavaScript 的對(duì)象機(jī)制是基于原型的，支持 部分多重繼承琉兜，繼承 EventEmitter 不會(huì)打亂對(duì)象原有的繼承關(guān)系
