首頁 > web前端 > js教程 > 深入理解Node.js 事件循環和回調函數

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

高洛峰
發布: 2016-12-08 10:26:53
原創
1562 人瀏覽過

本文詳細的介紹了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🎜🎜🎜🎜
相關標籤:
來源:php.cn
本網站聲明
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn
最新問題
熱門教學
更多>
最新下載
更多>
網站特效
網站源碼
網站素材
前端模板