Pratique de programmation asynchrone de when.js sous node.js_node.js

Supposons un scénario commercial :

Récupérez le rss via l'adresse rss et enregistrez-le dans le fichier, et l'adresse rss est enregistrée dans le fichier.

Pour terminer les affaires de ce scénario, vous devez effectuer 3 tâches :

1. Lisez l'adresse rss du fichier.

2. Recevez des flux RSS.

3. Enregistrer dans un fichier.

Intégrez enfin ces trois tâches.

Préparation :

Le fichier qui stocke l'adresse rss, adresse.txt.

http://programmer.csdn.net/rss_programmer.html

Tâche 1 :

Lisez le contenu du fichier d'adresse rss et renvoyez-le via rappel.

Copier le code Le code est le suivant :

var getRssAddress = function(chemin, rappel) {
fs.readFile(chemin, {encodage : 'utf8'}, fonction (erreur, données) {
​ rappel(erreur, données);
});
>

Mission 2 :

Obtenez du RSS via l'adresse RSS et renvoyez une erreur ou des données via un rappel.

Copier le code Le code est le suivant :

var getRss = fonction (url, rappel) {
var données = '';
http.get(url, fonction(res) {
res.on('data', function(chrunk) {
données = chrunk ;
});
res.on('end', function() {
​​ rappel(null, données);
});
}).on('erreur', fonction(erreur) {
​ callback(err, null);
});
>

Mission 3 :

Enregistrez le RSS dans le fichier et renvoyez l'erreur via le rappel.

Copier le code Le code est le suivant :

var saveRss = fonction (données, rappel) {
fs.writeFile('rss.txt', data, 'utf8', function(err) {
rappel(erreur);
});
>

Intégration :

Copier le code Le code est le suivant :

getRssAddress('address.txt', function(err, data) {
si (erreur) {
console.log(err);
Retour ;
>
getRss (données, fonction (erreur, données) {
Si (erreur) {
console.log(err);
Retour ;
>
SaveRss(données, fonction(err) {
Si(err) console.log(err);
});
});
});

Le code ci-dessus est un traitement entièrement asynchrone, utilisant le rappel le plus courant pour gérer le retour de la logique asynchrone. L'avantage est qu'il s'agit d'une méthode d'écriture standard que tout le monde peut facilement accepter ; la gestion des exceptions est difficile et le code n'est pas intuitif, en particulier lorsqu'il s'agit d'une logique métier complexe et de plusieurs tâches de traitement, des couches de rappels peuvent éblouir les yeux, rendant le code difficile à maintenir.

when.js, l'une des implémentations de la spécification Promise/A, vise ce domaine problématique.

Jetons un coup d'œil au code transformé.

Mission 1 :

Copier le code Le code est le suivant :

var getRssAddress = fonction (chemin) {
var différé = when.defer();
fs.readFile(chemin, {encodage : 'utf8'}, fonction (erreur, données) {
Si (err) différé.reject(err);
        deferred.resolve(data);
});

retour différé.promise ;
>

Mission 2 :

Copier le code Le code est le suivant :

var getRss = fonction (url) {
  var différé = when.defer();
    var données = '';
    http.get(url, fonction(res) {
      res.on('data', function(chrunk) {
        données = chrunk ;
      });
      res.on('end', function() {
        différé.resolve(data);
      });
    }).on('erreur', fonction(erreur) {
      différé.reject(err);
    });

    retour différé.promise ;
>

任务3：

复制代码 代码如下 :

var saveRss = fonction (données) {
  var différé = when.defer();
  fs.writeFile('rss.txt', data, 'utf8', function(err) {
    if(err) différé.reject(err);
    différé.resolve();
  });

 retour différé.promise ;
>

 

整合：

复制代码 代码如下 :

getRssAddress('adresse.txt')
  .then(getRss)
  .then(saveRss)
  .catch(fonction(erreur) {
    console.log(err);
  });

解释：

promise/A规范定义的"Différé/Promesse"模型就是"发布/订阅者"模型，通过Différé对象发布事件，可以是完成resolve事件，或者是失败reject事件；通过Promise对象进行对应完成或失败的订阅。

在Promises/A规范中，每个任务都有三种状态：默认(en attente),完成(réalisé)、失败(rejeté)。

1.

2.

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

4.行过程中。

按照上面的代码。

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

var différé = when.defer();

异步数据获取成功后，发布一个完成事件。

deferred.resolve(data);

异步数据获取失败后，发布一个失败事件。

deferred.reject(err);

并且返回Promise对象作为订阅使用。

retour différé.promise;

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

getRssAddress('adresse.txt')

  .then(getRss)

then有三个参数，分别是onFulfilled、onRejected、onProgress

promise.then(onFulfilled, onRejected, onProgress)

上一个任务被resolve(data),onFulfilled函数就会被触发，data作为它的参数.

上一个任务被reject(reason),那么onRejected就会被触发，收到reason。

任何时候，onFulfilled et onRejected都只有其一可以被触发，并且只触发一次。

对于处理异常，when.js也提供了极其方便的方法，then能传递错误，多个任务串行执行时，我们可以只在最后一个then定义onRejected。也可以在最后一个then的后面调用catch函数捕获任何一个任务的异常。

如此写法简单明了。

复制代码 代码如下 :

getRssAddress('adresse.txt')

  .then(getRss)
  .then(saveRss)
  .catch(fonction(erreur) {
    console.log(err);
  });

Promesse运，以上代码仅仅是基本使用，when.js提供的功能远远不止本文提到的这些，具体参照官方API。