第四章 建議學習時間3小時 課程共10章

學習方式：詳細閱讀，並手動實現相關代碼

學習目標：此教程將教會大家 安裝Node、搭建服務器、express、mysql、mongodb、編寫後臺業務邏輯、編寫接口，最後完成一個完整的項目後臺，預計共10天課程。

node.js事件機制

node.js是單線程，但是通過事件和回調支持並發，可以實現非常高的性能。

node.js所有的API都是通過異步調用。第一堂課的時候，我們寫過一個同步和異步的示例（如下），當初說到：同步代碼先執行完成，然後才執行異步代碼。

setTimeout(function(){
    console.log(1000000000);
},
 
0);

for(var i=0; i<1000; i++){
    console.log(i);
}

而對於異步的多個代碼，它們的執行順序是怎樣的呢？試試下面的代碼：

今天的代碼我們放到一個新的文件夾 中，為了完成下面的文件讀取，我們需要提前準備一個a.txt的文件（註意：文件格式最好是uft-8）

main.js中寫入如下代碼：

var fs = require("fs"); //node 內置模塊可直接引入  fs：文件系統操作模塊
fs.readFile("./a.txt","utf-8",function(err,data){  //讀取文件
    if(err) throw err;
    console.log(data);
});
setTimeout(
 
function(){
    console.log("定時器打印！");
},0);

使用 node 運行 main.js後，你會發現定時器的先打印，（增加定時器的觸發時間，你會發現，打印的順序會改變。）

具體的異步代碼執行順序，是由node.js內部機制控制的，我們很難準確預知。這裏給大家介紹一下node.js的事件模型：

Node.js 使用事件驅動模型，當web server接收到請求，就把它關閉然後進行處理，然後去服務下一個web請求。

當這個請求完成，它被放回處理隊列，當到達隊列開頭，這個結果被返回給用戶。

這個模型非常高效可擴展性非常強，因為webserver一直接受請求而不等待任何讀寫操作。（這也被稱之為非阻塞式IO或者事件驅動IO）

在事件驅動模型中，會生成一個主循環來監聽事件，當檢測到事件時觸發回調函數。

回調函數

回調函數就是將一個函數作為另一個函數的參數傳入，作為另一個函數內部執行的函數。

我們上面示例中的文件讀取方法中，第三個參數是一個回調函數，當文件讀取完成，就會自動調用這個函數。

fs.readFile("./a.txt","utf-8",function(err,data){  //讀取文件
    if(err) throw err;
    console.log(data);
});

上面的回調是封裝好的，那麽我們自己來寫一個回調函數的實現樣子：

創建 一個js文件，寫入如下代碼：

function fn01(data,callback){
    if(data){
        callback("",data);
    }else{
        var err = new Error("錯誤了");
        callback(err)
    }
}

fn01("aa",function(err,data){
    if(err){
        console.log("錯誤"+err);
    }else{
        console.log(data);
    }
})

上面代碼是回調函數的標準模型，我們在調用 fn01的時候，傳入了兩個參數，第一個是字符串，第二個是一個回調函數，當參數傳入以後。我們來看fn01的主方法，方法中檢測第一個參數的存在情況來，然後執行callback方法，也就是執行了當參數傳入的那個方法。

異步IO操作

我們前面講的文件讀取的方式是一次性全部讀取，當文件過大的時候，一次性讀取不僅緩慢，而且影響用戶體驗，那麽怎麽實現分步讀取呢，

這就得使用到異步IO的操作，像水流一樣流出一段取得一段。

具體實現：

我們創建一個文件讀取流，先上代碼

var fs = require("fs");

var  data = "";  //聲明一個空字符串來存讀取的數據
var rs = fs.createReadStream("a.txt");

rs.setEncoding("utf-8");

//監聽當有數據流入的時候
rs.on("data",function(chunc){
    data += chunc;       //將讀取的數據拼接到data上。
    console.log("..."); //讀的過程中，我們打印三個點。
});

rs.on("end",function(){
    console.log("沒有數據了")
});

我們將 a.txt中的內容增加，以讓讀取時間變長，

代碼中，創建main3.js寫入上面的代碼，使用 reateReadStream創建讀取流對象，在對象上使用on監聽“data”讀取數據的事件，每讀取一段數據，就會觸發這個事件，當讀取完畢， 就會觸發“end”事件。

執行main3.js，我們就可以看到下面打印的結果，從打印的多行"..."中，我們就可以看出，讀取了多次才讀完。

將讀取到的數據，慢慢的寫入 b.txt中

修改mai3.js中的代碼為如下，增加了下面代碼的 4/10/16行，4行表示建立一個寫入流（如果寫入的文件不存在，會自動創建一個文件），10行表示往文件寫入東西，16行表示關閉寫入流。

 1 var fs = require("fs");
 2 
 3 var rs = fs.createReadStream("a.txt");
 4 var ws = fs.createWriteStream("b.txt"); //寫入流
 5 rs.setEncoding("utf-8");
 6 
 7 //監聽當有數據流入的時候
 8 rs.on("data",function(chunc){
 9     console.log("..."); //讀的過程中，我們打印三個點。
10     ws.write(chunc,"utf-8"); //向文件寫入東西
11 });
12 
13 
14 rs.on("end",function(){
15     console.log("沒有數據了");
16     ws.end();                 //關閉寫入流
17 });

這樣我們異步的讀取和寫入文件就實現了

好，今天就講這麽多，明天將講解：express 路由。

node.js零基礎詳細教程(4)：node.js事件機制、node異步IO操作