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,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',ips) { if (err) { handlerError(err) } else { ips2geos(ips,geos) { if (err) { handlerError(err) } else { geos2weathers(geos,weathers) { if (err) { handlerError(err) } else { writeWeather(weathers,function(err) { if (err) { handlerError(err) } else { console.log('success!') } }) } }) } }) } })
哈哈,你妈这嵌套,你可能觉得这就是 JavaScript 异步的问题,说真的,嵌套不是 JavaScript 异步的真正问题所在。上面这段代码我们可以下面这样写:
function ips2geosCallback(err,geos2weathersCallback) } }
function geos2weathersCallback(err,writeWeatherCallback) } }
function writeWeatherCallback(err) { if (err) { handlerError(err) } else { console.log('success!') } }
readIP('./ip.json',ReadIPCallback)
好了,这是我们 callback.js 的全部内容。运行: