博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Express 与 koa 中间件模式对比
阅读量:6266 次
发布时间:2019-06-22

本文共 4172 字,大约阅读时间需要 13 分钟。

起因

最近在学习koa的使用, 由于koa是相当基础的web框架,所以一个完整的web应用所需要的东西大都以中间件的形式引入,比如koa-router, koa-view等。在koa的文档里有提到:koa的中间件模式与express的是不一样的,koa是洋葱型,express是直线型,至于为什么这样,网上很多文章并没有具体分析。或者简单的说是async/await的特性之类。先不说这种说法的对错,对于我来说这种说法还是太模糊了。所以我决定通过源码来分析二者中间件实现的原理以及用法的异同。

为了简单起见这里的express用connect代替(实现原理是一致的)

用法

二者都以官网(github)文档为准

connect

下面是官网的用法:

var connect = require('connect');var http = require('http');var app = connect();// gzip/deflate outgoing responsesvar compression = require('compression');app.use(compression());// store session state in browser cookievar cookieSession = require('cookie-session');app.use(cookieSession({    keys: ['secret1', 'secret2']}));// parse urlencoded request bodies into req.bodyvar bodyParser = require('body-parser');app.use(bodyParser.urlencoded({
extended: false}));// respond to all requestsapp.use(function(req, res){ res.end('Hello from Connect!\n');});//create node.js http server and listen on porthttp.createServer(app).listen(3000);复制代码

根据文档我们可以看到,connect是提供简单的路由功能的:

app.use('/foo', function fooMiddleware(req, res, next) {  // req.url starts with "/foo"  next();});app.use('/bar', function barMiddleware(req, res, next) {  // req.url starts with "/bar"  next();});复制代码

connect的中间件是线性的,next过后继续寻找下一个中间件,这种模式直觉上也很好理解,中间件就是一系列数组,通过路由匹配来寻找相应路由的处理方法也就是中间件。事实上connect也是这么实现的。

app.use就是往中间件数组中塞入新的中间件。中间件的执行则依靠私有方法app.handle进行处理,express也是相同的道理。

koa

相对connect,koa的中间件模式就不那么直观了,借用网上的图表示:

koa

也就是koa处理完中间件后还会回来走一趟,这就给了我们更加大的操作空间,来看看koa的官网实例:

const Koa = require('koa');const app = new Koa();// x-response-timeapp.use(async (ctx, next) => {  const start = Date.now();  await next();  const ms = Date.now() - start;  ctx.set('X-Response-Time', `${ms}ms`);});// loggerapp.use(async (ctx, next) => {  const start = Date.now();  await next();  const ms = Date.now() - start;  console.log(`${ctx.method} ${ctx.url} - ${ms}`);});// responseapp.use(async ctx => {  ctx.body = 'Hello World';});app.listen(3000);复制代码

很明显,当koa处理中间件遇到await next()的时候会暂停当前中间件进而处理下一个中间件,最后再回过头来继续处理剩下的任务,虽然说起来很复杂,但是直觉上我们会有一种隐隐熟悉的感觉:不就是回调函数吗。这里暂且不说具体实现方法,但是确实就是回调函数。跟async/await的特性并无任何关系。

源码简析

connect与koa中间件模式区别的核心就在于next的实现,让我们简单看下二者next的实现。

connect

connect的源码相当少加上注释也就200来行,看起来也很清楚,connect中间件处理在于proto.handle这个私有方法,同样next也是在这里实现的

// 中间件索引var index = 0function next(err) {    // 递增    var layer = stack[index++];    // 交由其他部分处理    if (!layer) {      defer(done, err);      return;    }    // route data    var path = parseUrl(req).pathname || '/';    var route = layer.route;    // 递归    // skip this layer if the route doesn't match    if (path.toLowerCase().substr(0, route.length) !== route.toLowerCase()) {      return next(err);    }    // call the layer handle    call(layer.handle, route, err, req, res, next);  }复制代码

删掉混淆的代码后 我们可以看到next实现也很简洁。一个递归调用顺序寻找中间件。不断的调用next。代码相当简单但是思路却很值得学习。

其中done是第三方处理方法。其他处理sub app以及路由的部分都删除了。不是重点

koa

koa将next的实现抽离成了一个单独的包,代码更加简单,但是实现了一个貌似更加复杂的功能

function compose (middleware) {  return function (context, next) {    // last called middleware #    let index = -1    return dispatch(0)    function dispatch (i) {      index = i      try {        return Promise.resolve(fn(context, function next () {          return dispatch(i + 1)        }))      } catch (err) {        return Promise.reject(err)      }    }  }}复制代码

看着上面处理过的的代码 有些同学可能还是会不明觉厉。

那么我们继续处理一下:

function compose (middleware) {  return function (context, next) {    // last called middleware #    let index = -1    return dispatch(0)    function dispatch (i) {      index = i      let fn = middleware[i]      if (i === middleware.length) {        fn = next      }      if (!fn) return      return fn(context, function next () {        return dispatch(i + 1)      })    }  }}复制代码

这样一来 程序更加简单了 跟async/await也没有任何关系了,让我们看下结果好了

var ms = [  function foo (ctx, next) {    console.log('foo1')    next()    console.log('foo2')  },  function bar (ctx, next) {    console.log('bar1')    next()    console.log('bar2')  },  function qux (ctx, next) {    console.log('qux1')    next()    console.log('qux2')  }]compose(ms)()复制代码

执行上面的程序我们可以发现依次输出:

foo1bar1qux1qux2bar2foo2复制代码

同样是所谓koa的洋葱模型,到这里我们就可以得出这样一个结论:koa的中间件模型跟async或者generator并没有实际联系,只是koa强调async优先。所谓中间件暂停也只是回调函数的原因。

如有错误,希望不吝指出。

over。

转载地址:http://wgdpa.baihongyu.com/

你可能感兴趣的文章
python自动化开发-1
查看>>
Remote远程特性的使用
查看>>
orm在django中的简单使用
查看>>
poj 2373 Dividing the Path
查看>>
dplyr 数据操作 常用函数(4)
查看>>
A股实时股票行情,指数行情web API 使用方法
查看>>
大整数算法[04] 位操作
查看>>
C# Parsing 类实现的 PDF 文件分析器
查看>>
汇编学习(1)
查看>>
Google招聘 Lead Software Engineer
查看>>
Bzoj1026 windy数
查看>>
Java07
查看>>
mongodb基础知识_4
查看>>
ROP
查看>>
Windows常用网络命令技巧汇总 [转]
查看>>
【noi 2.6_8787】数的划分(DP){附【转】整数划分的解题方法}
查看>>
Win8 app判断网络连接状态
查看>>
CentOS 6.7下nginx SSL证书部署的方法分享
查看>>
菜鸟学SQLServer--数据文件和日志文件
查看>>
分享我积攒的测试相关的资料收集awesome-test
查看>>