koa中间件机制详解
转自:https://cnodejs.org/topic/58fd8ec7523b9d0956dad945
koa是由express原班人马打造的一个更小、更富有表现力、更健壮的web框架。
在我眼中,koa
的确是比express
轻量的多,koa
给我的感觉更像是一个中间件框架,koa
只是一个基础的架子,需要用到的相应的功能时,用相应的中间件来实现就好,诸如路由系统等。一个更好的点在于,express
是基于回调来处理,至于回调到底有多么的不好,大家可以自行搜索来看。koa1
基于的co
库,所以koa1
利用Generator
来代替回调,而koa2
由于node
对async/await
的支持,所以koa2
利用的是async/await
。关于async
以及co
库等,大家可以参考我之前写过的一篇文章(理解async)。koa
可以说是一个各种中间件的架子,下面就来看一下koa
对于中间件部分的实现:
koa1的中间件
koa1
主要利用的是Generator
来实现,一般来说,koa1
的一个中间件大概是长这个样子的:
app.use(function *(next){console.log(1);yield next;console.log(5); }); app.use(function *(next){console.log(2);yield next;console.log(4); }); app.use(function *(){console.log(3); });
这样的输出会是1, 2, 3, 4, 5
,koa
的中间件的实现主要依靠的是koa-compose
:
function compose(middleware){return function *(next){if (!next) next = noop();var i = middleware.length;// 组合中间件while (i--) {next = middleware[i].call(this, next);}return yield *next;} } function *noop(){}
源码非常的简单,实现的功能就是将所有的中间件串联起来,首先给倒数第一个中间件传入一个noop
作为其next
,再将这个整理后的倒数第一个中间作为next
传入倒数第二个中间件,最终得到的next
就是整理后的第一个中间件。说起来比较复杂,画图来看:
实现的效果如同上图,与redux
需要实现的目标类似,只要遇到了yield next
就去执行下一个中间件,利用co
库很容易将这个流程串联起来,下面来简单模拟下,中间件完整的实现:
const middlewares = [];const getTestMiddWare = (loggerA, loggerB) => {return function *(next) {console.log(loggerA);yield next;console.log(loggerB);} }; const mid1 = getTestMiddWare(1, 4),mid2 = getTestMiddWare(2, 3);const getData = new Promise((resolve, reject) => {setTimeout(() => resolve('数据已经取出'), 1000); });function *response(next) {// 模拟异步读取数据库数据const data = yield getData;console.log(data); }middlewares.push(mid1, mid2, response); // 简单模拟co库 function co(gen) {const ctx = this,args = Array.prototype.slice.call(arguments, 1);return new Promise((reslove, reject) => {if (typeof gen === 'function') gen = gen.apply(ctx, args);if (!gen || typeof gen.next !== 'function') return resolve(gen);const baseHandle = handle => res => {let ret;try {ret = gen[handle](res);} catch(e) {reject(e);}next(ret);};const onFulfilled = baseHandle('next'),onRejected = baseHandle('throw');onFulfilled();function next(ret) {if (ret.done) return reslove(ret.value);// 将yield的返回值转换为Proimselet value = null;if (typeof ret.value.then !== 'function') {value = co(ret.value);} else {value = ret.value;}if (value) return value.then(onFulfilled, onRejected);return onRejected(new TypeError('yield type error'));}}); } // 调用方式 const gen = compose(middlewares); co(gen);
koa2的中间件
随着node
对于async/await
的支持,貌似不需要再借助于co
这种工具库了,直接利用原生的就好,于是koa
也做出了改变,来看目前的koa-compose
:
function compose (middleware) {// 参数检验return function (context, next) {// last called middleware #let index = -1return dispatch(0)function dispatch (i) {if (i <= index) return Promise.reject(new Error('next() called multiple times'))index = ilet fn = middleware[i]// 最后一个中间件的调用if (i === middleware.length) fn = nextif (!fn) return Promise.resolve()// 用Promise包裹中间件,方便await调用try {return Promise.resolve(fn(context, function next () {return dispatch(i + 1)}))} catch (err) {return Promise.reject(err)}}} }
koa-compose
利用了Promise
,koa2
的中间件的参数也有一个变为了两个,而且执行下一个的中间件利用的是await next()
,要达到与上面的示例代码的相同效果,需要更改中间件的写法:
const middlewares = []; const getTestMiddWare = (loggerA, loggerB) => async (ctx, next) => {console.log(loggerA);await next();console.log(loggerB); };const mid1 = getTestMiddWare(1, 4),mid2 = getTestMiddWare(2, 3); const response = async () => {// 模拟异步读取数据库数据const data = await getData();console.log(data); }; const getData = () => new Promise((resolve, reject) => {setTimeout(() => resolve('数据已经取出'), 1000); }); middlewares.push(mid1, mid2);// 调用方式 compose(middlewares)(null, response);
如何做到兼容
可以看到的是,koa1
与koa2
对于中间件的实现还是有着很多的不同的,将koa1
的中间件直接拿到koa2
下面来使用肯定是会出现错误的,如何兼容这两个版本也成了一个问题,koa
团队写了一个包来是koa1
的中间件可以用于koa2
中,叫做koa-convert
,先来看看这个包怎么使用:
function *mid3(next) {console.log(2, 'koa1的中间件');yield next;console.log(3, 'koa1的中间件'); } convert.compose(mid3)
来看下这个包实现的思路:
// 将参数转为数组,对每一个koa1的中间件执行convert操作 convert.compose = function (arr) {if (!Array.isArray(arr)) {arr = Array.from(arguments)}return compose(arr.map(convert)) } // 关键在于convert的实现 const convert = mw => (ctx, next) => {// 借助co库,返回一个Promise,同时执行yieldreturn co.call(ctx, mw.call(ctx, createGenerator(next))); };function * createGenerator (next) {/*next为koa-compomse中:function next () {return dispatch(i + 1)}*/return yield next()// 执行完koa1的中间件,又回到了利用await执行koa2中间件的正轨 }
个人感觉koa-convert
的思路就是对Generator
封装一层Promise
,使上一个中间件可以利用await next()
的方式调用,对于Generator
的执行,利用co
库,从而达到了兼容的目的。
转载于:https://www.cnblogs.com/duhuo/p/8526160.html
koa中间件机制详解相关推荐
- PHP autoload机制详解
PHP autoload机制详解 转载自 jeakccc PHP autoload机制详解 (1) autoload机制概述 在使用PHP的OO模式开发系统时,通常大家习惯上将每个类的实现都存放在一个 ...
- 模糊匹配 读音_onenote搜索机制详解②:两种搜索模式,模糊与精确匹配
先从纯文本搜索讲起,这是最基本也是最重要的. 从这篇开始,以及接下来连续几篇文章,都会介绍搜索的基础功能.注意,这几篇文章中谈论的都是基本的.正常的搜索功能,暂时不考虑Bug等因素. 在很多软件(例如 ...
- Java类加载机制详解【java面试题】
Java类加载机制详解[java面试题] (1)问题分析: Class文件由类装载器装载后,在JVM中将形成一份描述Class结构的元信息对象,通过该元信息对象可以获知Class的结构信息:如构造函数 ...
- Numpy的广播机制详解(broadcasting)
Numpy的广播机制详解(broadcasting) 广播(Broadcast)是 numpy 对不同形状(shape)的数组进行数值计算的方式, 对数组的算术运算通常在相应的元素上进行. 如果两个数 ...
- Session机制详解及分布式中Session共享解决方案
Session机制详解及分布式中Session共享解决方案 参考文章: (1)Session机制详解及分布式中Session共享解决方案 (2)https://www.cnblogs.com/jing ...
- java异常处理机制详解
java异常处理机制详解 参考文章: (1)java异常处理机制详解 (2)https://www.cnblogs.com/vaejava/articles/6668809.html 备忘一下.
- SpringMVC异常处理机制详解[附带源码分析]
SpringMVC异常处理机制详解[附带源码分析] 参考文章: (1)SpringMVC异常处理机制详解[附带源码分析] (2)https://www.cnblogs.com/fangjian0423 ...
- 动态代理机制详解(JDK 和CGLIB,Javassist,ASM)
2019独角兽企业重金招聘Python工程师标准>>> 在运行时期可以按照Java虚拟机规范对class文件的组织规则生成对应的二进制字节码.当前有很多开源框架可以完成这些功能,如A ...
- JAVA之JVM垃圾回收(GC)机制详解
一.为什么需要垃圾回收 如果不进行垃圾回收,内存迟早都会被消耗空,因为我们在不断的分配内存空间而不进行回收.除非内存无限大,我们可以任性的分配而不回收,但是事实并非如此.所以,垃圾回收是必须的. 二. ...
最新文章
- 不懂编程可以自学python吗-我不会编程,也可能学会Python吗?
- pytorch常用函数API简析与汇总——以备查询
- Excellent Service
- SqlServe中使用EXEC @sql 来传递table变量
- 风之大陆电脑版要下载c语言,风之大陆电脑版
- 服务器搭建对讲机系统,世邦对讲配置步骤以及方法(支持跨服务器对讲).doc
- 数据库悲观锁和乐观锁
- 【opencv14】cv::Mat---Desne数组类
- php短信功能实现原理,基于信息熵原理分词的php实现
- html5动态连线,canvas简单连线动画的实现代码
- opencv需要安装mysql吗_OpenCV2.4.3的新特征以及安装方法
- 加速 SpringBoot 应用开发,官方热部署神器真带劲
- 离线语音芯片-开发指南
- Tesra平台训练数据(没有足够强大的显卡情况下使用云端跑代码)(一)
- 【python学习】Python开心消消乐实现过程基础1
- 极进网络将收购斑马技术的无线局域网业务并获蓝筹客户
- 新手小白怎么做shopee虾皮跨境?记住这三点不会被割“韭菜”
- unity3d实现第一人称射击游戏之CS反恐精英(一)(第一人称移动)
- 前端如何实现词云效果?
- 第四章 治病法要(2)