'use strict';const routerUrl = 'router'; // 當(dāng)前目錄下的router地址const Router = require('./net/Router'); // 初始化路由const net = require('net');const port = '3000';Router.init(routerUrl);const app = sock => {  sock.on('data', function (data) {    try {      Router.request(data, sock);    } catch (error) {      console.log(error)    }  });  sock.on('error', (err) => {    console.log(err)  })  // 為這個(gè)socket實(shí)例添加一個(gè)"close"事件處理函數(shù)  sock.on('close', function (data) {    console.log('clone')  })}const server = net.createServer(app);server.listen(port, () => {  console.log(`Startu in env ${process.env.NODE_ENV || 'development'} on port ${port}`);});server.on('error', (err) => {  console.log(err)})

const fs = require('fs');const _ = require('lodash');var path = require("path");var ROOT_PATH = path.resolve(__dirname);class Router {  constructor() {    this.routeMap = {};  }  /**   * 通過(guò)routerUrl來(lái)匹配目錄下的文件，加載進(jìn)來(lái)   * @param {*} routerUrl   */  init(routerUrl) {    let files = fs.readdirSync(path.join(ROOT_PATH, `../${routerUrl}`));    return _.reduce(files, (config, file) => {      let svc = require(path.join(ROOT_PATH, `../${routerUrl}/${file}`));      this.routeMap = {        [file.split('.')[0]]: svc.get()      };    }, {})  }  /**   * 通過(guò)url匹配加載的router， 其他字段可自定義，url這里的邏輯也可改成配置文件進(jìn)行配置，類似于protobuf   * @param {*} data {url, body}   * @param {*} sock   */  request(data, sock) {    try {      this.routeMap[result.url.split('/')[1]][result.url.replace(`/${result.url.split('/')[1]}`, '')](data, sock);    } catch (error) {      sock.write(error);    }  }}module.exports = new Router();

const Next = require('./next');class Register {  constructor() {    this._init = {};  }  <!-- 初始化router函數(shù)，開始運(yùn)行函數(shù)鏈 -->  set(url, ...handlers) {    this._init[url] = async (data, sock) => {      try {        let next = new Next(handlers);        next.run(data, sock);        } catch (error) {        sock.write(error);      }    };  }  <!-- 獲取初始化的router函數(shù) -->  get() {    return this._init;  }}module.exports = new Register();

class Next {  constructor(stack) {    this.index = 0;    this.stack = stack;    this.data = null;    this.sock = null;  }  <!-- 運(yùn)行中間件 -->  run(data, sock) {    this.data = data;    this.sock = sock;    this.stack[this.index](data, sock, this.next.bind(this));  }  <!-- 調(diào)到下一個(gè)中間件，若帶參數(shù)就跳到第arguments[0]步 -->  next() {    if (arguments[0] && arguments[0] === +arguments[0] && +arguments[0] < this.stack.length) {      this.index = +arguments[0];      return this.run(data, this.sock);    }    this.index++;    this.run(this.data, this.sock);  }}module.exports = Next;

const init = require('../net/register');init.set('/test',  (data, sock, next) => {    next()  },  async (data, sock) => {    try {      sock.write(test);    } catch (e) {      sock.write(e);    }  });