Promise 模式的Q库
Promise是一种让异步代码书写起来更舒服、更可控、优雅的模式,能够让异步操作代码像同步代码那样书写并且阅读。
Q库可运行中node.js环境下,它是Promise模式的实现,下面我们来介绍它。
通过 npm i q 安装Q库。
下面是采用回调的方式编写:
var fs = require("fs");
fs.readdir(".",function(err,rs){
fs.readFile(rs[0],function(err,f1){
console.log(f1);
fs.readFile(rs[1],function(err,f2){
console.log(f2);
fs.readFile(rs[2],function(err,f3){
console.log(f3);
})
})
})
})这段代码的意思是,查看当前目录下有多少文件,然后逐个读取,把读取的数据打印到终端,可笑的是,你还必须要知道到底有几个文件,如果我知道有3个,就调用三次 readFile异步函数,如果1000个,那就要......
那么,采用Q库如何改善呢?
// 导入q库
var Q = require("q"),fs = require("fs");
Q.nfcall(fs.readdir, ".").then(function(ns){
var promises = [];
ns.forEach(function(filename){
promises.push(Q.nfcall(fs.readFile, filename,"utf8"));
})
Q.all(promises).then(function(results){
console.log(results);
})
})通过Q.nfcall 方法调用异步函数,返回一个 promise对象,promise对象具有一个方法then ,可以得到运行结果。
这里的 var promises = []; 变量用于储存promise数组,把这个参数加入Q.all方法里,会得到一个promise对象,调用then方法会得到一个数组,这个数组就是所有 promises的运行结果。
一切都围绕promise对象,它有一个then方法用于返回回调函数结果,还有一个fail 函数,用于返回异常对象,then 和 fail 不会同时被调用,就好比一个普通函数,如果抛出异常就不会有返回值一样。
举例,修改之前代码:
var Q = require("q"),fs = require("fs");
Q.nfcall(fs.readdir, "no path")
.then(function(ns){
var promises = [];
ns.forEach(function(filename){
promises.push(Q.nfcall(fs.readFile, filename,"utf8"));
})
Q.all(promises).then(function(results){
console.log(results);
})
})
.fail(function(err){
console.log(err);
})运行结果是:
{ [Error: ENOENT, readdir 'no path']
stack: 'Error: ENOENT, readdir \'no path\'\n at Error (native)',
errno: -2,
code: 'ENOENT',
path: 'no path' }说明调用的是 fail函数,而不是then,说明 then 代表无异常情况下的返回值,fail表示抛出的异常,如果过程中有任何异常,promise.then 的函数都不会被调用,而是会调用fail,表示抛出异常。
详细API可参看 http://documentup.com/kriskowal/q/ 有任何问题可在线提问。