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