1.1Node,js中的异步API
// 读取文件操作
fs.readFile('./demo.txt',(eer,result)=>{});
// 事件监听API
var server = http.creatServer;
server.on('request',(req,res)=>{});
如果异步API后面的代码执行依赖当前异步API的执行结果,但实际上后续代码在执行的时候异步API还没有返回结果,这个问题怎么解决?
fs.readFile('./demo.txt',(eer,result)=>{});
console.log('文件读取结果');
解决办法:①把console.log()放在回调函数中
问题?需求,依次读取A文件,B文件,C文件(如果使用①的解决办法,那么函数会嵌套太多,难以维护)。
新建文件1.txt,2.txt,3.txt
const fs = require('fs')
fs.readFile('./1.txt','utf8',(err,result1)=>{
console.log(result1);
fs.readFile('./2.txt','utf8',(err,result2)=>{
console.log(result2);
fs.readFile('./3.txt','utf8',(err,result3)=>{
console.log(result3);
});
});
});
返回:1
2
3
PS:这样的代码叫做回调地狱,虽然能解决需求,但难以维护。es6中提供了promise可以解决回调地狱的问题。
1.2promise解决回调地狱
基础语法
let promise = new Promise((resolve,reject)=>{ // resolve成功,reject执行失败信息
setTimeout(()=>{
if(true){
resolve({name,'张三'})
}else{
reject('失败了');
}
},2000);
});
promise.then(result=>console.log(result);) // { name:'张三'}
.catch(error=>console.log(error);) // 失败了
新建文件7.promise.js
const fs =require('fs');
let promise = new Promise((resolve,reject)=>{
fs.readFile('./100.txt','utf8',(err,result)=>{
if(err !=null){
reject(err);
}else{
resolve(result);
}
});
});
promise.then((result)=>{
console.log(result);
})
.catch((err)=>{
console.log(err);
})
返回[Error: ENOENT: no such file or directory, open 'C:\Node\100.txt'] {
errno: -4058,
code: 'ENOENT',
syscall: 'open',
path: 'C:\Node\100.txt'
}
通过catch拿到异步API的错误信息,此时能够把异步API的执行,和错误的处理进行了分离,使用这样的方式就能解决回调地狱的问题。
新建8.promise2.js文件
const fs = require('fs')
// fs.readFile('./1.txt','utf8',(err,result1)=>{
// console.log(result1);
// fs.readFile('./2.txt','utf8',(err,result2)=>{
// console.log(result2);
// fs.readFile('./3.txt','utf8',(err,result3)=>{
// console.log(result3);
// });
// });
// });
function p1(){
return new Promise((resolve,reject)=>{
fs.readFile('./1.txt','utf8',(err,result)=>{
resolve(result);
});
})
}
function p2(){
return new Promise((resolve,reject)=>{
fs.readFile('./2.txt','utf8',(err,result)=>{
resolve(result);
});
})
}
function p3(){
return new Promise((resolve,reject)=>{
fs.readFile('./3.txt','utf8',(err,result)=>{
resolve(result);
});
})
}
p1().then((r1)=>{
console.log(r1);
return p2();
})
.then((r2)=>{
console.log(r2);
return p3();
})
.then((r3)=>{
console.log(r3);
})
返回1 2 3
1.3异步函数(ES7)
基于promise对象的基础上进行封装,将看起来比较臃肿的代码封装起来,开发一些关键字,供我们使用。
异步函数是异步编程语法的终极解决方案,他可以让我们将异步代码写成同步形式,让代码不再有回调函数嵌套,使代码变得清晰明了。
语法:
const fn = async()=>{};
async function fn(){}
新建文件9.async.js
// 1.在普通函数定义的前面加上async关键字,普通函数就变成了异步函数
// 2.异步函数默认的返回值是promise对象
// 3.在异步函数内部使用throw关键字进行错误抛出
// 4.await关键字 PS:1.它只能出现在异步函数中2.await promise 他可以暂停异步函数的执行,等待promise对象返回结果后再向下执行函数。
async function fn(){
}
console.log(fn())
返回:Promise{undefined}
async function fn(){
return 123
}
console.log(fn())
返回:Promise{123}
async function fn(){
return 123
}
fn().then(function(data){
console.log(data);
})
返回:Promise{123}
错误信息怎么返回?以前是用reject,现在用throw关键字。
async function fn(){
throw '发生了一些错误'; // throw一旦执行后面的代码就无法执行了
return 123
}
fn().then(function(data){
console.log(data);
})
.catch(function(err){ // err就是throw后面的文字
console.log(err)
})
返回:发生了一些错误
使用await关键字
async function = p1(){
return 'p1';
}
async function = p2(){
return 'p2';
}
async function = p3(){
return 'p3';
}
async function run(){
let r1 = await p1() // 使用了await如果P1没有结果不会向下执行
let r2 = await p2()
let r3 = await p3()
console.log(r1)
console.log(r2)
console.log(r3)
}
run()
返回:p1
p2
p3
async关键字
1.普通函数定义前加async关键字, 普通函数就变成了异步函数
2.异步函数默认返回promise对象
3.在异步函数内部使用return关键字进行结果返回,结果会被包裹的promise对象中,return关键字代替了resolve方法
4.在异步函数内部使用throw关键字抛出程序异常
5.调用异步函数在链式调用then方法获取异步函数执行结果
6.调用异步函数再链式调用catch方法获取异步函数执行的错误信息
await关键字
1.await关键字只能出现在异步函数中
2.await promise await后面只能写promise对象,写其他类型API是不可以的
3.await关键字可暂停异步函数向下执行,指定promise返回结果
异步函数在Node.js中的应用
新建anyac目录下新建文件anyncfunction.js
PS:redFile是通过返回值的方式,来获取文件的读取结果,也就是它不返回promise对象,readFile前面不能加await关键字,因为它不返回promise对象,也就是异步函数中node.js不能用。
后来node.js提供了一个方法,能对现有的异步API进行包装,让这个方法去返回promise对象,以支持异步函数语法。
这个方法叫做 promisify,它存储在了util模块中
const fs= require('fs');
// 改造现有异步函数API,让其返回promise对象从而支持异步函数语法
const promisify = require('util').promisify;
// promisify(fs.readFile) // 返回一个新的读取文件的方法
// 调用promisify方法改造现有异步API,让其返回promise对象
const readFile = promisify(fs.readFile)
async function run(){
let r1 = await readFile('./1.txt','utf8')
let r2 = await readFile('./2.txt','utf8')
let r3 = await readFile('./3.txt','utf8')
console.log(r1);
console.log(r2);
console.log(r3);
}
run();