Node.js 异步编程之 Callback介绍(一)

2020-06-17 05:54:34易采站长站整理

  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 服务:


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 数据来获取 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)
  })
}

现在我们已经获取 geo、获取 weather 的接口,接下来我们还有稍微复杂的问题要处理,因为 ip 有多个,所以我们需要并行地去读取 geo 已经并行地读取 weather 数据:


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