摘要:三中间件实现原理首先需要明确是中间件并不是中的概念,它只是和框架衍生的概念。中间件的执行流程主要由与函数决定依次取出中间件终止条件路由匹配规则函数中使用闭包函数来检测是否与当前路由相匹配,匹配则执行该上的中间件函数,否则继续检查下一个。
Koa作为下一代Web开发框架,不仅让我们体验到了async/await语法带来同步方式书写异步代码的酸爽,而且本身简洁的特点,更加利于开发者结合业务本身进行扩展。
本文从以下几个方面解读Koa源码:
封装创建应用程序函数
扩展res和req
中间件实现原理
异常处理
一、封装创建应用程序函数利用NodeJS可以很容易编写一个简单的应用程序:
const http = require("http") const server = http.createServer((req, res) => { // 每一次请求处理的方法 console.log(req.url) res.writeHead(200, { "Content-Type": "text/plain" }) res.end("Hello NodeJS") }) server.listen(8080)
注意:当浏览器发送请求时,会附带请求/favicon.ico。
而Koa在封装创建应用程序的方法中主要执行了以下流程:
组织中间件(监听请求之前)
生成context上下文对象
执行中间件
执行默认响应方法或者异常处理方法
// application.js listen(...args) { const server = http.createServer(this.callback()); return server.listen(...args); } callback() { // 组织中间件 const fn = compose(this.middleware); // 未监听异常处理,则采用默认的异常处理方法 if (!this.listenerCount("error")) this.on("error", this.onerror); const handleRequest = (req, res) => { // 生成context上下文对象 const ctx = this.createContext(req, res); return this.handleRequest(ctx, fn); }; return handleRequest; } handleRequest(ctx, fnMiddleware) { const res = ctx.res; // 默认状态码为404 res.statusCode = 404; // 中间件执行完毕之后 采用默认的 错误 与 成功 的处理方式 const onerror = err => ctx.onerror(err); const handleResponse = () => respond(ctx); onFinished(res, onerror); return fnMiddleware(ctx).then(handleResponse).catch(onerror); }二、扩展res和req
首先我们要知道NodeJS中的res和req是http.IncomingMessage和http.ServerResponse的实例,那么就可以在NodeJS中这样扩展req和res:
Object.defineProperties(http.IncomingMessage.prototype, { query: { get () { return querystring.parse(url.parse(this.url).query) } } }) Object.defineProperties(http.ServerResponse.prototype, { json: { value: function (obj) { if (typeof obj === "object") { obj = JSON.stringify(obj) } this.end(obj) } } })
而Koa中则是自定义request和response对象,然后保持对res和req的引用,最后通过getter和setter方法实现扩展。
// application.js createContext(req, res) { const context = Object.create(this.context); const request = context.request = Object.create(this.request); const response = context.response = Object.create(this.response); context.app = request.app = response.app = this; context.req = request.req = response.req = req; // 保存原生req对象 context.res = request.res = response.res = res; // 保存原生res对象 request.ctx = response.ctx = context; request.response = response; response.request = request; context.originalUrl = request.originalUrl = req.url; context.state = {}; // 最终返回完整的context上下文对象 return context; }
所以在Koa中要区别这两组对象:
request、response: Koa扩展的对象
res、req: NodeJS原生对象
// request.js get header() { return this.req.headers; }, set header(val) { this.req.headers = val; },
此时已经可以采用这样的方式访问header属性:
ctx.request.header
但是为了方便开发者调用这些属性和方法,Koa将response和request中的属性和方法代理到context上。
通过Object.defineProperty可以轻松的实现属性的代理:
function access (proto, target, name) { Object.defineProperty(proto, name, { get () { return target[name] }, set (value) { target[name] = value } }) } access(context, request, "header")
而对于方法的代理,则需要注意this的指向:
function method (proto, target, name) { proto[name] = function () { return target[name].apply(target, arguments) } }
上述就是属性代理和方法代理的核心代码,这基本算是一个常用的套路。
代理这部分详细的源码,可以查看node-delegates, 不过这个包时间久远,有一些老方法已经废除。
在上述过程的源码中涉及到很多JavaScript的基础知识,例如:原型继承、this的指向。对于基础薄弱的同学,还需要先弄懂这些基础知识。
三、中间件实现原理首先需要明确是:中间件并不是NodeJS中的概念,它只是connect、express和koa框架衍生的概念。
在connect中,开发者可以通过use方法注册中间件:
function use(route, fn) { var handle = fn; var path = route; // 不传入route则默认为"/",这种基本是框架处理参数的一种套路 if (typeof route !== "string") { handle = route; path = "/"; } ... // 存储中间件 this.stack.push({ route: path, handle: handle }); // 以便链式调用 return this; }
use方法内部获取到中间件的路由信息(默认为"/")和中间件的处理函数之后,构建成layer对象,然后将其存储在一个队列当中,也就是上述代码中的stack。
connect中间件的执行流程主要由handle与call函数决定:
function handle(req, res, out) { var index = 0; var stack = this.stack; ... function next(err) { ... // 依次取出中间件 var layer = stack[index++] // 终止条件 if (!layer) { defer(done, err); return; } var path = parseUrl(req).pathname || "/"; var route = layer.route; // 路由匹配规则 if (path.toLowerCase().substr(0, route.length) !== route.toLowerCase()) { return next(err); } ... call(layer.handle, route, err, req, res, next); } next(); }
handle函数中使用闭包函数next来检测layer是否与当前路由相匹配,匹配则执行该layer上的中间件函数,否则继续检查下一个layer。
这里需要注意next中检查路由的方式可能与想象中的不太一样,所以默认路由为"/"的中间件会在每一次请求处理中都执行。
function call(handle, route, err, req, res, next) { var arity = handle.length; var error = err; var hasError = Boolean(err); try { if (hasError && arity === 4) { // 错误处理中间件 handle(err, req, res, next); return; } else if (!hasError && arity < 4) { // 请求处理中间件 handle(req, res, next); return; } } catch (e) { // 记录错误 error = e; } // 将错误传递下去 next(error); }
在通过call方法执行中间件方法的时候,采用try/catch捕获错误,这里有一个特别需要注意的地方是,call内部会根据是否存在错误以及中间件函数的参数决定是否执行错误处理中间件。并且一旦捕获到错误,next方法会将错误传递下去,所以接下来普通的请求处理中间件即使通过了next中的路由匹配,仍然会被call方法给过滤掉。
下面是layer的处理流程图:
上述就是connect中间件设计的核心要点,总结起来有如下几点:
通过use方法注册中间件;
中间件的顺序执行是通过next方法衔接的并且需要手动调用,在next中会进行路由匹配,从而过滤掉部分中间件;
当中间件的执行过程中发生异常,则next会携带异常过滤掉非错误处理中间件,也是为什么错误中间件会比其他中间件多一个error参数;
在请求处理的周期中,需要手动调用res.end()来结束响应;
Koa中间件与connect中间件的设计有很大的差异:
Koa中间件的执行并不需要匹配路由,所以注册的中间件每一次请求都会执行。(当然还是需要手动调用next);
Koa中通过继承event,暴露error事件让开发者自定义异常处理;
Koa中res.end由中间件执行完成之后自动调用,这样避免在connect忘记调用res.end导致用户得不到任何反馈。
Koa中采用了async/await语法让开发者利用同步的方式编写异步代码。
当然,Koa中也是采用use方法注册中间件,相比较connect省去路由匹配的处理,就显得很简洁:
use(fn) { this.middleware.push(fn); return this; }
并且use支持链式调用。
Koa中间件的执行流程主要通过koa-compose中的compose函数完成:
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) { 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) } } } }
看到这里本质上connect与koa实现中间件的思想都是递归,不难看出koa相比较connect实现得更加简洁,主要原因在于:
connect中提供路由匹配的功能,而Koa中则是相当于connect中默认的"/"路径。
connect在捕获中间件的异常时,通过next携带error一个个中间件验证,直到错误处理中间件,而Koa中则是用Promise包装中间件,一旦中间件发生异常,那么会直接触发reject状态,直接在Promise的catch中处理就行。
上述就是connect中间件与Koa中间件的实现原理,现在在再看Koa中间件的这张执行流程图,应该没有什么疑问了吧?!
四、异常处理对于同步代码,通过try/catch可以轻松的捕获异常,在connect中间件的异常捕获则是通过try/catch完成。
对于异步代码,try/catch则无法捕获,这时候一般可以构造Promise链,在最后的catch方法中捕获错误,Koa就是这样处理,并且在catch方法中发送error事件,以便开发者自定义异常处理逻辑。
this.app.emit("error", err, this);
前面也谈到Koa利用async/await语法带来同步方式书写异步代码的酸爽,另外也让错误处理更加自然:
// 也可以这样自定义错误处理 app.use(async (ctx, next) => { try { await next(); } catch (err) { ctx.status = err.status || 500 ctx.body = err } })五、总结
相信看到这里,再回忆一下之前遇到的那些问题,你应该会有新的理解,并且再次使用Koa时会更加得心应手,这也是分析Koa源码的目的之一。
文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。
转载请注明本文地址:https://www.ucloud.cn/yun/100520.html
摘要:主要通过处理二进制数据流,但是它并不支持字符编码方式,需要通过模块进行处理。最后留图一张往期精彩回顾玩转原理解析玩转核心原理分析 一、前置知识 在理解koa-bodyparser原理之前,首先需要了解部分HTTP相关的知识。 1、报文主体 HTTP报文主要分为请求报文和响应报文,koa-bodyparser主要针对请求报文的处理。 请求报文主要由以下三个部分组成: 报文头...
摘要:搭建一个的脚手架并不困难,但就如其他体力活一样,我们并不想重复劳动其他脚手架生成出来的项目目录结构可能并不是我们想要的一些基于和类型的框架型项目集成了等重量级组件,当然,这本身无可厚非,大家的定位不一样我希望只通过一个最小化的容器去 Github Repo: https://github.com/qddegtya/let-us-koa showImg(https://segmentfa...
摘要:四路由注册构造函数首先看了解一下构造函数限制必须采用关键字服务器支持的请求方法,后续方法会用到保存前置处理函数存储在构造函数中初始化的和属性最为重要,前者用来保存前置处理函数,后者用来保存实例化的对象。 一、前言 Koa为了保持自身的简洁,并没有捆绑中间件。但是在实际的开发中,我们需要和形形色色的中间件打交道,本文将要分析的是经常用到的路由中间件 -- koa-router。 ...
摘要:感谢大神的免费的计算机编程类中文书籍收录并推荐地址,以后在仓库里更新地址,声音版全文狼叔如何正确的学习简介现在,越来越多的科技公司和开发者开始使用开发各种应用。 说明 2017-12-14 我发了一篇文章《没用过Node.js,就别瞎逼逼》是因为有人在知乎上黑Node.js。那篇文章的反响还是相当不错的,甚至连著名的hax贺老都很认同,下班时读那篇文章,竟然坐车的还坐过站了。大家可以很...
摘要:感谢大神的免费的计算机编程类中文书籍收录并推荐地址,以后在仓库里更新地址,声音版全文狼叔如何正确的学习简介现在,越来越多的科技公司和开发者开始使用开发各种应用。 说明 2017-12-14 我发了一篇文章《没用过Node.js,就别瞎逼逼》是因为有人在知乎上黑Node.js。那篇文章的反响还是相当不错的,甚至连著名的hax贺老都很认同,下班时读那篇文章,竟然坐车的还坐过站了。大家可以很...
阅读 3003·2021-11-11 16:55
阅读 3114·2021-10-18 13:34
阅读 564·2021-10-14 09:42
阅读 1606·2021-09-03 10:30
阅读 808·2021-08-05 10:02
阅读 927·2019-08-30 11:27
阅读 3454·2019-08-29 15:14
阅读 1207·2019-08-29 13:02