Node.js 異步編程之 Callback介紹（一）
Node.js 基于 JavaScript 引擎 v8，是單線程的。Node.js 采用了與通常 Web 上的 JavaScript 異步編程的方式來處理會造成阻塞的I/O操作。在 Node.js 中讀取文件、訪問數(shù)據(jù)庫、網(wǎng)絡(luò)請求等等都有可能是異步的。對于 Node.js 新人或者從其他語言背景遷移到 Node.js 上的開發(fā)者來說，異步編程是比較痛苦的一部分。本章將由淺入深為大家講解 Node.js 異步編程的方方面面。從最基礎(chǔ)的 callback 到 thunk、Promise、co 直到 ES7 計劃的 async/await。
首先我們先從一個具體的異步編程的例子說起。
獲取多個 ip 所在地的天氣信息
在 ip.json 這個文件中，有一個數(shù)組我們存放了若干個 ip 地址，分別來自不同的地方的不同訪問者，內(nèi)容如下：
// ip.json
["115.29.230.208", "180.153.132.38", "74.125.235.224", "91.239.201.98", "60.28.215.115"]
希望可以每一個 ip 所在地當(dāng)前的天氣。將結(jié)果輸出到 weather.json 這個文件中各式如下：
// weather.json
[
{ "ip": "115.29.230.208", "weather": "Clouds", "region": "Zhejiang" },
{ "ip": "180.153.132.38", "weather": "Clear", "region": "Shanghai" },
{ "ip": "74.125.235.224", "weather": "Rain", "region": "California" },
{ "ip": "60.28.215.115", "weather": "Clear", "region": "Tianjin" }
]
整理思路，我們分成以下幾步來完成：
1.讀取 ip 地址；
2.根據(jù) ip 地址獲取 ip 所在地的地理位置；
3.根據(jù)地理位置查詢當(dāng)?shù)氐奶鞖猓?br />
4.將結(jié)果寫入到 weather.json 文件中。
這些步驟都是異步的（讀寫文件可以同步，但作為示例，都用異步）。
callback
首先我們嘗試不借助任何庫，試著以 Node.js API 通常提供的方式——專遞一個 callback 作為異步回調(diào)——來實現(xiàn)。我們將借助三個基礎(chǔ)模塊：
1.fs：從文件 ip.json 讀取 IP 列表；把結(jié)果寫入到文件中；
2.request：用來發(fā)送 HTTP 請求，根據(jù) IP 地址獲取 geo 數(shù)據(jù)，再通過 geo 數(shù)據(jù)獲取天氣數(shù)據(jù)；
3.querystring：用來組裝發(fā)送請求的 url 參數(shù)。
新建一個 callback.js 文件，引入這幾個模塊：
// callback.js
var fs = require('fs')
var request = require('request')
var qs = require('querystring')
讀取文件中的 IP 列表，調(diào)用 fs.readFile 讀取文件內(nèi)容，再通過 JSON.parse 來解析 JSON 數(shù)據(jù)：
...
function readIP(path, callback) {
fs.readFile(path, function(err, data) {
if (err) {
callback(err)
} else {
try {
data = JSON.parse(data)
callback(null, data)
} catch (error) {
callback(error)
}
}
})
}
...
接著就是使用 IP 來獲取geo，我們使用 request 來請求一個開放的 geo 服務(wù)：
...
function ip2geo(ip, callback) {
var url = 'http://www.telize.com/geoip/' + ip
request({
url: url,
json: true
}, function(err, resp, body) {
callback(err, body)
})
}
...
使用 geo 數(shù)據(jù)來獲取 weather：
...
function geo2weather(lat, lon, callback) {
var params = {
lat: lat,
lon: lon,
APPID: '9bf4d2b07c7ddeb780c5b32e636c679d'
}
var url = 'http://api.openweathermap.org/data/2.5/weather?' + qs.stringify(params)
request({
url: url,
json: true,
}, function(err, resp, body) {
callback(err, body)
})
}
...
現(xiàn)在我們已經(jīng)獲取 geo、獲取 weather 的接口，接下來我們還有稍微復(fù)雜的問題要處理，因為 ip 有多個，所以我們需要并行地去讀取 geo 已經(jīng)并行地讀取 weather 數(shù)據(jù)：
...
function ips2geos(ips, callback) {
var geos = []
var ip
var remain = ips.length
for (var i = 0; i < ips.length; i++) {
ip = ips[i];
(function(ip) {
ip2geo(ip, function(err, geo) {
if (err) {
callback(err)
} else {
geo.ip = ip
geos.push(geo)
remain--
}
if (remain == 0) {
callback(null, geos)
}
})
})(ip)
}
}
function geos2weathers(geos, callback) {
var weathers = []
var geo
var remain = geos.length
for (var i = 0; i < geos.length; i++) {
geo = geos[i];
(function(geo) {
geo2weather(geo.latitude, geo.longitude, function(err, weather) {
if (err) {
callback(err)
} else {
weather.geo = geo
weathers.push(weather)
remain--
}
if (remain == 0) {
callback(null, weathers)
}
})
})(geo)
}
}
...
ips2geos 和 geos2weathers 都使用了一種比較原始的方法，remain 來計算等待返回的個數(shù)，remain 為 0 表示并行請求結(jié)束，將處理結(jié)果裝進一個數(shù)組返回。
最后就是將結(jié)果寫入到 weather.json 文件中：
...
function writeWeather(weathers, callback) {
var output = []
var weather
for (var i = 0; i < weathers.length; i++) {
weather = weathers[i]
output.push({
ip: weather.geo.ip,
weather: weather.weather[0].main,
region: weather.geo.region
})
}
fs.writeFile('./weather.json', JSON.stringify(output, null, ' '), callback)
}
...
組合上面這些函數(shù)，我們就可以實現(xiàn)我們的目標(biāo)：
...
function handlerError(err) {
console.log('error: ' + err)
}
readIP('./ip.json', function(err, ips) {
if (err) {
handlerError(err)
} else {
ips2geos(ips, function(err, geos) {
if (err) {
handlerError(err)
} else {
geos2weathers(geos, function(err, weathers) {
if (err) {
handlerError(err)
} else {
writeWeather(weathers, function(err) {
if (err) {
handlerError(err)
} else {
console.log('success!')
}
})
}
})
}
})
}
})
哈哈，你媽這嵌套，你可能覺得這就是 JavaScript 異步的問題，說真的，嵌套不是 JavaScript 異步的真正問題所在。上面這段代碼我們可以下面這樣寫：
...
function ReadIPCallback(err, ips) {
if (err) {
handlerError(err)
} else {
ips2geos(ips, ips2geosCallback)
}
}
function ips2geosCallback(err, geos) {
if (err) {
handlerError(err)
} else {
geos2weathers(geos, geos2weathersCallback)
}
}
function geos2weathersCallback(err, weathers) {
if (err) {
handlerError(err)
} else {
writeWeather(weathers, writeWeatherCallback)
}
}
function writeWeatherCallback(err) {
if (err) {
handlerError(err)
} else {
console.log('success!')
}
}
readIP('./ip.json', ReadIPCallback)
好了，這是我們 callback.js 的全部內(nèi)容。運行：
node callback.js
將會生成 weater.json 文件：
[
{
"ip": "180.153.132.38",
"weather": "Clear",
"region": "Shanghai"
},
{
"ip": "91.239.201.98",
"weather": "Clouds"
},
{
"ip": "60.28.215.115",
"weather": "Clear",
"region": "Tianjin"
},
{
"ip": "74.125.235.224",
"weather": "Clouds",
"region": "California"
},
{
"ip": "115.29.230.208",
"weather": "Clear",
"region": "Zhejiang"
}
]
那正真的問題是什么？
當(dāng)然是異步的問題啦，異步本質(zhì)上要處理三個事情：
1.異步操作什么時候結(jié)束，需要通知回來，Callback 是一種方案；
2.異步產(chǎn)生的結(jié)果需要傳遞回來，Callback 接受一個 data 參數(shù)，把數(shù)據(jù)傳回來；
3.異步如果出錯了怎么辦？Callback 接受 一個 err 參數(shù)，把錯誤傳回來。
但有沒有發(fā)現(xiàn)好多重復(fù)的工作（各種 callback）？上面的這些代碼有什么問題么？請大家期待本文的續(xù)篇。
相關(guān)文章
這篇文章主要介紹了node中使用es6/7/8(支持性與性能)，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2019-03-03
React+react-dropzone+node.js實現(xiàn)圖片上傳的示例代碼
本篇文章主要介紹了React+react-dropzone+node.js實現(xiàn)圖片上傳的示例代碼，非常具有實用價值，需要的朋友可以參考下2017-08-08
Node.js中MongoDB插入數(shù)據(jù)的實現(xiàn)方法
在Node.js中,可以使用MongoDB原生驅(qū)動或Mongoose庫來連接和操作MongoDB數(shù)據(jù)庫,本文就來介紹一下Node.js中MongoDB插入數(shù)據(jù)的實現(xiàn)方法,感興趣的可以了解一下2023-12-12
這篇文章主要介紹了npm 語義版本控制詳解，文中通過示例代碼介紹的非常詳細，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2019-09-09
nodejs?實現(xiàn)簡單的文件上傳功能(示例詳解)
這篇文章主要介紹了nodejs?實現(xiàn)簡單的文件上傳功能,文件上傳方式分為三種，本文通過實例代碼給大家詳細介紹，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值，需要的朋友可以參考下2022-02-02
這篇文章主要為大家分享了如何在你的Linux發(fā)行版上安裝Node.js？感興趣的小伙伴們可以參考一下2016-04-04
這篇文章主要介紹了nodeJs編寫錯誤處理中間件問題，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-12-12
delegates?庫為?JavaScript?社區(qū)提供了一種高效的方式來聲明對象之間的委托關(guān)系,讓代碼結(jié)構(gòu)更加清晰,減少不必要的重復(fù),并提高可維護性,本文將詳細介紹如何在?Node.js?項目中使用?delegates?庫進行高級委托,需要的朋友可以參考下2024-01-01
這篇文章主要介紹了Node.js中進程管理的相關(guān)資料，文中通過示例代碼介紹的非常詳細，相信對大家的學(xué)習(xí)或者工作具有一定的參考價值，需要的朋友們下面來一起看看吧。2017-03-03
部分老舊項目需要使用低版本的node,網(wǎng)上很多是無效的,高版本無法直接安裝低版本node,但是低版本nodejs可以安裝部分高版本node,從而達到升級效果,下面這篇文章主要給大家介紹了關(guān)于nodejs高版本降為低版本的詳細解決方案,需要的朋友可以參考下2022-12-12