node.js下when.js 的異步編程實踐
假設(shè)一個業(yè)務(wù)場景：
通過rss地址，獲取rss并保存于文件，rss地址保存于文件中。
完成該場景的業(yè)務(wù)需要完成3個任務(wù)：
1.從文件中讀取rss地址。
2.獲取rss。
3.保存于文件。
最后將這三個任務(wù)進(jìn)行整合。
準(zhǔn)備：
存放rss地址的文件，address.txt。
http://programmer.csdn.net/rss_programmer.html
任務(wù)1：
讀取rss地址文件的內(nèi)容并通過callback返回。
var getRssAddress = function(path, callback) {
fs.readFile(path, {encoding: 'utf8'}, function (err, data) {
callback(err, data);
});
}
任務(wù)2：
通過rss地址get到rss，并通過callback返回錯誤或數(shù)據(jù)。
var getRss = function(url, callback) {
var data = '';
http.get(url, function(res) {
res.on('data', function(chrunk) {
data += chrunk;
});
res.on('end', function() {
callback(null, data);
});
}).on('error', function(err) {
callback(err, null);
});
}
任務(wù)3：
將rss保存于文件并通過callback返回錯誤。
var saveRss = function(data, callback) {
fs.writeFile('rss.txt', data, 'utf8', function(err) {
callback(err);
});
}
整合：
getRssAddress('address.txt', function(err, data) {
if(err) {
console.log(err);
return;
}
getRss(data, function(err, data) {
if(err) {
console.log(err);
return;
}
saveRss(data, function(err) {
if(err) console.log(err);
});
});
});
上面的代碼是全異步處理，使用最常見的callback處理異步邏輯的返回，好處是標(biāo)準(zhǔn)寫法，大家都能容易接受；壞處是耦合性太強(qiáng)，處理異常麻煩，代碼不直觀，特別是處理業(yè)務(wù)邏輯復(fù)雜和處理任務(wù)多的場景，層層的callback會讓人眼冒金星，代碼難以維護(hù)。
Promise/A規(guī)范的實現(xiàn)之一when.js正是針對這樣的問題域。
讓我們來看一下改造后的代碼。
任務(wù)1：
var getRssAddress = function(path) {
var deferred = when.defer();
fs.readFile(path, {encoding: 'utf8'}, function (err, data) {
if (err) deferred.reject(err);
deferred.resolve(data);
});
return deferred.promise;
}
任務(wù)2：
var getRss = function(url) {
var deferred = when.defer();
var data = '';
http.get(url, function(res) {
res.on('data', function(chrunk) {
data += chrunk;
});
res.on('end', function() {
deferred.resolve(data);
});
}).on('error', function(err) {
deferred.reject(err);
});
return deferred.promise;
}
任務(wù)3：
var saveRss = function(data) {
var deferred = when.defer();
fs.writeFile('rss.txt', data, 'utf8', function(err) {
if(err) deferred.reject(err);
deferred.resolve();
});
return deferred.promise;
}
整合：
getRssAddress('address.txt')
.then(getRss)
.then(saveRss)
.catch(function(err) {
console.log(err);
});
解釋：
promise/A規(guī)范定義的“Deferred/Promise”模型就是“發(fā)布/訂閱者”模型，通過Deferred對象發(fā)布事件，可以是完成resolve事件，或者是失敗reject事件；通過Promise對象進(jìn)行對應(yīng)完成或失敗的訂閱。
在Promises/A規(guī)范中，每個任務(wù)都有三種狀態(tài)：默認(rèn)(pending)、完成(fulfilled)、失敗(rejected)。
1.默認(rèn)狀態(tài)可以單向轉(zhuǎn)移到完成狀態(tài)，這個過程叫resolve，對應(yīng)的方法是deferred.resolve(promiseOrValue)；
2.默認(rèn)狀態(tài)還可以單向轉(zhuǎn)移到失敗狀態(tài)，這個過程叫reject，對應(yīng)的方法是deferred.reject(reason)；
3.默認(rèn)狀態(tài)時，還可以通過deferred.notify(update)來宣告任務(wù)執(zhí)行信息，如執(zhí)行進(jìn)度；
4.狀態(tài)的轉(zhuǎn)移是一次性的，一旦任務(wù)由初始的pending轉(zhuǎn)為其他狀態(tài)，就會進(jìn)入到下一個任務(wù)的執(zhí)行過程中。
按照上面的代碼。
通過when.defer定義一個deferred對象。
var deferred = when.defer();
異步數(shù)據(jù)獲取成功后，發(fā)布一個完成事件。
deferred.resolve(data);
異步數(shù)據(jù)獲取失敗后，發(fā)布一個失敗事件。
deferred.reject(err);
并且返回Promise對象作為訂閱使用。
return deferred.promise;
訂閱是通過Promise對象的then方法進(jìn)行完成/失敗/通知的訂閱。
getRssAddress('address.txt')
.then(getRss)
then有三個參數(shù)，分別是onFulfilled、onRejected、onProgress
promise.then(onFulfilled, onRejected, onProgress)
上一個任務(wù)被resolve(data)，onFulfilled函數(shù)就會被觸發(fā)，data作為它的參數(shù).
上一個任務(wù)被reject(reason)，那么onRejected就會被觸發(fā)，收到reason。
任何時候，onFulfilled和onRejected都只有其一可以被觸發(fā)，并且只觸發(fā)一次。
對于處理異常，when.js也提供了極其方便的方法，then能傳遞錯誤，多個任務(wù)串行執(zhí)行時，我們可以只在最后一個then定義onRejected。也可以在最后一個then的后面調(diào)用catch函數(shù)捕獲任何一個任務(wù)的異常。
如此寫法簡單明了。
getRssAddress('address.txt')
.then(getRss)
.then(saveRss)
.catch(function(err) {
console.log(err);
});
Promise給異步編程帶來了巨大的方便，可以讓我們專注于單個任務(wù)的實現(xiàn)而不會陷入金字塔厄運，以上代碼僅僅是基本使用，when.js提供的功能遠(yuǎn)遠(yuǎn)不止本文提到的這些，具體參照官方API。
相關(guān)文章
Node.js在處理多個請求方面具有優(yōu)勢,它利用事件驅(qū)動和非阻塞式I/O的特性,能夠高效地處理并發(fā)請求,提供快速響應(yīng)和良好的可擴(kuò)展性,這篇文章主要介紹了Node.js如何處理多個請求,需要的朋友可以參考下2023-11-11
這篇文章主要介紹了nodeJS模塊簡單用法,結(jié)合實例形式簡單分析了nodejs模塊定義、引入、注冊、啟動等相關(guān)操作技巧,需要的朋友可以參考下2018-04-04
詳解如何在NodeJS應(yīng)用程序中處理多個API請求
NodeJS默認(rèn)是異步的,這意味著它已經(jīng)能夠同時處理多個請求,但它只適用于I/O操作,如HTTP請求、文件系統(tǒng)操作、數(shù)據(jù)庫查詢、實時聊天應(yīng)用等,在處理CPU密集型任務(wù)時,可能需要很長時間,這就是為什么NodeJS提供了一些我們將在下面介紹的特定包2023-12-12
之前兩篇文章基本上都是給我們介紹的nodejs的理論基礎(chǔ)，今天我們來點干貨，先從NET模塊開始講起吧。2015-01-01
這篇文章主要介紹了詳解如何使用nvm管理Node.js多版本，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2019-05-05
輕松創(chuàng)建nodejs服務(wù)器（5）：事件處理程序
這篇文章主要介紹了輕松創(chuàng)建nodejs服務(wù)器（5）：事件處理程序,本系列文章將一步一步創(chuàng)建一個完整的nodejs服務(wù)器,需要的朋友可以參考下2014-12-12
nodejs使用PassThrough流進(jìn)行數(shù)據(jù)傳遞合并示例詳解
這篇文章主要為大家介紹了nodejs使用PassThrough流進(jìn)行數(shù)據(jù)傳遞合并示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-09-09
這篇文章主要介紹了express中static中間件的具體使用方法，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2019-10-10
本篇文章主要介紹了nodejs接入阿里大魚短信驗證碼的方法，具有一定的參考價值，感興趣的小伙伴們可以參考一下。2017-07-07
這篇文章主要介紹了Nodejs調(diào)用Dll模塊的方法,在文中給大家提到了nodejs通過ffi調(diào)用dll模塊的代碼，本文給大家介紹的非常詳細(xì)，具有一定的參考借鑒價值，需要的朋友可以參考下2018-09-09