国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 編程 > JavaScript > 正文

理解Koa2中的async&await的用法

2019-11-19 14:24:34
字體:
來源:轉載
供稿:網友

Koa是一款非常著名的Node服務端框架,有1.x版本和2.x版本。前者使用了generator來進行異步操作,后者則用了最新的async/await方案

一開始使用這種寫法的時候,我遇到一個問題,代碼如下:

const Koa = require('koa');const app = new Koa();const doSomething = time => {  return new Promise(resolve => {    setTimeout(() => {      resolve('task done!')    }, time)  })}// 用來打印請求信息app.use((ctx, next) => {  console.log(`${ctx.method}:::${ctx.url}`)  next()})app.use(async ctx => {  const result = await doSomething(3000)  console.log(result);  ctx.body = result})app.listen(3000);

讓我們測試一下:curl http://localhost:3000

期望結果:

(3秒后...)task done!

然而現實卻是:

(立即)
Not Found

什么鬼?為什么沒有按照預期執行?這就需要我們來理解下Koa中中間件是如何串聯起來的了。翻一下源碼,將middlewares串聯起來的代碼如下:

function compose (middleware) { return function (context, next) {  // 這個index用來計數,防止next被多次調用  let index = -1  // 執行入口  return dispatch(0)    function dispatch (i) {   // 如果next被多次調用,報異常   if (i <= index) return Promise.reject(new Error('next() called multiple times'))   index = i   // 取出第一個middleware   let fn = middleware[i]   // 將最初傳入的next作為最后一個函數執行   if (i === middleware.length) fn = next   if (!fn) return Promise.resolve()   try {    /**    這里就是關鍵了,Promise.resolve是什么意思呢?     Promise.resolve方法有下面三種形式:          Promise.resolve(value);     Promise.resolve(promise);     Promise.resolve(theanable);         這三種形式都會產生一個新的Promise。其中:    第一種形式提供了自定義Promise的值的能力,它與Promise.reject(reason)對應。兩者的不同,在于得到的Promise的狀態不同。    第二種形式,提供了創建一個Promise的副本的能力。    第三種形式,是將一個類似Promise的對象轉換成一個真正的Promise對象。它的一個重要作用是將一個其他實現的Promise對象封裝成一個當前實現的Promise對象。例如你正在用bluebird,但是現在有一個Q的Promise,那么你可以通過此方法把Q的Promise變成一個bluebird的Promise。第二種形式可以歸在第三種里面        **/    return Promise.resolve(fn(context, function next () {     // 執行下一個middleware,返回結果也是一個Promise     return dispatch(i + 1)    }))   } catch (err) {    return Promise.reject(err)   }  } }}

有了以上基礎,我們再來看一下之前的問題,為什么response沒有等到第二個middleware執行完成就立即返回了呢?

因為第一個middleware并不是一個異步函數啊。

由于每次next方法的執行,實際上都是返回了一個Promise對象,所以如果我們在某個middleware中執行了異步操作,要想等待其完成,就要在執行這個middleware之前添加await

那我們來改寫一下之前的代碼

app.use(async (ctx, next) => {  console.log(`${ctx.method}:::${ctx.url}`)  await next()})app.use(async ctx => {  const result = await doSomething(3000)  console.log(result);  ctx.body = result})

好了,沒有問題,一切如期望執行:clap:

錯誤處理

借助了Promise強大的功力,配合async/await語法,我們只需要把try/catch的操作寫在最外層的middleware中,就可以捕獲到之后所有中間件的異常!

app.use(async (ctx, next) => {  try{    await next()  }catch(err){    console.log(err)  }})app.use(async (ctx)=>{  throw new Error('something wrong!')  ctx.body = 'Hello'})

基于中間件鏈的完全控制,并且基于 Promise 的事實使得一切都變得容易操作起來。不再是到處的 if (err) return next(err) 而只有 promise

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持武林網。

發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 三门县| 民勤县| 温宿县| 泽库县| 黑水县| 昌宁县| 西青区| 秦安县| 高陵县| 和林格尔县| 龙州县| 葫芦岛市| 仙桃市| 南康市| 竹溪县| 伊宁县| 宝山区| 乌拉特中旗| 正镶白旗| 青海省| 陈巴尔虎旗| 明光市| 开封县| 蓬安县| 白朗县| 云安县| 昂仁县| 阳江市| 南康市| 温泉县| 双峰县| 辽源市| 古交市| 香河县| 朝阳县| 黄龙县| 洪洞县| 海宁市| 七台河市| 莆田市| 江都市|