Nodejs的單執行緒非阻塞I/O事件驅動

在 Java、PHP 或者.net 等伺服器端語言中，會為每一個客戶端連線建立一個新的執行緒。 而每個執行緒需要耗費大約 2MB 記憶體。也就是說，理論上，一個 8GB 記憶體的伺服器可以同時 連線的最大使用者數為 4000 個左右。要讓 Web 應用程式支援更多的使用者，就需要增加伺服器 的數量，而 Web 應用程式的硬體成本當然就上升了。 Node.js 不為每個客戶連線建立一個新的執行緒，而僅僅使用一個執行緒。當有使用者連線了， 就觸發一個內部事件，通過非阻塞 I/O、事件驅動機制，讓 Node.js 程式巨集觀上也是並行的。 使用 Node.js，一個 8GB 記憶體的伺服器，可以同時處理超過4 萬用戶的連線。

Nodejs 回撥處理非同步

//錯誤的寫法：  
function getData (){ 
    // 模擬請求資料     
    var result=''; 
    setTimeout(function(){         
         result='這是請求到的資料'  
    },200);     
    return result; 
 }  
console.log( getData ()); /* 非同步導致請求不到資料 */ 

// 正確的處理非同步 ： 
function getData (callback){
     // 模擬請求資料     
 

     var result='';     
     setTimeout (function(){         
         result='這是請求到的資料'; 
         callback(result);     
     },200); 
} 
getData (function( data ){ 
    console.log(data); 
}); 

Nodejs events 模組處理非同步

Node.js 有多個內建的事件，我們可以通過引入 events 模組，並通過例項化 EventEmitter 類來繫結和監聽事件。

/*

 Node.js 事件迴圈:

 Node.js 是單程序單執行緒應用程式，但是通過事件和回撥支援併發，所以效能非常高。
 Node.js 的每一個 API 都是非同步的，並作為一個獨立執行緒執行，使用非同步函式呼叫，並處理併發。

 Node.js 有多個內建的事件，我們可以通過引入 events 模組，並通過例項化 EventEmitter 類來繫結和監聽事件，

 如下例項：

* */
 

// 引入 events 模組

var events=require('events');

//console.log(events);

var EventEmitter=new events.EventEmitter();

//廣播 和接收廣播

EventEmitter.on('to_mime',function(data){

    console.log(data);

})

//監聽to_parent的廣播
EventEmitter.on('to_parent',function(data){
    //console.log('接收到了這個廣播事件');

    console.log(data);

    EventEmitter.emit('to_mime','給mime傳送的資料')

})

setTimeout(function(){
    console.log('開始廣播...');
    //廣播to_parent事件
    EventEmitter.emit('to_parent','傳送的資料')

},1000);

我的上一篇博文：http://blog.csdn.net/cckevincyh/article/details/78637576
中讀取mime.json檔案，返回指定mime type,我們使用的是回撥來處理非同步。現在我們改造一下，通過events 模組來處理非同步。
我們現在測試下我們的程式碼：

var fs=require('fs');
var events=require('events');

var EventEmitter=new events.EventEmitter();


function getMime(){

    fs.readFile('mime.json',function(err,data){
        EventEmitter.emit('data',data)
    })

}

getMime();/*執行方法*/
//監聽廣播資料
EventEmitter.on('data',function(mime){

    console.log(mime.toString());
})

好了，通過events 模組我們可以獲取到我們的資料了，現在我們開始改造我們的程式碼：

exports.getMime=function(fs,EventEmitter,extname){  /*獲取字尾名的方法*/

    fs.readFile('./mime.json',function(err,data){

        if(err){
            console.log('mime.json檔案不存在');
            return false;
        }
        //console.log(data.toString());

        var Mimes=JSON.parse(data.toString());

        var result= Mimes[extname] || 'text/html';

        EventEmitter.emit('to_mime',result);

    })


}

//引入http模組
var http=require('http');

//fs模組

var fs=require('fs');

//path模組
var path=require('path');  /*nodejs自帶的模組*/

//url模組

var url=require('url');


var events=require('events');

var EventEmitter=new events.EventEmitter();

var mimeModel=require('./model/getmimefromfile_events.js');
//引入副檔名的方法是在檔案裡面獲取到的。
//console.log(mimeModel.getMime('.css'));   //獲取檔案型別

http.createServer(function(req,res){



    //http://localhost:8001/news.html    /news.html
    //http://localhost:8001/index.html    /index.html

    //css/dmb.bottom.css

    //xxx.json?214214124

    var pathname=url.parse(req.url).pathname;

    console.log(pathname);

    if(pathname=='/'){
        pathname='/index.html'; /*預設載入的首頁*/
    }

    //獲取檔案的字尾名
    var extname=path.extname(pathname);

    if(pathname!='/favicon.ico'){  /*過濾請求favicon.ico*/
        //console.log(pathname);
        //檔案操作獲取 static下面的index.html

        fs.readFile('static/'+pathname,function(err,data){

            if(err){  /*沒有這個檔案*/

                console.log('404');

                fs.readFile('static/404.html',function(error,data404){
                    if(error){
                        console.log(error);
                    }
                    res.writeHead(404,{"Content-Type":"text/html;charset='utf-8'"});
                    res.write(data404);
                    res.end(); /*結束響應*/
                })

            }else{ /*返回這個檔案*/

                mimeModel.getMime(fs,EventEmitter,extname);  /*呼叫獲取資料的方法*/

                EventEmitter.on('to_mime',function(mime){

                    res.writeHead(200,{"Content-Type":""+mime+";charset='utf-8'"});
                    //res.write(data);
                    res.end(data); /*結束響應*/
                })


            }
        })

    }

}).listen(8002);

setMaxListeners():
在預設情況下，同一個指定的事件，最多可以繫結10個事件處理函式。當繫結數超出時，啟動nodejs時，會有相應的錯誤提示。也可以通過下面的方法修改:

EventEmitter.setMaxListeners (n)   
//給EventEmitter設定最大監聽
//引數1： n 數字型別，最大監聽數