Koa 中间件的执行
Node.js 中請求的處理討論 Koa 中間件前，先看原生 Node.js 中是如何創(chuàng)建 server 和處理請求的。 node_server.js const http = require("http"); const PORT = 3000;const server = http.createServer((req, res) => {res.end("hello world!"); });server.listen(PORT); console.log(`server started at http://localhost:${PORT}`);Koa 中請求的處理Koa 也是通過上面的 http.createServer 創(chuàng)建服務(wù)器處理請求的返回 res。 但在 Koa 的封裝體系下，其提供了十分好用的中間件系統(tǒng)，可對請求 req 及返回 res 進(jìn)行便捷地處理。 koa/lib/application.js#L64 listen(...args) {debug('listen'); + const server = http.createServer(this.callback());return server.listen(...args);}Koa 中的 hello world: server.js const Koa = require("koa"); const app = new Koa();app.use(async ctx => {ctx.body = "Hello World"; });app.listen(3000);Koa 中，涉及到對請求返回處理都是通過中間件完成的，像上面為樣，返回頁面一個 Hello World 文本，也是調(diào)用 app.use 向 Application 對象注冊了個中間件來完成。 Koa 中間件編寫及使用Koa 中中間件即一個處理請求的方法，通過調(diào)用 app.use(fn) 后，中間件 fn 被保存到了內(nèi)部一個中間件數(shù)組中。 koa/lib/application.js#L105 use(fn) {if (typeof fn !== 'function') throw new TypeError('middleware must be a function!');if (isGeneratorFunction(fn)) {deprecate('Support for generators will be removed in v3. ' +'See the documentation for examples of how to convert old middleware ' +'https://github.com/koajs/koa/blob/master/docs/migration.md');fn = convert(fn);}debug('use %s', fn._name || fn.name || '-');this.middleware.push(fn);return this;}通過上面的代碼可看到，注冊的中間件被壓入 Application 對象的 this.middleware 數(shù)組。這里有對傳入的方法進(jìn)行判斷，區(qū)分是否為生成器（[generator]）方法，因為較早版本的 Koa 其中間件是通過生成器來實現(xiàn)的，后面有 async/await 語法后轉(zhuǎn)向了后者，所以更推薦使用后者，因此這里有廢棄生成器方式的提示。 因為中間件中需要進(jìn)行的操作是不可控的，完全有可能涉及異步操作，比如從遠(yuǎn)端獲取數(shù)據(jù)或從數(shù)據(jù)庫查詢數(shù)據(jù)后返回到 ctx.body，所以理論上中間件必需是異步函數(shù)。 比如實現(xiàn)計算一個請求耗時的中間件，以下分別是通過普通函數(shù)配合 Promise 以及使用 async/await 方式實現(xiàn)的版本： 來自官方 README 中使用 Promise 實現(xiàn)中間件的示例代碼 // Middleware normally takes two parameters (ctx, next), ctx is the context for one request, // next is a function that is invoked to execute the downstream middleware. It returns a Promise with a then function for running code after completion.app.use((ctx, next) => {const start = Date.now();return next().then(() => {const ms = Date.now() - start;console.log(`${ctx.method} ${ctx.url} - ${ms}ms`);}); });來自官方 README 中使用 async/await 實現(xiàn)中間件的示例代碼 app.use(async (ctx, next) => {const start = Date.now();await next();const ms = Date.now() - start;console.log(`${ctx.method} ${ctx.url} - ${ms}ms`); });可以看到，一個中間件其簽名是 (ctx,next)=>Promise，其中 ctx 為請求上下文對象，而 next 是這樣一個函數(shù)，調(diào)用后將執(zhí)行流程轉(zhuǎn)入下一個中間件，如果當(dāng)前中間件中沒有調(diào)用 next，整個中間件的執(zhí)行流程則會在這里終止，后續(xù)中間件不會得到執(zhí)行。以下是一個測試。 server.js app.use(async (ctx, next) => {console.log(1);next(); }); app.use(async (ctx, next) => {console.log(2); }); app.use(async (ctx, next) => {console.log(3);ctx.body = "Hello, world!"; });執(zhí)行后控制臺輸出： $ node server.js 1 2訪問頁面也不會看到 Hello, world! 因為設(shè)置響應(yīng)的代碼 ctx.body = "Hello, world!"; 所在的中間件沒有被執(zhí)行。 compose下面來看當(dāng)多次調(diào)用 app.use 注冊中間件后，這些中間件是如何被順次執(zhí)行的。 中間件的執(zhí)行是跟隨一次請求的。當(dāng)一個請求來到后臺，中間件被順次執(zhí)行，在各中間件中對請求 request 及 resposne 進(jìn)行各種處理。 所以從 Koa 中處理請求的地方出發(fā)，找到中間件執(zhí)行的源頭。 通過查看 lib/application.js 中相關(guān)代碼： lib/application.js#L127 callback() { + const fn = compose(this.middleware);if (!this.listenerCount('error')) this.on('error', this.onerror);const handleRequest = (req, res) => {const ctx = this.createContext(req, res);return this.handleRequest(ctx, fn);};return handleRequest;}可定位到存儲在 this.middleware 中的中間件數(shù)組會傳遞給 compose 方法來處理，處理后得到一個函數(shù) fn，即這個 compose 方法處理后，將一組中間件函數(shù)處理成了一個函數(shù)，最終在 handleRequest 處被調(diào)用，開啟了中間件的執(zhí)行流程。 lib/application.js#L151 handleRequest(ctx, fnMiddleware) {const res = ctx.res;res.statusCode = 404;const onerror = err => ctx.onerror(err);const handleResponse = () => respond(ctx);onFinished(res, onerror); + return fnMiddleware(ctx).then(handleResponse).catch(onerror);}即 compose 的簽名長這樣：compose([a, b, c, ...])，它來自另一個單獨的倉庫 koajs/compose，其代碼也不復(fù)雜： koajs/compose/index.js function compose(middleware) {if (!Array.isArray(middleware))throw new TypeError("Middleware stack must be an array!");for (const fn of middleware) {if (typeof fn !== "function")throw new TypeError("Middleware must be composed of functions!");}/** * @param {Object} context * @return {Promise} * @api public */return function(context, next) {// last called middleware #let index = -1;return dispatch(0);function dispatch(i) {if (i <= index)return Promise.reject(new Error("next() called multiple times"));index = i;let fn = middleware[i];if (i === middleware.length) fn = next;if (!fn) return Promise.resolve();try {return Promise.resolve(fn(context, dispatch.bind(null, i + 1)));} catch (err) {return Promise.reject(err);}}}; }這個方法只做了兩件事，
這里中間件從數(shù)組中取出并順次執(zhí)行的邏輯便在 dispatch 函數(shù)中。 整體方法體中維護(hù)了一個索引 index 其初始值為 -1，后面每調(diào)用一次 dispatch 會加 1。當(dāng)執(zhí)行 dispatch(0) 時，從中間件數(shù)組 middleware 中取出第 0 個中間件并執(zhí)行，同時將 dispatch(i+1) 作為 next 傳遞到下一次執(zhí)行。 let fn = middleware[i]; return Promise.resolve(fn(context, dispatch.bind(null, i + 1)));所以這里就能理解，為什么中間件中必需調(diào)用 next，否則后續(xù)中間件不會執(zhí)行。 這樣一直進(jìn)行下去直到所有中間件執(zhí)行完畢，此時 i === middleware.length，最后一個中間件已經(jīng)執(zhí)行完畢，next 是沒有值的，所以直接 resolve 掉結(jié)束中間件執(zhí)行流程。 if (i === middleware.length) fn = next; if (!fn) return Promise.resolve();回到中間件被喚起的地方： lib/application.js fnMiddleware(ctx).then(handleResponse).catch(onerror);中間件完成后，流程到了 handleResponse。 總結(jié)從中間件執(zhí)行流程可知道：
相關(guān)資源
|
轉(zhuǎn)載于:https://www.cnblogs.com/Wayou/p/koa_middleware.html
總結(jié)
以上是生活随笔為你收集整理的Koa 中间件的执行的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 第一单元总结
- 下一篇： mount 挂载光盘