這篇文章主要介紹了Node.js 異步編程之 Callback介紹(一),本文用實例講解Callback的相關知識,本文是第一篇,下一篇小編會跟進,需要的朋友可以參考下
Node.js 基於 JavaScript 引擎 v8,是單線程的。Node.js 采用了與通常 Web 上的 JavaScript 異步編程的方式來處理會造成阻塞的I/O操作。在 Node.js 中讀取文件、訪問數據庫、網絡請求等等都有可能是異步的。對於 Node.js 新人或者從其他語言背景遷移到 Node.js 上的開發者來說,異步編程是比較痛苦的一部分。本章將由淺入深為大家講解 Node.js 異步編程的方方面面。從最基礎的 callback 到 thunk、Promise、co 直到 ES7 計劃的 async/await。
首先我們先從一個具體的異步編程的例子說起。
獲取多個 ip 所在地的天氣信息
在 ip.json 這個文件中,有一個數組我們存放了若干個 ip 地址,分別來自不同的地方的不同訪問者,內容如下:
代碼如下:
整理思路,我們分成以下幾步來完成:
1.讀取 ip 地址;
2.根據 ip 地址獲取 ip 所在地的地理位置;
3.根據地理位置查詢當地的天氣;
4.將結果寫入到 weather.json 文件中。
這些步驟都是異步的(讀寫文件可以同步,但作為示例,都用異步)。
callback
首先我們嘗試不借助任何庫,試著以 Node.js API 通常提供的方式——專遞一個 callback 作為異步回調——來實現。我們將借助三個基礎模塊:
1.fs:從文件 ip.json 讀取 IP 列表;把結果寫入到文件中;
2.request:用來發送 HTTP 請求,根據 IP 地址獲取 geo 數據,再通過 geo 數據獲取天氣數據;
3.querystring:用來組裝發送請求的 url 參數。
新建一個 callback.js 文件,引入這幾個模塊:
代碼如下:
讀取文件中的 IP 列表,調用 fs.readFile 讀取文件內容,再通過 JSON.parse 來解析 JSON 數據:
代碼如下:
接著就是使用 IP 來獲取geo,我們使用 request 來請求一個開放的 geo 服務:
代碼如下:
使用 geo 數據來獲取 weather:
代碼如下:
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 來計算等待返回的個數,remain 為 0 表示並行請求結束,將處理結果裝進一個數組返回。
最後就是將結果寫入到 weather.json 文件中:
代碼如下:
組合上面這些函數,我們就可以實現我們的目標:
代碼如下:
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 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 的全部內容。運行:
代碼如下: