深入理解Node.js 事件循環和回調函數

本文詳細的介紹了Node.js 事件循環和Node.js回調函數，廢話不多說了，具體看下面把。

 一、Node.js 事件循環

Node.js 是單進程單線程應用程序，但透過事件和回調支援並發，所以效能非常高。 Node.js 的每一個 API 都是非同步的，並作為一個獨立執行緒運行，使用非同步函數調用，並處理並發。 Node.js 基本上所有的事件機制都是用設計模式中觀察者模式實作。 Node.js 單執行緒類似進入一個while(true)的事件循環，直到沒有事件觀察者退出，每個非同步事件都會產生一個事件觀察者，如果有事件發生就呼叫該回呼函數.

1、事件驅動程式

Node.js 使用事件驅動模型，當web server接收到請求，就把它關閉然後進行處理，然後去服務下一個web請求。當這個請求完成，它被放回處理佇列，當到達佇列開頭，這個結果被回傳給使用者。這個模型非常有效率可擴充性非常強，因為web server一直接受請求而不等待任何讀寫操作。 （這也稱為非阻塞式IO或事件驅動IO）。在事件驅動模型中，會產生一個主循環來監聽事件，當偵測到事件時觸發回呼函數。

整個事件驅動的流程就是這麼實現的，非常簡潔。有點類似觀察者模式，事件相當於一個主題(Subject)，而所有註冊到這個事件上的處理函數相當於觀察者(Observer)。 Node.js 有多個內建的事件，我們可以透過引入events 模組，並透過實例化EventEmitter 類別來綁定和監聽事件，以下實例：

// 引入 events 模块
var events = require('events');
// 创建 eventEmitter 对象
var eventEmitter = new events.EventEmitter();
以下程序绑定事件处理程序：
// 绑定事件及事件的处理程序
eventEmitter.on('eventName', eventHandler);
我们可以通过程序触发事件：
// 触发事件
eventEmitter.emit('eventName');

   

2、存在實例

js 文件，程式碼如下：

// 引入 events 模块
var events = require('events');
// 创建 eventEmitter 对象
var eventEmitter = new events.EventEmitter();
// 创建事件处理程序
var connectHandler = function connected() {
  console.log('连接成功。');
  // 触发 data_received 事件
  eventEmitter.emit('data_received');
}
// 绑定 connection 事件处理程序
eventEmitter.on('connection', connectHandler);
// 使用匿名函数绑定 data_received 事件
eventEmitter.on('data_received', function(){
  console.log('数据接收成功。');
});
// 触发 connection 事件
eventEmitter.emit('connection');
console.log("程序执行完毕。");

   

二、Node.js 回呼函數

Node.js 非同步程式設計的直接體現就是回調。非同步程式設計依託於回調來實現，但不能說使用了回調後程式就非同步化了。回調函數在完成任務後就會被調用，Node 使用了大量的回調函數，Node 所有 API 都支援回調函數。例如，我們可以一邊讀取文件，一邊執行其他命令，在文件讀取完成後，我們將文件內容作為回調函數的參數傳回。這樣在執行程式碼時就沒有阻塞或等待檔案 I/O 操作。這大大提高了 Node.js 的效能，可以處理大量的並發請求。

1、阻塞程式碼實例

建立一個檔案test.txt ，內容如下：

Hello World!
fs.readFileSync()
fs.readFile()

   

建立test.js 檔案, 執行程式碼上述

2、非阻塞程式碼實例

建立test.js 檔案, 程式碼如下：

console.log('-------程序开始执行--------'); 
// 引入fs模块
var fs = require("fs");
//同步读取文件
var data = fs.readFileSync('test.txt','utf-8');
console.log(data.toString());
console.log('-------程序执行结束--------');

   

以上程式中fs.readFile() 是非同步函數用於讀取檔案。如果在讀取檔案過程中發生錯誤，錯誤 err 物件就會輸出錯誤訊息。如果沒發生錯誤，readFile 跳過 err 物件的輸出，檔案內容就透過回呼函數輸出。

以上程式碼執行結果如下：

接下來我們刪除 input.txt 文件，執行結果如下所示：

 以上兩個實例我們了解了阻塞與非阻塞呼叫的不同。第一個實例在檔案讀取完後才執行完程式。第二個實例我們不需要等待檔案讀取完，這樣就可以在讀取檔案時同時執行接下來的程式碼，大大提升了程式的效能。因此，阻塞按是按順序執行的，而非阻塞是不需要按順序的，所以如果需要處理回調函數的參數，我們就需要寫在回調函數內。

三、fs.readFileSync和fs.readFile

1、s.readFileSync

語法：fs.readFileSync(filename, [encoding]) 

接收參數：op ，包含encoding，編碼格式，該項是可選的。

 由於Node.js只支援以下編碼：utf8, ucs2, ascii, binary, base64, hex，並不支援中文GBK或GB2312之類的編碼，因此如果要讀寫GBK或GB2312格式的檔案的中文內容，必須要用額外的模組：iconv-lite。

2、fs.readFile

語法：fs.readFile(filename, [encoding], [callback(err,data)])

接收參數：

  filename：檔案路徑

接收參數：

  filename：檔案路徑🎜🎜接收，編碼格式，該項是可選的。 🎜🎜  callback ：回調，傳遞2個參數 異常err 和 文件內容 data🎜🎜🎜🎜