node.js下when.js 的異步編程實(shí)踐
假設(shè)一個(gè)業(yè)務(wù)場(chǎng)景：
通過rss地址，獲取rss并保存于文件，rss地址保存于文件中。
完成該場(chǎng)景的業(yè)務(wù)需要完成3個(gè)任務(wù)：
1.從文件中讀取rss地址。
2.獲取rss。
3.保存于文件。
最后將這三個(gè)任務(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返回錯(cuò)誤或數(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返回錯(cuò)誤。
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ù)多的場(chǎng)景，層層的callback會(huì)讓人眼冒金星，代碼難以維護(hù)。
Promise/A規(guī)范的實(shí)現(xiàn)之一when.js正是針對(duì)這樣的問題域。
讓我們來看一下改造后的代碼。
任務(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對(duì)象發(fā)布事件，可以是完成resolve事件，或者是失敗reject事件；通過Promise對(duì)象進(jìn)行對(duì)應(yīng)完成或失敗的訂閱。
在Promises/A規(guī)范中，每個(gè)任務(wù)都有三種狀態(tài)：默認(rèn)(pending)、完成(fulfilled)、失敗(rejected)。
1.默認(rèn)狀態(tài)可以單向轉(zhuǎn)移到完成狀態(tài)，這個(gè)過程叫resolve，對(duì)應(yīng)的方法是deferred.resolve(promiseOrValue)；
2.默認(rèn)狀態(tài)還可以單向轉(zhuǎn)移到失敗狀態(tài)，這個(gè)過程叫reject，對(duì)應(yīng)的方法是deferred.reject(reason)；
3.默認(rèn)狀態(tài)時(shí)，還可以通過deferred.notify(update)來宣告任務(wù)執(zhí)行信息，如執(zhí)行進(jìn)度；
4.狀態(tài)的轉(zhuǎn)移是一次性的，一旦任務(wù)由初始的pending轉(zhuǎn)為其他狀態(tài)，就會(huì)進(jìn)入到下一個(gè)任務(wù)的執(zhí)行過程中。
按照上面的代碼。
通過when.defer定義一個(gè)deferred對(duì)象。
var deferred = when.defer();
異步數(shù)據(jù)獲取成功后，發(fā)布一個(gè)完成事件。
deferred.resolve(data);
異步數(shù)據(jù)獲取失敗后，發(fā)布一個(gè)失敗事件。
deferred.reject(err);
并且返回Promise對(duì)象作為訂閱使用。
return deferred.promise;
訂閱是通過Promise對(duì)象的then方法進(jìn)行完成/失敗/通知的訂閱。
getRssAddress('address.txt')
.then(getRss)
then有三個(gè)參數(shù)，分別是onFulfilled、onRejected、onProgress
promise.then(onFulfilled, onRejected, onProgress)
上一個(gè)任務(wù)被resolve(data)，onFulfilled函數(shù)就會(huì)被觸發(fā)，data作為它的參數(shù).
上一個(gè)任務(wù)被reject(reason)，那么onRejected就會(huì)被觸發(fā)，收到reason。
任何時(shí)候，onFulfilled和onRejected都只有其一可以被觸發(fā)，并且只觸發(fā)一次。
對(duì)于處理異常，when.js也提供了極其方便的方法，then能傳遞錯(cuò)誤，多個(gè)任務(wù)串行執(zhí)行時(shí)，我們可以只在最后一個(gè)then定義onRejected。也可以在最后一個(gè)then的后面調(diào)用catch函數(shù)捕獲任何一個(gè)任務(wù)的異常。
如此寫法簡(jiǎn)單明了。
getRssAddress('address.txt')
.then(getRss)
.then(saveRss)
.catch(function(err) {
console.log(err);
});
Promise給異步編程帶來了巨大的方便，可以讓我們專注于單個(gè)任務(wù)的實(shí)現(xiàn)而不會(huì)陷入金字塔厄運(yùn)，以上代碼僅僅是基本使用，when.js提供的功能遠(yuǎn)遠(yuǎn)不止本文提到的這些，具體參照官方API。
相關(guān)文章
socket.io與pm2（cluster）集群搭配的解決方案
這篇文章主要給大家介紹了關(guān)于socket.io與pm2（cluster）集群搭配的解決方案，文中介紹的非常詳細(xì)，對(duì)大家具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面跟著小編一起來看看吧。2017-06-06
pnpm workspace管理monorepo項(xiàng)目使用過程詳解
這篇文章主要為大家介紹了pnpm workspace管理monorepo項(xiàng)目使用過程詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-10-10
nodejs更新package.json中的dependencies依賴到最新版本的方法
今天小編就為大家分享一篇nodejs更新package.json中的dependencies依賴到最新版本的方法，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過來看看吧2018-10-10
淺析Node.js實(shí)現(xiàn)HTTP文件下載
本文介紹如何用Node.js來實(shí)現(xiàn)HTTP文件下載，文章以實(shí)例演示所以很詳細(xì)，有需要的小伙伴們可以參考學(xué)習(xí)。2016-08-08
這篇文章主要介紹了npx的使用及原理,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2024-02-02
在全局安裝pnpm后,如果出現(xiàn)無法使用的問題,一般是由于沒有添加系統(tǒng)變量導(dǎo)致的,本文就來介紹一下node.js解決全局安裝pnpm后無法使用的問題,感興趣的可以了解一下2024-10-10
node.js使用redis儲(chǔ)存session的方法
這篇文章主要介紹了node.js使用redis儲(chǔ)存session的方法,本文給大家介紹的非常詳細(xì)，具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2018-09-09
Node.js腳本提取OPML文件信息實(shí)現(xiàn)示例詳解
這篇文章主要為大家介紹了Node.js腳本提取OPML文件信息,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-09-09
Node.js實(shí)現(xiàn)在目錄中查找某個(gè)字符串及所在文件
這篇文章主要介紹了Node.js實(shí)現(xiàn)在目錄中查找某個(gè)字符串及所在文件,文中代碼簡(jiǎn)潔,而且速度相當(dāng)?shù)目?需要的朋友可以參考下2014-09-09
從零學(xué)習(xí)node.js之詳解異步控制工具async（八）
sync是一個(gè)流程控制工具包，提供了直接而強(qiáng)大的異步功能?；贘avaScript為Node.js設(shè)計(jì)，同時(shí)也可以直接在瀏覽器中使用。下面這篇文章主要介紹了node.js之異步控制工具async的相關(guān)資料，需要的朋友可以參考下。2017-02-02