node.js下when.js 的异步编程实践
假设一个业务场景：
通过rss地址，获取rss并保存于文件，rss地址保存于文件中。
完成该场景的业务需要完成3个任务：
1.从文件中读取rss地址。
2.获取rss。
3.保存于文件。
最后将这三个任务进行整合。
准备：
存放rss地址的文件，address.txt。
http://programmer.csdn.net/rss_programmer.html
任务1：
读取rss地址文件的内容并通过callback返回。
var getRssAddress = function(path, callback) {
fs.readFile(path, {encoding: 'utf8'}, function (err, data) {
callback(err, data);
});
}
任务2：
通过rss地址get到rss，并通过callback返回错误或数据。
var getRss = function(url, callback) {
var data = '';
http.get(url, function(res) {
res.on('data', function(chrunk) {
data += chrunk;
});
res.on('end', function() {
callback(null, data);
});
}).on('error', function(err) {
callback(err, null);
});
}
任务3：
将rss保存于文件并通过callback返回错误。
var saveRss = function(data, callback) {
fs.writeFile('rss.txt', data, 'utf8', function(err) {
callback(err);
});
}
整合：
getRssAddress('address.txt', function(err, data) {
if(err) {
console.log(err);
return;
}
getRss(data, function(err, data) {
if(err) {
console.log(err);
return;
}
saveRss(data, function(err) {
if(err) console.log(err);
});
});
});
上面的代码是全异步处理，使用最常见的callback处理异步逻辑的返回，好处是标准写法，大家都能容易接受；坏处是耦合性太强，处理异常麻烦，代码不直观，特别是处理业务逻辑复杂和处理任务多的场景，层层的callback会让人眼冒金星，代码难以维护。
Promise/A规范的实现之一when.js正是针对这样的问题域。
让我们来看一下改造后的代码。
任务1：
var getRssAddress = function(path) {
var deferred = when.defer();
fs.readFile(path, {encoding: 'utf8'}, function (err, data) {
if (err) deferred.reject(err);
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
promise.then(onFulfilled, onRejected, onProgress)
上一个任务被resolve(data)，onFulfilled函数就会被触发，data作为它的参数.
上一个任务被reject(reason)，那么onRejected就会被触发，收到reason。
任何时候，onFulfilled和onRejected都只有其一可以被触发，并且只触发一次。
对于处理异常，when.js也提供了极其方便的方法，then能传递错误，多个任务串行执行时，我们可以只在最后一个then定义onRejected。也可以在最后一个then的后面调用catch函数捕获任何一个任务的异常。
如此写法简单明了。
getRssAddress('address.txt')
.then(getRss)
.then(saveRss)
.catch(function(err) {
console.log(err);
});
Promise给异步编程带来了巨大的方便，可以让我们专注于单个任务的实现而不会陷入金字塔厄运，以上代码仅仅是基本使用，when.js提供的功能远远不止本文提到的这些，具体参照官方API。
相关文章
Node.js在处理多个请求方面具有优势,它利用事件驱动和非阻塞式I/O的特性,能够高效地处理并发请求,提供快速响应和良好的可扩展性,这篇文章主要介绍了Node.js如何处理多个请求,需要的朋友可以参考下2023-11-11
这篇文章主要介绍了nodeJS模块简单用法,结合实例形式简单分析了nodejs模块定义、引入、注册、启动等相关操作技巧,需要的朋友可以参考下2018-04-04
NodeJS默认是异步的,这意味着它已经能够同时处理多个请求,但它只适用于I/O操作,如HTTP请求、文件系统操作、数据库查询、实时聊天应用等,在处理CPU密集型任务时,可能需要很长时间,这就是为什么NodeJS提供了一些我们将在下面介绍的特定包2023-12-12
之前两篇文章基本上都是给我们介绍的nodejs的理论基础，今天我们来点干货，先从NET模块开始讲起吧。2015-01-01
这篇文章主要介绍了详解如何使用nvm管理Node.js多版本，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2019-05-05
这篇文章主要介绍了轻松创建nodejs服务器（5）：事件处理程序,本系列文章将一步一步创建一个完整的nodejs服务器,需要的朋友可以参考下2014-12-12
nodejs使用PassThrough流进行数据传递合并示例详解
这篇文章主要为大家介绍了nodejs使用PassThrough流进行数据传递合并示例详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪2023-09-09
这篇文章主要介绍了express中static中间件的具体使用方法，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2019-10-10
本篇文章主要介绍了nodejs接入阿里大鱼短信验证码的方法，具有一定的参考价值，感兴趣的小伙伴们可以参考一下。2017-07-07
这篇文章主要介绍了Nodejs调用Dll模块的方法,在文中给大家提到了nodejs通过ffi调用dll模块的代码，本文给大家介绍的非常详细，具有一定的参考借鉴价值，需要的朋友可以参考下2018-09-09
最新评论