Promise学习¶
前沿¶
JavaScript是一种同步编程语言，程序由上往下依次执行。在处理异步任务时，可以使用回调函数。 例如我们前面介绍的异步读取文件操作.
const fs = require('fs');
fs.readFile('file.txt', (err,data)=>{
if(err){
throw new Error('读数据出错');
}
console.log(data);
})
1.Promise介绍¶
Promise 是异步编程的一种更优雅的解决方案，比传统的解决方案——回调函数——更合理和更强大。它由社区最早提出和实现，ES6 将其写进了语言标准，统一了用法，原生提供了Promise对象。
所谓Promise，简单说就是一个容器，里面保存着某个未来才会结束的事件（通常是一个异步操作）的结果。从语法上说，Promise 是一个对象，从它可以获取异步操作的消息。Promise 提供统一的 API，各种异步操作都可以用同样的方法进行处理。
简单理解为： promise是对异步操作的封装，封装异步文件读写， ajax异步网络请求...
Promise对象有以下两个特点。
（1）对象的状态不受外界影响。Promise对象代表一个异步操作，有三种状态：pending（进行中）、fulfilled（已成功）和rejected（已失败）。只有异步操作的结果，可以决定当前是哪一种状态，任何其他操作都无法改变这个状态。这也是Promise这个名字的由来，它的英语意思就是“承诺”，表示其他手段无法改变。
（2）一旦状态改变，就不会再变，任何时候都可以得到这个结果。Promise对象的状态改变，只有两种可能：从pending变为fulfilled和从pending变为rejected。只要这两种情况发生，状态就凝固了，不会再变了，会一直保持这个结果，这时就称为 resolved（已定型）。
有了Promise对象，就可以将异步操作以同步操作的流程表达出来，避免了层层嵌套的回调函数。
//异步读取filename命名的文件
//读取文件1
fs.readFile(filename, function (err, data) {
if (err) {
console.log('读文件出错' + err);
} else {
console.log(data.toString());
//读取文件2
fs.readFile(filename, function (err, data) {
if (err) {
console.log('读文件出错' + err);
} else {
console.log(data.toString());
//读取文件3
fs.readFile(filename, function (err, data) {
if (err) {
console.log('读文件出错' + err);
} else {
console.log(data.toString());
}
});
}
});
}
});
2. 基本用法¶
const promise = new Promise(function(resolve, reject) {
// ... some code
if (/* 异步操作成功 */){
resolve(value);
} else {
reject(error);
}
});
以异步读取文件为例
- 封装异步读取文件promise对象
const promiseObj = new Promise((resovled, rejected) => {
//具体异步操作
fs.readFile(path, (err, data) => {
if (err) {
rejected(err);
} else {
resovled(data);
}
});
});
- 处理异步文件读取成功&失败的结果
promiseObj.then((result)=>{
console.log(`result :${result}`);
});
promiseObj.catch((err) => {
console.log(`err>>> : ${err}`);
});
//链式写法
promiseObj.then((result) => {
console.log(`result :${result}`);
}).catch((err) => {
console.log(`err>>> : ${err}`);
});
3. 链式调用¶
3.1 异步读取多个文件¶
const fs = require('fs');
/**
* promise对象是javascript中对象， 处理异步操作的.
* promise对象实质是对异步操作的封装
*/
const promiseObj1 = new Promise((resovled, rejected) => {
//具体异步操作
fs.readFile('./test1.txt', (err, data) => {
if (err) {
rejected(err);
} else {
resovled(data);
}
});
});
const promiseObj2 = new Promise((resovled, rejected) => {
//具体异步操作
fs.readFile('./test2.txt', (err, data) => {
if (err) {
rejected(err);
} else {
resovled(data);
}
});
});
const promiseObj3 = new Promise((resovled, rejected) => {
//具体异步操作
fs.readFile('./test3.txt', (err, data) => {
if (err) {
rejected(err);
} else {
resovled(data);
}
});
});
//调用promise链式调用
promiseObj1.then((result1) => {
console.log(`result1 :${result1}`);
return promiseObj2;
}).then((result2) => {
console.log(`result2 :${result2}`);
return promiseObj3;
}).then((result3) => {
console.log(`result3 :${result3}`);
})
.catch((err) => {
console.log(`err>>> : ${err}`);
});
3.2 异步读取文件封装为函数¶
const fs = require('fs');
/**
* 封装promise对象到readFileByPromise函数中
*/
const readFileByPromise = (path) => {
const promiseObj = new Promise((resovled, rejected) => {
//具体异步操作
fs.readFile(path, (err, data) => {
if (err) {
rejected(err);
} else {
resovled(data);
}
});
});
return promiseObj;
}
const promise = readFileByPromise('./test1.txt');
//调用promise链式调用
promise.then((result1) => {
console.log(`result1 :${result1}`);
return readFileByPromise('./test2.txt');
}).then((result2) => {
console.log(`result2 :${result2}`);
return readFileByPromise('./test3.txt');
}).then((result3) => {
console.log(`result3 :${result3}`);
})
.catch((err) => {
console.log(`err>>> : ${err}`);
});
3.3 模块化¶
//readFilePromise.js
const fs = require('fs');
/**
* 封装promise对象到readFileByPromise函数中
*/
const readFileByPromise = (path) => {
const promiseObj = new Promise((resovled, rejected) => {
//具体异步操作
fs.readFile(path, (err, data) => {
if (err) {
rejected(err);
} else {
resovled(data);
}
});
});
return promiseObj;
}
module.exports = {readFile:readFileByPromise};
//test.js
const readPromise = require('./readFilePromise.js');
const promise = readPromise.readFile('./test2.txt');
promise.then((result)=>{
console.log(`result: ${result}`);
});
4. Promise.all() 多个异步任务，并发执行¶
Promise.all([
promise1,
promise2,
promise3
]).then( result => {
console.log(`result : ${result}`);
})
5. Promise.race() 多个异步任务，谁最先执行完，then函数就处理谁¶
Promise.race([
promise1,
promise2,
promise3
]).then( result => {
console.log(`result : ${result}`);
})
示例:
const fs = require('fs');
/**
* 封装promise对象到readFileByPromise函数中
*/
const readFileByPromise = (path) => {
const promiseObj = new Promise((resovled, rejected) => {
//具体异步操作
fs.readFile(path, (err, data) => {
if (err) {
rejected(err);
} else {
resovled(data);
}
});
});
return promiseObj;
}
const promise1 = readFileByPromise('./test1.txt');
const promise2 = readFileByPromise('./test2.txt');
const promise3 = readFileByPromise('./test3.txt');
//调用promise链式调用
promise.then((result1) => {
console.log(`result1 :${result1}`);
return readFileByPromise('./test2.txt');
}).then((result2) => {
console.log(`result2 :${result2}`);
return readFileByPromise('./test3.txt');
}).then((result3) => {
console.log(`result3 :${result3}`);
})
.catch((err) => {
console.log(`err>>> : ${err}`);
});
// Promise.all() 多个异步任务，并发执行
Promise.all([
promise1,
promise2,
promise3
]).then( result => {
console.log(`result : ${result}`);
})
// Promise.race() 多个异步任务，谁最先执行完，then函数就处理谁
Promise.race([
promise1,
promise2,
promise3
]).then( result => {
console.log(`result : ${result}`);
})