Amalan pengaturcaraan tak segerak when.js di bawah node.js_node.js

Anggap senario perniagaan:

Dapatkan rss melalui alamat rss dan simpan dalam fail, dan alamat rss disimpan dalam fail.

Untuk menyelesaikan perniagaan senario ini, anda perlu menyelesaikan 3 tugasan:

1. Baca alamat rss daripada fail.

2. Dapatkan rss.

3.

Akhir sekali integrasikan ketiga-tiga tugasan ini.

Penyediaan:

Fail yang menyimpan alamat rss, address.txt.

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

Tugasan 1:

Baca kandungan fail alamat rss dan kembalikannya melalui panggilan balik.

Salin kod Kod adalah seperti berikut:

var getRssAddress = fungsi(laluan, panggil balik) {
fs.readFile(path, {encoding: 'utf8'}, function (err, data) {
panggil balik(err, data);
});
}

Misi 2:

Dapatkan rss melalui alamat rss dan kembalikan ralat atau data melalui panggilan balik.

Salin kod Kod adalah seperti berikut:

var getRss = function(url, panggil balik) {
var data = '';
http.get(url, function(res) {
res.on('data', function(crunk) {
data = chrunk;
});
res.on('end', function() {
panggilan balik(null, data);
});
}).on('error', function(err) {
​ panggil balik(err, null);
});
}

Misi 3:

Simpan RSS dalam fail dan kembalikan ralat melalui panggilan balik.

Salin kod Kod adalah seperti berikut:

var saveRss = fungsi(data, panggil balik) {
fs.writeFile('rss.txt', data, 'utf8', function(err) {
​ panggil balik(err);
});
}

Integrasi:

Salin kod Kod adalah seperti berikut:

getRssAddress('address.txt', fungsi(err, data) {
jika(err) {
console.log(err);
Kembali;
}
getRss(data, fungsi(err, data) {
Jika(err) {
console.log(err);
Kembali;
}
SaveRss(data, fungsi(err) {
If(err) console.log(err);
});
});
});

Kod di atas adalah pemprosesan tak segerak sepenuhnya, menggunakan panggilan balik yang paling biasa untuk mengendalikan pengembalian logik tak segerak Kelebihannya ialah kaedah penulisan standard yang boleh diterima dengan mudah oleh semua orang; pengendalian pengecualian adalah menyusahkan, dan kod itu tidak intuitif, terutamanya Apabila berurusan dengan logik perniagaan yang kompleks dan pelbagai tugas pemprosesan, lapisan panggilan balik boleh membuatkan mata orang terpesona, menjadikan kod sukar untuk dikekalkan.

when.js, salah satu pelaksanaan spesifikasi Promise/A, ditujukan kepada domain masalah ini.

Mari kita lihat kod yang diubah.

Misi 1:

Salin kod Kod adalah seperti berikut:

var getRssAddress = fungsi(laluan) {
var tertunda = when.defer();
fs.readFile(path, {encoding: 'utf8'}, function (err, data) {
Jika (err) ditangguhkan.reject(err);
        deferred.resolve(data);
});

pulangan tertunda.janji;
}

Misi 2:

Salin kod Kod adalah seperti berikut:

var getRss = function(url) {
  var tertunda = when.defer();
    var data = '';
    http.get(url, function(res) {
      res.on('data', function(crunk) {
        data = chrunk;
      });
      res.on('end', function() {
        deferred.resolve(data);
      });
    }).on('error', function(err) {
      deferred.reject(err);
    });

    pemulangan tertunda.janji;
}

任务3：

复制代码 代码如下:

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

  pemulangan tertunda.janji;
}

 

整合：

复制代码 代码如下:

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

解释：

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

在Promises/A规范中，每个任务都有三种状态：默认(pending)、完成(ditepati)、失败(ditolak)>。2.默认状态还可以单向转移到失败状态，这个过程叫menolak，对应的方法是(ditangguh).

3.默认状态时，还可以通过ditunda.notify(kemas kini)来宣告任务执行信息，如执行进度；>4.状态的转移是一次性的，一旦任务由初始的pending转为其他状态，就会进入到个个下们中。

按照上面的代码。

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

var tertunda = when.defer();

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

tertunda.menyelesaikan(data);

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

tertunda.tolak(err);

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

pulangan tertunda.janji;

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

getRssAddress('address.txt')

  .then(getRss)

kemudian有三个参数，分别是diDipenuhi、padaDitolak、sedang berlangsung

janji.kemudian(padaDitepati, padaDitolak, onProgress)

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

上一个任务被menolak(sebab)，那么ditolak就会被触发，收到alasan。

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

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

如此写法简单明了。

复制代码

代码如下: getRssAddress('address.txt')   .then(getRss)   .then(saveRss)

  .catch(function(err) {

    console.log(err);
  });



Janji给异步编程带来了巨大的方便，可以让我们专注于单个任务的实现而金实现而间以上代码仅仅是基本使用，when.js提供的功能远远不止本文提到的的这些，具体参照官方API。