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

第四章 建議學習時間2小時  課程共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行表示關閉寫入流。

var fs = require("fs");

var rs = fs.createReadStream("a.txt");
var ws = fs.createWriteStream("b.txt"); //寫入流
rs.setEncoding("utf-8");

//監聽當有數據流入的時候
rs.on("data",function(chunc){
    console.log("..."); //讀的過程中，我們打印三個點。
    ws.write(chunc,"utf-8"); //向文件寫入東西
});


rs.on("end",function(){
    console.log("沒有數據了");
    ws.end();                 //關閉寫入流
});

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

 

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