如何在Koa2中使用async&await=

今天就跟大家聊聊有關(guān)如何在Koa2中使用async&await=，可能很多人都不太了解，為了讓大家更加了解，小編給大家總結(jié)了以下內(nèi)容，希望大家根據(jù)這篇文章可以有所收獲。

Koa是一款非常著名的Node服務(wù)端框架，有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

期望結(jié)果：

(3秒后...)task done!

然而現(xiàn)實卻是：

(立即)
Not Found

什么鬼？為什么沒有按照預(yù)期執(zhí)行？這就需要我們來理解下Koa中中間件是如何串聯(lián)起來的了。翻一下源碼，將middlewares串聯(lián)起來的代碼如下：

function compose (middleware) {
 return function (context, next) {
  // 這個index用來計數(shù)，防止next被多次調(diào)用
  let index = -1
  // 執(zhí)行入口
  return dispatch(0)
  
  function dispatch (i) {
   // 如果next被多次調(diào)用，報異常
   if (i <= index) return Promise.reject(new Error('next() called multiple times'))
   index = i
   // 取出第一個middleware
   let fn = middleware[i]
   // 將最初傳入的next作為最后一個函數(shù)執(zhí)行
   if (i === middleware.length) fn = next
   if (!fn) return Promise.resolve()
   try {
    /**
    這里就是關(guān)鍵了,Promise.resolve是什么意思呢？
     Promise.resolve方法有下面三種形式：
     
     Promise.resolve(value);
     Promise.resolve(promise);
     Promise.resolve(theanable);
     
    這三種形式都會產(chǎn)生一個新的Promise。其中：

    第一種形式提供了自定義Promise的值的能力，它與Promise.reject(reason)對應(yīng)。兩者的不同，在于得到的Promise的狀態(tài)不同。

    第二種形式，提供了創(chuàng)建一個Promise的副本的能力。

    第三種形式，是將一個類似Promise的對象轉(zhuǎn)換成一個真正的Promise對象。它的一個重要作用是將一個其他實現(xiàn)的Promise對象封裝成一個當(dāng)前實現(xiàn)的Promise對象。例如你正在用bluebird，但是現(xiàn)在有一個Q的Promise，那么你可以通過此方法把Q的Promise變成一個bluebird的Promise。第二種形式可以歸在第三種里面
    
    **/
    return Promise.resolve(fn(context, function next () {
     // 執(zhí)行下一個middleware，返回結(jié)果也是一個Promise
     return dispatch(i + 1)
    }))
   } catch (err) {
    return Promise.reject(err)
   }
  }
 }
}

有了以上基礎(chǔ)，我們再來看一下之前的問題，為什么response沒有等到第二個middleware執(zhí)行完成就立即返回了呢？

因為第一個middleware并不是一個異步函數(shù)啊。

由于每次next方法的執(zhí)行，實際上都是返回了一個Promise對象，所以如果我們在某個middleware中執(zhí)行了異步操作，要想等待其完成，就要在執(zhí)行這個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
})

好了，沒有問題，一切如期望執(zhí)行: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

看完上述內(nèi)容，你們對如何在Koa2中使用async&await=有進一步的了解嗎？如果還想了解更多知識或者相關(guān)內(nèi)容，請關(guān)注億速云行業(yè)資訊頻道，感謝大家的支持。