node.js下when.js 的异步编程实践

2020-06-17 06:53:17易采站长站整理

        deferred.resolve(data);
      });

    return deferred.promise;
}
 
任务2:


var getRss = function(url) {
  var deferred = when.defer();
    var data = ”;
    http.get(url, function(res) {
      res.on(‘data’, function(chrunk) {
        data += chrunk;
      });
      res.on(‘end’, function() {
        deferred.resolve(data);
      });
    }).on(‘error’, function(err) {
      deferred.reject(err);
    });

    return deferred.promise;
}

任务3:


var saveRss = function(data) {
  var deferred = when.defer();
  fs.writeFile(‘rss.txt’, data, ‘utf8’, function(err) {
    if(err) deferred.reject(err);
    deferred.resolve();
  });

  return deferred.promise;
}
 

整合:


getRssAddress(‘address.txt’)
  .then(getRss)
  .then(saveRss)
  .catch(function(err) {
    console.log(err);
  });

解释:

promise/A规范定义的“Deferred/Promise”模型就是“发布/订阅者”模型,通过Deferred对象发布事件,可以是完成resolve事件,或者是失败reject事件;通过Promise对象进行对应完成或失败的订阅。

在Promises/A规范中,每个任务都有三种状态:默认(pending)、完成(fulfilled)、失败(rejected)。

1.默认状态可以单向转移到完成状态,这个过程叫resolve,对应的方法是deferred.resolve(promiseOrValue);

2.默认状态还可以单向转移到失败状态,这个过程叫reject,对应的方法是deferred.reject(reason);

3.默认状态时,还可以通过deferred.notify(update)来宣告任务执行信息,如执行进度;

4.状态的转移是一次性的,一旦任务由初始的pending转为其他状态,就会进入到下一个任务的执行过程中。

按照上面的代码。

通过when.defer定义一个deferred对象。

var deferred = when.defer();
异步数据获取成功后,发布一个完成事件。

deferred.resolve(data);
异步数据获取失败后,发布一个失败事件。

deferred.reject(err);
并且返回Promise对象作为订阅使用。

return deferred.promise;
订阅是通过Promise对象的then方法进行完成/失败/通知的订阅。

getRssAddress(‘address.txt’)
  .then(getRss)
then有三个参数,分别是onFulfilled、onRejected、onProgress