摘要:中異步處理在中使用的是,在中使用的是,我們本次采用來處理異步。函數參數為的數組,數組成員是通過方法添加的中間件。小結從最開始的編寫中間件,到現在閱讀函數源碼,中間件機制并不復雜,了解之后,我們可以運用編寫更合適的中間件,構建自己的應用。
上一篇講了如何編寫屬于自己的 Koa 中間件,本篇將根據原理實現一個簡單的中間件處理函數,并對 Koa 中間件處理函數 compose 函數進行源碼解析。
1. compose 函數簡單實現Koa 中間件采取的是中間件洋蔥模型,具體原理可見如何編寫屬于自己的 Koa 中間件。本質就是將中間件嵌套執行:
function middleware0(){ console.log("middleware0") } function middleware1(){ console.log("middleware1") } // 將兩個中間件嵌套執行 middleware0(middleware1())
當然實際上更復雜,還要考慮中間件的異步執行和中間件如何進行嵌套。Koa 中異步處理在 Koa1 中使用的是 generator + co.js,在 Koa2 中使用的是 async/await,我們本次采用 async/await 來處理異步。中間件的嵌套可以通過將中間件當參數傳遞來實現嵌套。據此我們對上面的代碼進行進一步加工:
ps:Node7.6+ 支持 async/await
async function middleware0(next){ console.log("middleware0") await next() } async function middleware1(next){ console.log("middleware1") } // 將兩個中間件嵌套執行 middleware0(middleware1)
Koa 中通過 compose 函數對中間件的進行處理。compose 函數參數為 middleware 的數組, middleware 數組成員是通過 use 方法添加的中間件。下面寫個簡單的 compose 函數,來實現多個中間件的處理:
async function middleware0(next){ console.log("middleware0") await next() console.log("middleware0 end") } async function middleware1(next){ console.log("middleware1") await next() console.log("middleware1 end") } async function middleware2(next){ console.log("middleware2") await next() console.log("middleware2 end") } /** * @param {Array} 中間件數組 */ function compose (middleware) { // 從第一個中間件開始執行 return dispatch(0) function dispatch(i){ // 獲取第 i 個中間件 fn = middleware[i] // 獲取不到中間件,則直接返回結束 if(!fn) return // 執行第 i 個中間件,并傳入第 i + 1 個中間件 return fn(() => dispatch(i + 1)) } } // 執行 compose([middleware0, middleware1, middleware2])2. 源碼解析
我們已經簡單實現了一個 compose 函數,現在來看下 Koa 中源碼的實現。Koa 中的 compose 函數已經提取到 koa-compose 包中,其中的核心代碼如下:
/** * @param {Array} 中間件數組 * @return {Function} */ function compose (middleware) { // 判斷是否為數組,不是則拋出異常 if (!Array.isArray(middleware)) throw new TypeError("Middleware stack must be an array!") // 判斷 middleware 數組中的中間件是否為函數,不是函數拋出異常 for (const fn of middleware) { if (typeof fn !== "function") throw new TypeError("Middleware must be composed of functions!") } /** * 此處先不執行中間件,直接返回函數 * 統一在外面進行異常判斷,再開始執行中間件 */ return function (context, 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 // 獲取第 i 個中間件 let fn = middleware[i] /** * 中間件執行結束,檢查是否有傳入 next 回調函數 * 此 next 并非中間件執行的 next 參數 */ if (i === middleware.length) fn = next /** * 所有的返回都是Promise對象 * Promise對象可以保證中間件和返回請求對象之間的執行順序 */ if (!fn) return Promise.resolve() try { // 執行第 i 個中間件,并傳入第 i + 1 個中間件 return Promise.resolve(fn(context, dispatch.bind(null, i + 1))); } catch (err) { return Promise.reject(err) } } } }
通過解析可以發現,源碼相對于我們的實現更加健全:
更完善的異常處理
在執行前統一對傳入參數進行檢查
多次執行 next 函數拋出異常處理等
最終返回結果 Promise 化,保證中間件和整個處理函數在 Koa 中的執行順序,具體可參考下面 Koa 源碼片段:
/** * application.js * fnMiddleware(ctx) 就是 compose 函數返回的函數,默認不傳入 next 參數 * Promise 保證中間件,handleResponse 執行順序。 */ fnMiddleware(ctx).then(handleResponse).catch(onerror)3. 小結
從最開始的編寫 Koa 中間件,到現在閱讀 compose 函數源碼,Koa 中間件機制并不復雜,了解之后,我們可以運用、編寫更合適的中間件,構建自己的 Koa 應用。
本文首發于公眾號,更多內容歡迎關注我的公眾號: 阿夸漫談
文章版權歸作者所有,未經允許請勿轉載,若此文章存在違規行為,您可以聯系管理員刪除。
轉載請注明本文地址:http://specialneedsforspecialkids.com/yun/101208.html
摘要:目前使用人數眾多。通過利用函數,幫你丟棄回調函數,并有力地增強錯誤處理。這個系列的博客主要講解和的中間件機制,本篇將主要講解的中間件機制。其中間件機制的核心為內部方法的實現。 提到 Node.js 開發,不得不提目前炙手可熱的2大框架 Express 和 Koa。 Express 是一個保持最小規模的靈活的 Node.js Web 應用程序開發框架,為 Web 和移動應用程序提供一組...
摘要:實現的四大模塊上文簡述了源碼的大體框架結構,接下來我們來實現一個的框架,筆者認為理解和實現一個框架需要實現四個大模塊,分別是封裝創建類構造函數構造對象中間件機制和剝洋蔥模型的實現錯誤捕獲和錯誤處理下面我們就逐一分析和實現。 什么是koa框架? ? ? ? ?koa是一個基于node實現的一個新的web框架,它是由express框架的原班人馬打造的。它的特點是優雅、簡潔、表達力強、自由度...
摘要:實現的四大模塊上文簡述了源碼的大體框架結構,接下來我們來實現一個的框架,筆者認為理解和實現一個框架需要實現四個大模塊,分別是封裝創建類構造函數構造對象中間件機制和剝洋蔥模型的實現錯誤捕獲和錯誤處理下面我們就逐一分析和實現。 什么是koa框架? ? ? ? ?koa是一個基于node實現的一個新的web框架,它是由express框架的原班人馬打造的。它的特點是優雅、簡潔、表達力強、自由度...
摘要:前言目前最新版本是所以本文分析也基于這個版本。源碼分析直接切入主題由于目前是一個獨立的路由和中間件框架。所以分析的方向也以這兩個為主。源碼去年的時候有分析過現在對比分析思考下。 前言 目前express最新版本是4.16.2,所以本文分析也基于這個版本。目前從npm倉庫上來看express使用量挺高的,express月下載量約為koa的40倍。所以目前研究下express還是有一定意義...
閱讀 3916·2021-11-16 11:44
閱讀 3116·2021-11-12 10:36
閱讀 3373·2021-10-08 10:04
閱讀 1257·2021-09-03 10:29
閱讀 391·2019-08-30 13:50
閱讀 2605·2019-08-29 17:14
閱讀 1735·2019-08-29 15:32
閱讀 1081·2019-08-29 11:27