转载

异步编程值async-await

const fetch = require('node-fetch');

async function getZhihuColumn(id){
  const url = `https://zhuanlan.zhihu.com/api/columns/${id}`;
  const response = await fetch(url);
  return  await response.json();
}

getZhihuColumn('feweekly')
  .then(column => {
    console.log(`NAME: ${column.name}`);
    console.log(`INTRO: ${column.intro}`);
  })

await 接收一个 promise对象在 resolve的时候，把resolve的值返回给接收的值，但是在reject的时候会抛出错误

async 在全局作用域中使用async表达式是非法的

解决办法：使用匿名立即执行的函数

const fetch = require('node-fetch');

const getZhihuColumn = async (id) => {
    const url = `https://zhuanlan.zhihu.com/api/columns/${id}`;
    const response = await fetch(url);
    return await response.json();
}

(async ()=>{
    const column = await getZhihuColumn('feweekly');
    console.log(`NAME: ${column.name}`);
    console.log(`INTRO: ${column.intro}`);
})();

使用 class

class APIClient{
  async getColumn(id){
    const url = `https://zhuanlan.zhihu.com/api/columns/${id}`;
    const response = await fetch(url);
    return await response.json();
  }
}

(async ()=> {
  const client = new APIClient();
  const column = await client.getColumn('feweekly');
  console.log(`NAME: ${column.name}`);
  console.log(`INTRO: ${column.intro}`);
})();

错误处理

const fetch = require('node-fetch');

async function getZhihuColumn(id){
  const url = `https://zhuanlan.zhihu.com/api/columns/${id}`;
  const response = await fetch(url);
  if(response.status != 200){
    throw new Error(response.statusText);
  }
  return await response.json();
}

第一种：使用promise的 catch

getZhihuColumn('feweekl12y')
  .then( column => {
    console.log(`NAME: ${column.name}`);
    console.log(`INTRO: ${column.intro}`);
  })
  .catch(err => {
    console.log(err);
  });

第二种：写到另一个 async 函数里

const showColunmInfo = async (id) => {
   try{
     const column = await getZhihuColumn(id);
     console.log(`NAME: ${column.name}`);
     console.log(`INTRO: ${column.intro}`);
   }catch(err){
     console.error(err);
   }
}

showColunmInfo('feweekl12y');

并行处理和串行处理

并行比串行速度快。

const fetch = require('node-fetch');
//延迟俩秒再发起promise
const sleep = (timeout = 2000) => new Promise(resolve => {
  setTimeout(resolve, timeout);
});

async function getZhihuColumn(id){
  await sleep(2000);
  const url = `https://zhuanlan.zhihu.com/api/columns/${id}`;
  const response = await fetch(url);
  rerturn await response.json();
}

串行的

const showColumnInfro = async () => {
  console.time('SHOWCOLUMNINFO');
  const feweekly = await getZhihuColumn('feweekly');
  const toolingtips = await getZhihuColumn('toolingtips');

  console.log(`NAME: ${feweek.name}`);
  console.log(`INTRO: ${feweek.intro}`);

  console.log(`NAME: ${toolingtips.name}`);
  console.log('INTRO: ${toolingtips.intro}');
  console.timeEnd('SHOWCOLUMNINFO');
};

showColumnInfro();

运行结果

NAME: 前端周刊
INTRO: 在前端领域跟上时代的脚步，广度和深度不断精进
NAME: tooling bits
INTRO: 工欲善其事必先利其器
SHOWCOLUMNINFO: 4362.290ms

并行的(一)，可以先发起promise请求然后再await结果发起并行

const showColumnInfro = async () => {
  console.time('SHOWCOLUMNINFO');
  const feweeklyPromise = getZhihuColumn('feweekly');
  const toolingtipsPromise = getZhihuColumn('toolingtips');

  const feweekly = await feweeklyPromise;
  const toolingtips = await toolingtipsPromise;

  console.log(`NAME: ${feweekly.name}`);
  console.log(`INTRO: ${feweekly.intro}`);

  console.log(`NAME: ${toolingtips.name}`);
  console.log(`INTRO: ${toolingtips.intro}`);
  console.timeEnd('SHOWCOLUMNINFO');
};

showColumnInfro();

运行结果

NAME: 前端周刊
INTRO: 在前端领域跟上时代的脚步，广度和深度不断精进
NAME: tooling bits
INTRO: 工欲善其事必先利其器
SHOWCOLUMNINFO: 2542.540ms

并行(二) 使用 promise.all 执行并行操作

const fetch = require('node-fetch');

const sleep = (timeout = 2000) => new Promise(resolve => {
  setTimeout(resolve, timeout);
})

async function getZhihuColumn(id){
  await sleep();
  const url = `https://zhuanlan.zhihu.com/api/columns/${id}`;
  const response = await fetch(url);
  return await response.json();
}

const showColumnInfro = async () => {
  console.time('SHOWCOLUMNINFO');
  const [feweekly, toolingtips] = await Promise.all([
    getZhihuColumn('feweekly'),
    getZhihuColumn('toolingtips')
  ]);

  console.log(`NAME: ${feweekly.name}`);
  console.log(`INTRO: ${feweekly.intro}`);

  console.log(`NAME: ${toolingtips.name}`);
  console.log(`INTRO: ${toolingtips.intro}`);
  console.timeEnd('SHOWCOLUMNINFO');
};

showColumnInfro();

运行结果

NAME: 前端周刊
INTRO: 在前端领域跟上时代的脚步，广度和深度不断精进
NAME: tooling bits
INTRO: 工欲善其事必先利其器
SHOWCOLUMNINFO: 2532.700ms

如果 await 后面跟的不是 promise 对象，await会隐式的调用promise.resolve();成为一个立即resolve的promise

async function main(){
    const number = await 890;
    //const number = await Promise.resolve(890);
    console.log(number);
}
main();

在循环中使用async await的串行和并行

在循环中发起多个请求的并行和串行方法

const fetch = require('node-fetch');

const sleep = (timeout = 2000) => new Promise(resolve => setTimeout(resolve, timeout));

async function getZhihuColumn(id){
  await sleep(2000);
  const url = `https://zhuanlan.zhihu.com/api/columns/${id}`;
  const response = await fetch(url);
  return await response.json();
}


const showColumnInfo = async () => {
  console.time('SHOWCOLUMNINFO');

  const names = ['feweekly', 'toolingtips'];

串行

  for (let i = 0; i< names.length; i++){
    const column = await getZhihuColumn(names[i]);
    console.log(`NAME: ${column.name}`);
    console.log(`INTRO: ${column.intro}`);
  }

  console.timeEnd('SHOWCOLUMNINFO');
}

showColumnInfo();

并行的

const promiseArr = names.map(val => getZhihuColumn(val));
for(let promise of promiseArr){
    const column = await promise;
    console.log(`NAME: ${column.name}`);
    console.log(`INTRO: ${column.intro}`)
}

showColumnInfo();

循环中使用async await 注意点

await 只能用于 async 声明的函数上下文中。如下 forEach 中, 是不能直接使用await的，map，reduce中也不行

let array = [0,1,2,3,4,5];
(async ()=>{
  array.forEach(function(item){
    console.log(item);
    await wait(1000);//这是错误的写法
  });
})();
//因await只能用于 async 声明的函数上下文中, 故不能写在forEach内.下面我们来看正确的写法
(async ()=>{
  for(let i=0,len=array.length;i<len;i++){
    console.log(array[i]);
    await wait(1000);
  }
})();

async 做异步循环的时候最好用 for … of … 或者 Promise.all() 来完成并发请求

知识点关于箭头函数

错误

const sleep = (timeout = 2000) => {
    new Promise(resolve => setTimeout(resolve, timeout);
}

这个是我写的sleep函数在测试的时候一直就没执行，这里我以前一直以为的是arrowFunction会自动返回，在去掉 {} 后函数正常执行了，在这里补充一下箭头函数的注意点

正确

const sleep = (timeout = 2000) => new Promise( resolve =>
    setTimeout(resolve, timeout);
);

或

const sleep = (timeout = 2000) => {
    return new Promise(resolve => setTimeout(resolve, timeout);
}

1.箭头函数只有在省略了 {} 的时候，才会隐式的返回。而且只有在只有一行函数体的时候才可以省略 {} 。

2.如果函数体只有一行，而且也没有省略 {} 的话应该在函数体内加上 return 关键字，手动返回。

3.当函数参数只有一个时，可以省略 ()

本文链接：http://www.tiankai.party/异步编程值async-await.html

赏

谢谢你请我吃糖果

异步编程值async-await 支付宝

异步编程值async-await 微信

原文 http://www.tiankai.party/异步编程值async-await.html

正文到此结束

所属分类：编程技术

本文标签： IO ip API http node UI src 测试支付宝 client 协议 map setTimeout cat 参数 json js id https HTML
版权声明： 本文为互联网转载文章，出处已在文章中说明(部分除外)。如果侵权，请联系本站长删除，谢谢。
本文海报： 生成海报一生成海报二

异步编程值async-await

await 接收一个 promise对象在 resolve的时候，把resolve的值返回给接收的值，但是在reject的时候会抛出错误

async 在全局作用域中使用async表达式是非法的

解决办法：使用匿名立即执行的函数

使用 class

错误处理

并行处理和串行处理

如果 await 后面跟的不是 promise 对象，await会隐式的调用promise.resolve();成为一个立即resolve的promise

在循环中使用async await的串行和并行

循环中使用async await 注意点

知识点关于箭头函数

错误

热门推荐

相关文章

说给你听

本文目录

随机标签

书籍教程

近期评论

网站信息

其他链接

关于本站

问题交流

异步编程值async-await

await 接收一个 promise对象 在 resolve的 时候，把resolve的值返回给接收的值，但是在reject的时候会抛出错误

async 在全局作用域中使用async表达式是非法的

解决办法： 使用匿名立即执行的函数

使用 class

错误处理

并行处理和串行处理

如果 await 后面跟的不是 promise 对象，await会隐式的调用promise.resolve();成为一个立即resolve的promise

在循环中使用async await的串行和并行

循环中使用async await 注意点

知识点关于箭头函数

错误

热门推荐

相关文章

说给你听

本文目录

随机标签

书籍教程

近期评论

网站信息

其他链接

关于本站

问题交流

await 接收一个 promise对象在 resolve的时候，把resolve的值返回给接收的值，但是在reject的时候会抛出错误

解决办法：使用匿名立即执行的函数