电子商务网站建设评估工具,网页设计尺寸怎么设计,嘉兴网站建设999 999,微软雅黑做网站上上节实现了上下文的#xff0c;上一节使用了一下中间件#xff0c;这一节来实现 koa 的中间件这个洋葱模型。
思路#xff1a;
储存用户所有的 callback将用户传递的 callback 全部组合起来#xff08;redux 里的 compose#xff09;组合成一个线性结构依次执行#…上上节实现了上下文的上一节使用了一下中间件这一节来实现 koa 的中间件这个洋葱模型。
思路
储存用户所有的 callback将用户传递的 callback 全部组合起来redux 里的 compose组合成一个线性结构依次执行组合完返回一个大的 promise当组合后的 promise 完成后拿到最终的结果响应回去
application.js 代码实现如下核心就是组合方法的实现
const EventEmitter require(events);
const http require(http);
const context require(./context);
const request require(./request);
const response require(./response);console.log(kaimo-koa----);class Application extends EventEmitter {constructor() {super();// 防止多个实例共享 context request response 需要进行拷贝this.context Object.create(context);this.request Object.create(request);this.response Object.create(response);// 储存用户所有的 callbackthis.middlewares [];}use(callback) {// 将用户传递的 callback 全部组合起来this.middlewares.push(callback);}// 创建一个上下文createContext(req, res) {// 每次请求都应该是一个全新的 context需要拷贝let ctx Object.create(this.context);// 上下文中有一个 request 对象是自己封装的ctx.request Object.create(this.request);// 上下文中还有一个 req 属性 指代的是原生的 req自己封装的 request 对象上有 req 属性ctx.req ctx.request.req req;// 上下文中还有一个 response 对象是自己封装的ctx.response Object.create(this.response);// 上下文中还有一个 res 属性 指代的是原生的 res自己封装的 response 对象上有 res 属性ctx.res ctx.response.res res;return ctx;}compose(ctx) {// 在数组中取出第一个第一个执行后执行第二个const dispatch (i) {if (i this.middlewares.length) return Promise.resolve();let middleware this.middlewares[i];// 中间件如果不是 async 需要 Promise 包装一下() dispatch(i 1) 就是 nextreturn Promise.resolve(middleware(ctx, () dispatch(i 1)));};return dispatch(0);}async handleRequest(req, res) {const ctx this.createContext(req, res);// 组合成一个线性结构依次执行组合完返回一个大的 promiseawait this.compose(ctx);// 当组合后的 promise 完成后拿到最终的结果响应回去let body ctx.body;res.end(body);}listen(...args) {const server http.createServer(this.handleRequest.bind(this));server.listen(...args);}
}module.exports Application;然后我们编写测试 demo.js
const Koa require(./kaimo-koa);const app new Koa();const log () {return new Promise((resolve, reject) {setTimeout(() {console.log(kaimo313);resolve();}, 3000);});
};app.use(async (ctx, next) {console.log(1);console.time(kaimo);await next();ctx.body hello 1;console.log(2);console.timeEnd(kaimo);
});app.use(async (ctx, next) {console.log(3);await log();ctx.body hello 2;await next();console.log(4);
});app.use(async (ctx, next) {console.log(5);ctx.body hello 3;await next();console.log(6);
});app.listen(3000);启动服务访问 http://localhost:3000/
nodemon demo.js
