01-event-1.js

  1. const http = require("http");
  2. let request = {
  3.     get url() {
  4.         return this.req.url;
  5.     },
  6. };
  7. let response = {
  8.     get body() {
  9.         return this._body;
  10.     },
  11.     set body(val) {
  12.         this._body = val;
  13.     },
  14. };
  16. let context = {
  17.     get url() {
  18.         return this.request.url;
  19.     },
  20.     get body() {
  21.         return this.response.body;
  22.     },
  23.     set body(val) {
  24.         this.response.body = val;
  25.     },
  26. };
  27. class Application {
  28.     constructor() {
  29.         // this.callback = () => {}
  30.         this.context = context;
  31.         this.request = request;
  32.         this.response = response;
  33.         this.middlewares = [];
  34.     }
  35.     use(callback) {
  36.         this.middlewares.push(callback);
  37.         // this.callback = callback;
  38.     }
  39.     compose(middlewares) {
  40.         return function (context) {
  41.             return dispatch(0);
  43.             function dispatch(i) {
  44.                 let fn = middlewares[i];
  45.                 if (!fn) {
  46.                     return Promise.resolve();
  47.                 }
  48.                 return Promise.resolve(
  49.                     fn(context, function next() {
  50.                         return dispatch(i + 1);
  51.                     })
  52.                 );
  53.             }
  54.         };
  55.     }
  56.     listen(...args) {
  57.         const server = http.createServer(async (req, res) => {
  58.             let ctx = this.createCtx(req, res);
  59.             // await this.callback(ctx);
  60.             const fn = this.compose(this.middlewares);
  61.             await fn(ctx);
  62.             ctx.res.end(ctx.body);
  63.             // this.callback(req, res);
  64.         });
  65.         server.listen(...args);
  66.     }
  67.     createCtx(req, res) {
  68.         let ctx = Object.create(this.context);
  69.         ctx.request = Object.create(this.request);
  70.         ctx.response = Object.create(this.response);
  71.         ctx.req = ctx.request.req = req;
  72.         ctx.res = ctx.response.res = res;
  73.         return ctx;
  74.     }
  75. }
  77. module.exports = Application;

02-stream-1.js

  1. var fs = require("fs");
  2. var readStream = fs.createReadStream("./data/file1.txt"); // 读取文件的 Stream
  4. var length = 0;
  5. readStream.on("data", function (chunk) {
  6.     length += chunk.toString().length;
  7. });
  8. readStream.on("end", function () {
  9.     console.log(length);
  10. });

02-stream-2.js

  1. var readline = require("readline");
  2. var fs = require("fs");
  4. var rl = readline.createInterface({
  5.     input: fs.createReadStream("./data/file1.txt"),
  6. });
  8. var lineNum = 0;
  9. rl.on("line", function (line) {
  10.     lineNum++;
  11. });
  12. rl.on("close", function () {
  13.     console.log("lineNum", lineNum);
  14. });

02-stream-3.js

  1. var http = require("http");
  3. function serverCallback(req, res) {
  4.     var method = req.method.toLowerCase(); // 获取请求的方法
  5.     if (method === "get") {
  6.     }
  7.     if (method === "post") {
  8.         // 接收 post 请求的内容
  9.         var data = "";
  10.         req.on("data", function (chunk) {
  11.             // “一点一点”接收内容
  12.             console.log("chunk", chunk.toString());
  13.             data += chunk.toString();
  14.         });
  15.         req.on("end", function () {
  16.             // 接收完毕，将内容输出
  17.             console.log("end");
  18.             res.writeHead(200, { "Content-type": "text/html" });
  19.             res.write(data);
  20.             res.end();
  21.         });
  22.     }
  23. }
  24. http.createServer(serverCallback).listen(8081); // 注意端口别和其他 server 的冲突
  25. console.log("监听 8081 端口……");

03-genarator-1.js

  1. function* helloWorldGenerator() {
  2.     yield "hello";
  3.     yield "world";
  4.     return "ending";
  5. }
  7. var hw = helloWorldGenerator();
  8. console.log(hw.next());
  9. console.log(hw.next());
  10. console.log(hw.next());
  11. console.log(hw.next());
  13. function* foo() {
  14.     yield 1;
  15.     yield 2;
  16.     yield 3;
  17.     yield 4;
  18.     yield 5;
  19.     return 6;
  20. }
  22. for (let v of foo()) {
  23.     console.log(v);
  24. }

application.js

  1. const http = require("http");
  2. let request = {
  3.     get url() {
  4.         return this.req.url;
  5.     },
  6. };
  7. let response = {
  8.     get body() {
  9.         return this._body;
  10.     },
  11.     set body(val) {
  12.         this._body = val;
  13.     },
  14. };
  16. let context = {
  17.     get url() {
  18.         return this.request.url;
  19.     },
  20.     get body() {
  21.         return this.response.body;
  22.     },
  23.     set body(val) {
  24.         this.response.body = val;
  25.     },
  26. };
  27. class Application {
  28.     constructor() {
  29.         // this.callback = () => {}
  30.         this.context = context;
  31.         this.request = request;
  32.         this.response = response;
  33.         this.middlewares = [];
  34.     }
  35.     use(callback) {
  36.         this.middlewares.push(callback);
  37.         // this.callback = callback;
  38.     }
  39.     compose(middlewares) {
  40.         return function (context) {
  41.             return dispatch(0);
  43.             function dispatch(i) {
  44.                 let fn = middlewares[i];
  45.                 if (!fn) {
  46.                     return Promise.resolve();
  47.                 }
  48.                 return Promise.resolve(
  49.                     fn(context, function next() {
  50.                         return dispatch(i + 1);
  51.                     })
  52.                 );
  53.             }
  54.         };
  55.     }
  56.     listen(...args) {
  57.         const server = http.createServer(async (req, res) => {
  58.             let ctx = this.createCtx(req, res);
  59.             // await this.callback(ctx);
  60.             const fn = this.compose(this.middlewares);
  61.             await fn(ctx);
  62.             ctx.res.end(ctx.body);
  63.             // this.callback(req, res);
  64.         });
  65.         server.listen(...args);
  66.     }
  67.     createCtx(req, res) {
  68.         let ctx = Object.create(this.context);
  69.         ctx.request = Object.create(this.request);
  70.         ctx.response = Object.create(this.response);
  71.         ctx.req = ctx.request.req = req;
  72.         ctx.res = ctx.response.res = res;
  73.         return ctx;
  74.     }
  75. }
  77. module.exports = Application;

server.js

  1. // const http = require("http");
  3. // const server = http.createServer((req, res) => {
  4. //     res.writeHead(200);
  5. //     res.end("Hello WuChenDi");
  6. // });
  8. // server.listen(9092, () => {
  9. //     console.log("server start on port 9092");
  10. // });
  12. const Dia = require("./application");
  13. const app = new Dia();
  15. function delay() {
  16.     return new Promise((reslove, reject) => {
  17.         setTimeout(() => {
  18.             reslove();
  19.         }, 2000);
  20.     });
  21. }
  23. app.use(async (ctx, next) => {
  24.     ctx.body = "1";
  25.     await next();
  26.     ctx.body += "2";
  27. });
  28. app.use(async (ctx, next) => {
  29.     ctx.body += "3";
  30.     await delay();
  31.     await next();
  32.     ctx.body += "4";
  33. });
  34. app.use(async (ctx, next) => {
  35.     ctx.body += "5";
  36. });
  37. // app.use((req, res) => {
  38. //     res.writeHead(200);
  39. //     res.end("Hello WuChenDi");
  40. // });
  42. app.listen(9092, () => {
  43.     console.log("server runing on port 9092");
  44. });

test.js

  1. // let digot = {
  2. //     _name: "Di-got",
  3. //     get name() {
  4. //         // console.log('value')
  5. //         // return '你好'
  6. //         return this._name;
  7. //     },
  8. //     set name(val) {
  9. //         console.log("new name is " + val);
  10. //         this._name = val;
  11. //     },
  12. // };
  14. // console.log(digot.name);
  15. // digot.name = "wuchendi";
  16. // console.log(digot.name);
  18. // function add(x, y) {
  19. //     return x + y;
  20. // }
  22. // function double(z) {
  23. //     return z * 2;
  24. // }
  25. // const res1 = add(1, 2);
  26. // const res2 = double(res1);
  27. // console.log(res2);
  29. // const res3 = double(add(1, 2));
  30. // console.log(res3);
  32. // function add(x, y) {
  33. //     return x + y;
  34. // }
  36. // function double(z) {
  37. //     return z * 2;
  38. // }
  39. // const middlewares = [add, double];
  40. // let len = middlewares.length;
  42. // function compose(midds) {
  43. //     return (...args) => {
  44. //         // 初始值
  45. //         let res = midds[0](...args);
  46. //         for (let i = 1; i < len; i++) {
  47. //             res = midds[i](res);
  48. //         }
  49. //         return res;
  50. //     };
  51. // }
  52. // const fn = compose(middlewares);
  53. // const res = fn(1, 2);
  54. // console.log(res);
  56. async function fn1(next) {
  57.     console.log("fn1");
  58.     await next();
  59.     console.log("end fn1");
  60. }
  62. async function fn2(next) {
  63.     console.log("fn2");
  64.     await delay();
  65.     await next();
  66.     console.log("end fn2");
  67. }
  69. async function fn3(next) {
  70.     console.log("fn3");
  71. }
  73. function delay() {
  74.     return new Promise((reslove, reject) => {
  75.         setTimeout(() => {
  76.             reslove();
  77.         }, 2000);
  78.     });
  79. }
  81. function compose(middlewares) {
  82.     return function () {
  83.         return dispatch(0);
  85.         function dispatch(i) {
  86.             let fn = middlewares[i];
  87.             if (!fn) {
  88.                 return Promise.resolve();
  89.             }
  90.             return Promise.resolve(
  91.                 fn(function next() {
  92.                     return dispatch(i + 1);
  93.                 })
  94.             );
  95.         }
  96.     };
  97. }
  99. const middlewares = [fn1, fn2, fn3];
  100. const finalFn = compose(middlewares);
  101. finalFn();