feat: koa

Author: 刘正锟

base/25koa/package-lock.json

@@ -0,0 +1,22 @@
+{
+  "name": "25koa",
+  "version": "1.0.0",
+  "description": "",
+  "main": "index.js",
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "keywords": [],
+  "author": "",
+  "license": "ISC",
+  "dependencies": {
+    "ejs": "^3.1.3",
+    "koa": "^2.13.0",
+    "koa-better-body": "^3.3.9",
+    "koa-bodyparser": "^4.3.0",
+    "koa-router": "^9.1.0",
+    "koa-session": "^6.0.0",
+    "koa-static": "^5.0.0",
+    "koa-views": "^6.3.0"
+  }
+}

base/25koa/package.json

@@ -0,0 +1,24 @@
+const Koa = require("koa");
+const app = new Koa();
+
+app.use(async (ctx, next) => {
+  console.log(ctx.url);
+  if (ctx.url == "/write") {
+    ctx.cookies.set("name", "zfpx");
+    ctx.body = "write";
+  } else {
+    next();
+  }
+});
+app.use(async (ctx) => {
+  if (ctx.url == "/read") {
+    ctx.body = ctx.cookies.get("name");
+  }
+});
+
+app.on("error", (err) => {
+  log.error("server error", err);
+});
+app.listen(3000, () => {
+  console.log("服务启动在3000端口");
+});

base/25koa/src/cookie.js

@@ -0,0 +1,15 @@
+const Koa = require("koa");
+const views = require("koa-views");
+const path = require("path");
+const app = new Koa();
+app.use(
+  views(path.join(__dirname, "./views"), {
+    extension: "ejs",
+  })
+);
+app.use(async (ctx) => {
+  await ctx.render("index", { name: "维基百科" });
+});
+app.listen(3000, () => {
+  console.log("server is starting at port 3000");
+});

base/25koa/src/ejs.js

@@ -0,0 +1,81 @@
+const Koa = require('koa');
+const views = require('koa-views');
+const fs = require('fs');
+let querystring = require('querystring');
+let path = require('path');
+let uuid = require('uuid');
+const app = new Koa();
+app.use(async (ctx, next) => {
+ if (ctx.method == 'GET') {
+ ctx.set('Content-Type', 'text/html;charset=utf8');
+ ctx.body = (
+ `
+ <form id="userform" method="POST" enctype="multipa
+ 用户名:<input type="text" name="username">
+密码<input type="text" name="password">
+头像<input type="file" name="avatar">
+ <input type="submit">
+ </form>
+ `
+ );
+ } else if (ctx.method == 'POST') {
+ let buffers = [];
+ ctx.req.on('data', function (data) {
+ buffers.push(data);
+ });
+ ctx.req.on('end', function () {
+ let result = Buffer.concat(buffers);
+ let type = ctx.headers['content-type'];
+ let matched = type.match(/\bboundary=(.+)\b/);
+ if (matched) {
+ let seperator = '--' + matched[1];
+ let body = process(seperator, result);
+ ctx.body = body;
+ } else {
+ next();
+ }
+ });
+ ctx.body = 'hello';
+ } else {
+ next();
+ }
+});
+app.listen(3000);
+Buffer.prototype.split = Buffer.prototype.split || function (sep)
+ let len = Buffer.byteLength(sep);
+ let parts = [];
+ let offset = 0;
+ let pos = -1;
+ while (-1 != (pos = this.indexOf(sep, offset))) {
+ parts.push(this.slice(offset, pos));
+ offset = pos + len;
+ }
+ parts.push(this.slice(offset));
+ return parts;
+}
+function process(seperator, result) {
+ let lines = result.split(seperator);
+ lines = lines.slice(1, -1);
+ let body = {};
+ let files = [];
+ lines.forEach(function (line) {
+ let [desc, val] = line.split('\r\n\r\n');
+ desc = desc.toString();
+ val = val.slice(0, -2);
+ if (desc.includes('filename')) {//如果是文件的话
+ let [, line1, line2] = desc.split('\r\n');
+ let obj1 = querystring.parse(line1, '; ');
+ let obj2 = querystring.parse(line2, '; ');
+ let filepath = path.join(__dirname, 'uploads', uuid.v4
+ fs.writeFileSync(filepath, val);
+ files.push({
+ ...obj1, filepath
+ });
+ } else {
+ let matched = desc.match(/\bname=(.+)\b/);
+ if (matched)
+ body[matched[1]] = val.toString();
+ }
+ });
+ return { body, files };
+}

base/25koa/src/form.js

@@ -0,0 +1,44 @@
+const Koa = require("koa");
+const app = new Koa();
+
+app.use(async (ctx, next) => {
+  console.log('ctx: ', ctx);
+  console.log(1);
+  const start = Date.now();
+  await next();
+  const ms = Date.now() - start;
+  ctx.set("X-Response-Time", `${ms}ms`);
+  console.log(11);
+});
+// logger
+app.use(async (ctx, next) => {
+  console.log(2);
+
+  const start = Date.now();
+  await next();
+  const ms = Date.now() - start;
+  console.log(`${ctx.method} ${ctx.url} - ${ms}`);
+  console.log(22);
+});
+// response
+app.use(async (ctx) => {
+  console.log(3);
+
+  ctx.body = "Hello World";
+  console.log(33);
+});
+app.on("error", (err) => {
+  log.error("server error", err);
+});
+app.listen(3000, () => {
+  console.log("服务启动在3000端口");
+});
+/**
+ * 1
+2
+3
+33
+11
+GET / - 3
+22
+ */

base/25koa/src/index.js

@@ -0,0 +1,13 @@
+const Koa = require("koa");
+const app = new Koa();
+app.use(async (ctx) => {
+  console.log(ctx.method); //获取请求方法
+  console.log(ctx.url); //获取请求URL
+  console.log(ctx.query); //获取解析的查询字符串对象
+  console.log(ctx.querystring); //根据 ? 获取原始查询字符串.
+  console.log(ctx.headers); //获取请求头对象
+  ctx.body = ctx.url;
+});
+app.listen(3000, () => {
+  console.log("server is starting at port 3000");
+});

base/25koa/src/index2.js

@@ -0,0 +1,38 @@
+const Koa = require("koa");
+const querystring = require("querystring");
+const app = new Koa();
+app.use(async (ctx) => {
+  if (ctx.method == "GET") {
+    ctx.set("Content-Type", "text/html;charset=utf-8");
+    ctx.body = `
+ <form method="POST">
+ <input name="username" >
+ <input type="submit">
+ </form>
+ `;
+  } else if (ctx.method == "POST") {
+    ctx.set("Content-Type", "application/json");
+    ctx.body = await parseBody(ctx);
+  } else {
+    ctx.body = "Not Allowed";
+  }
+});
+function parseBody(ctx) {
+  return new Promise(function (resolve, reject) {
+    let buffers = [];
+    ctx.req.on("data", function (data) {
+      buffers.push(data);
+    });
+    ctx.req.on("end", function (data) {
+      let body = buffers.toString();
+      body = querystring.parse(body);
+      resolve(body);
+    });
+    ctx.req.on("error", function (errdata) {
+      reject(err);
+    });
+  });
+}
+app.listen(3000, () => {
+  console.log("server is starting at port 3000");
+});

base/25koa/src/index3.js

@@ -0,0 +1,25 @@
+const Koa = require("koa");
+const querystring = require("querystring");
+const bodyParser = require("koa-bodyparser");
+const app = new Koa();
+app.use(bodyParser());
+app.use(async (ctx) => {
+  if (ctx.method == "GET") {
+    ctx.set("Content-Type", "text/html;charset=utf-8");
+    ctx.body = `
+ <form method="POST">
+ <input name="username" >
+ <input type="submit">
+ </form>
+ `;
+  } else if (ctx.method == "POST") {
+    ctx.set("Content-Type", "application/json");
+    console.log("ctx.request.body: ", ctx.request.body);
+    ctx.body = ctx.request.body;
+  } else {
+    ctx.body = "Not Allowed";
+  }
+});
+app.listen(3000, () => {
+  console.log("server is starting at port 3000");
+});

base/25koa/src/index4.js

@@ -0,0 +1,36 @@
+const Koa = require("koa");
+const querystring = require("querystring");
+const path = require("path");
+const convert = require("koa-convert");
+const bodyParser = require("koa-better-body");
+const app = new Koa();
+app.use(
+  convert(
+    bodyParser({
+      uploadDir: path.join(__dirname, "uploads"),
+      keepExtensions: true,
+    })
+  )
+);
+app.use(async (ctx) => {
+  if (ctx.method == "GET") {
+    ctx.set("Content-Type", "text/html;charset=utf-8");
+    ctx.body = `
+ <form method="POST" enctype="multipart/form-data">
+ <input name="username" >
+ <input name="avatar" type="file" >
+ <input type="submit">
+ </form>
+ `;
+  } else if (ctx.method == "POST") {
+    ctx.set("Content-Type", "application/json");
+    console.log(ctx.request.fields);
+    const { username, avatar } = ctx.request.fields;
+    ctx.body = { username, img: avatar[0].path };
+  } else {
+    ctx.body = "Not Allowed";
+  }
+});
+app.listen(3000, () => {
+  console.log("server is starting at port 3000");
+});