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對象封裝成一個當前實現(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
聲明:本網(wǎng)頁內(nèi)容旨在傳播知識,若有侵權(quán)等問題請及時與本網(wǎng)聯(lián)系,我們將在第一時間刪除處理。TEL:177 7030 7066 E-MAIL:11247931@qq.com