koa——中间件机制中的http.createServer(app.callback())

商德泽
2023-12-01

中间件机制

使用koa创建一个基本的 http server

const Koa = require('koa');
const http = require('http');
const app = new Koa();
// Create HTTP server.
const server = http.createServer(app.callback());

有点不太理解http.createServer(app.callback())中的app.callback(),通过搜索查找发现是koa中封装好的一个函数

app.callback就是作为原生nodejs的callback来接收事件,我们都知道它将有两个参数 req 和 res

具体封装方式:

app.callback = function () {
    var fn = this.experimental
        ? compose_es7(this.middleware)
        : co.wrap(compose(this.middleware));
    var self = this;

    if (!this.listeners('error').length) this.on('error', this.onerror);

    return function (req, res) {
        res.statusCode = 404; //----- 入口
        var ctx = self.createContext(req, res); // ---- 封装req,res在this上
        onFinished(res, ctx.onerror); // ---绑定结束方法
        fn.call(ctx).then(function () { // 以 ctx 为 this 执行fn , 见下文
            respond.call(ctx);
        }).catch(ctx.onerror);
    }
};

其中,fn.call(ctx)是所有中间件执行的地方

var fn = this.experimental
        ? compose_es7(this.middleware)
        : co.wrap(compose(this.middleware));
//在非es7环境下,fn被co.wrap包裹,说明 compose(this.middleware) 将会返回一个generator.
//从里到外分解 
//this.middleware 在application的构造函数里面我们看到他就是一个数组。数组里面的内容是什么呢,在express里面我们知道,app.use就是增加一个中间件。我们看看koa的app.use

app.use

app.use = function (fn) {
    if (!this.experimental) {
        // es7 async functions are allowed
        assert(fn && 'GeneratorFunction' == fn.constructor.name, 'app.use() requires a generator function');
    }
    debug('use %s', fn._name || fn.name || '-');
    this.middleware.push(fn);
    return this;
};

参考链接:http://liyangready.github.io/2016/01/16/koa%E5%86%85%E9%83%A8%E8%A7%A3%E5%AF%86/

 类似资料: