nodejs Q 使用
## 背景 ##
### 同步api与异步api ##
nodejs中有同步api和异步api;通常情况下建议使用异步api,以提高程序的执行效率.
同步api优缺点:
- (优点)易于使用,逻辑清晰
- (缺点)使用耗时较长(如io操作)的api,程序的执行效率会非常低
异步api优缺点:
- (优点)使用耗时较长(如io操作)的api,也不会降低程序的执行效率
- (缺点)不易使用,逻辑容易乱
### 异步的问题 ###
关键在于异步api的结果如何传递
例如 读取文件:
fs.readFile(file, options, callback);//(err, data)
fs.readFileSync(file, options);//data, throw Error
同步api通过函数"返回值"返回结果
异步api通过"回调函数"返回结果
回调函数存在的问题:回调嵌套
例如 顺序读取3个文件:
fs.readFile(file1, function (){
fs.readFile(file2, function () {
fs.readFile(file3, function () {
//回调嵌套层数多了会使程序变得复杂
});
});
});
### 解决嵌套问题 ###
解决办法就是换一种思路:回归同步api的结果返回方式,使用"返回值"将结果带回
很明显,异步的结果不会直接在"返回值"中取到,只能间接取到
Promise,这是一个概念模型,Promise对象可以携带异步api的计算结果,可以访问Promise对象得到结果(当然得到结果也会是一个异步的)
## 是什么 ##
q是Promise的一个实现,定义了若干方便易用的api.
## 有什么用 ##
解决异步嵌套的问题
除了Promise,还有其他一些为了解决异步api使用的方案,包括 async, eventproxy
缺点也比较明显,async的嵌套问题没有解决,eventproxy使用的方式更容易使逻辑变得复杂
异步api得到简化,看上去更接近同步的api
嵌套层数明显减少
## 怎么用 ##
### 生成一个Promise对象 ###
//方式1
var readFile = function (file, options) {
var defer = Q.defer();
fs.readFile(file, options, function (err, data) {
if (err) {
defer.reject(err);
} else {
defer.resolve(data);
}
});
return defer.primise;
};
//方式2
var readFile = function (file, options) {
return Q.Promise(function (resolve, reject) {
fs.readFile(file, options, function (err, data) {
if (err) {
reject(err);
} else {
resolve(data);
}
});
});
};
//方式3
Q.resolve(data);
Q.reject(err);
### 访问Promise的值 ####
var promise1 = readFile('/path/to/the/data', {});
var promise2 = promise1.then(function (data) {
//data 就是文件'/path/to/the/data'的内容
});
通过Promise对象的then方法就可以访问Promise对象的值,同时会生成一个新的Promise对象
//then的定义
promise.then(onFulfilled, onRejected, onProgress)
### Promise的值 ###
Promise的对象的值有两种:fulfilled和rejected
Promise的对象的值一旦确定就不再改变,且可以被反复访问
var promise1 = readFile('/path/to/the/data', {});
var promise2 = promise1.then(function (data) {
//data 就是文件'/path/to/the/data'的内容
});
var promise3 = promise1.then(function (data) {
//data 还是文件'/path/to/the/data'的内容,
//而且'/path/to/the/data'实际只被读了1次
});
### 通过then或catch得到的新的Promise对象的值 ###
promise.then(function () {
//return data;
//return Q.resolve(data);
//return Q.reject(new Error('error message'));
//throw new Error('error message');
});
### Promise对象链式调用 ###
//假设函数f1,f2,f3,f4都是异步的且都返回Promise对象,
//并且要求f1,f2,f3,f4顺序被执行
//形式1:
var promise1 = f1();
var promise2 = promise1.then(function () {
return f2();
});
var promise3 = promise2.then(function () {
return f3();
});
var promise4 = promise3.then(function () {
return f4();
});
promise4.then(function () {
//f1,f2,f3,f4顺序被执行完成
});
//形式2:
f1().then(function () {
return f2().then(function () {
return f3().then(function () {
return f4().then(function () {
//f1,f2,f3,f4顺序被执行完成
});
});
});
});
//形式3:
f1().then(function () {
return f2();
}).then(function () {
return f3();
}).then(function () {
return f4();
}).then(function () {
//f1,f2,f3,f4顺序被执行完成
});
### Q.all(promisesArray) ###
同时进行多个异步操作
Q.all([
fs.readFile(file1, {}),
fs.readFile(file2, {})
]).then(function (results) {//[file1Data, file2Data]
//当异步调用都成功的时候才执行这里
}, function () {
//当存在失败的异步调用时执行这里
});
QQ群:323934521
www.niefengjun.cn