美文网首页周分享
手把手做一个node缓存服务

手把手做一个node缓存服务

作者: 橙汁坤 | 来源:发表于2020-11-02 17:39 被阅读0次

    前言

    不知道各位前端们在日常的开发生产中是否有过像我一样的困扰

    1. 公司用的内网或特定网络,离开公司就没办法使用内部接口?
    2. 大屏项目或各种向领导演示时担心网络不稳定,导致页面的数据,echart图表等无法显示?
    3. 在没有后端没有开发完的情况下怎样自己实时制造接口数据来保证自己前端开发的进度不落后?
      ..........
      其实总结就是缺少了一个我们前端可以控制的接口服务

    先看效果~

    • node服务启动前 依赖内网环境的前端项目所有的接口都无法使用


      image
    • node服务启动后 在内网状态下进行缓存后即可在脱离内网环境下演示和调试页面


      image
    • node服务在有缓存后可以保证向服务请求时不用等待⌛️后端数据库的查询,接口往往在10ms以内就可以返回,保证演示的时候界面不会出现因为等待某个接口而造成页面图表或文字显示不全


      image

    开始手写代码

    思路说明

    • 其实并不是什么高大尚的东西,本质就是在有网络环境的情况下启动一个node服务,请求后将所有请求的数据保存在本地的json文件中,之后如果在缺乏网络环境或者需要脱离后端自行调试的时候就可以完全由node服务获取接口数据。

    目录构建

    由于是个简单的项目,在这里我也就不使用koa,egg等框架了,有需要的小伙伴可以自行引入

    • 先执行npm init 初始化一下文件夹📁
    • 在文件夹新建index.js作为入口文件,新建utils文件夹和其下的store.js,新建json文件夹和其下的test.json至此简单的目录结构就已经搭建成功啦。
    ├── index.js             //主入口文件
    ├── json
    │   └── test.json    //存储返回数据
    ├── package.json
    └── utils
        └── store.js     //处理相关逻辑
    
    代码编写
    1. store.js
    // const fs = require('fs');
    const date = new Date()
    const path = require('path')
    const defalutpath = path.resolve(__dirname, '../json/test.json')
    const { promises: { readFile, writeFile } } = require('fs');
    async function getStuff (path = defalutpath) {
      let result = await readFile(path, 'utf8');
      return result
    }
    async function setStuff (value, path = defalutpath) {
      let result = await writeFile(path, value, 'utf8');
      return result
    }
    const getJson = ((key, callback) => {
      getStuff().then(res => {
        const json = res ? JSON.parse(res) : {}
        // console.log('读取数据', json[key])
        // console.log(json[key])
        if (typeof (json[key]) !== "undefined") {
          // console.log('有数据', json[key])
          callback(json[key])
        } else {
          callback(false)
        }
      })
    })
    const setJson = ((key, value = {}) => {
      getStuff().then(res => {
        const json = res ? JSON.parse(res) : {}
        json[key] = value
        if (json !== undefined) {
          setStuff(JSON.stringify(json))
          console.log('写入成功')
        }
      })
    })
    //如果有需要还可以在存储的key值后面加上今天的日期,保证数据的有效期。过了有效期重新请求
    const formatDate = ((date) => {
      let myyear = date.getFullYear()
      let mymonth = date.getMonth() + 1
      let myweekday = date.getDate()
      if (mymonth < 10) {
        mymonth = "0" + mymonth
      }
      if (myweekday < 10) {
        myweekday = "0" + myweekday
      }
      return myyear + "-" + mymonth + "-" + myweekday
    })
    const store = {
      getJson,
      setJson
    }
    module.exports = store
    
    • getStuffsetStuff来异步读写文件内容,避免造成node堵塞
    • getJsonsetJson则是对文件读取写入的逻辑处理
    1. index.js
    // 1、加载模块
    const http = require('http');
    const server = new http.Server()
    const axios = require('axios');
    const store = require('./utils/store')
    const md5 = require('md5-node')
    // const querystring = require('querystring')
    const Url = require('url')
    //定义请求头,解决跨域
    const headers = {
      "Content-Type": "application/json;charset=UTF-8",
      "Access-Control-Allow-Origin": "*",
      "access-control-allow-credentials": "true"
    }
    // 2、监听请求事件
    server.on('request', function (request, response) {
      // 监听到请求之后所做的操作
      // request 对象包含:用户请求报文的所有内容
      // response 响应对象,用来响应一些数据
      // 当服务器想要向客户端响应数据的时候,就必须使用response对象
      // const { method, url, headers } = request;
      // console.log(method, url, headers)
      if (request.url !== '/favicon.ico') {
        const index = request.url.indexOf('/mock/') //与前端约定用mock来识别
        const reurl = 'http://' + request.url.substr(index + 6)
        // 3、通过method来做不同的判断
        if (request.method === 'OPTIONS') { 
          response.writeHead(200, {
            "Access-Control-Allow-Credentials": "true",
            "Access-Control-Allow-Headers": "authorization,content-type,token",
            "Access-Control-Allow-Methods": "*",
            "Access-Control-Allow-Origin": "*",
            "Access-Control-Expose-Headers": "authorization,content-type,token",
            "Access-Control-Max-Age": "3600",
            "Connection": "keep-alive",
            "Content-Length": "0",
            "Server": 'openresty/1.15.8.2'
          })
          // res.write('')
          response.end()
          console.log('options go api... ')
        }
        if (request.method === 'GET') {
          store.getJson(reurl, ((res) => { 
            // console.log('GET-res', res)
            if (res) {//如果命中缓存🎯
              console.log('get请求命中缓存🎯')
              response.writeHead(200, headers)
              response.end(JSON.stringify(res))
            } else {
              console.log('get请求命中发送······')
              axios.get(reurl)
                .then(res => {
                  store.setJson(reurl, res.data)
                  response.writeHead(200, headers);
                  response.end(JSON.stringify(res.data));
                })
                .catch(err => {
                  console.log('geterr', err);
                })
            }
          }))
        } else {//post 请求
          const newURL = Url.parse(reurl)
          parseJSON(request, response, ((res) => {
            const key = reurl + md5(res)//post请求用Md5加密保证参数独立性
            const postData = res
            store.getJson(key, (res => {
            //这里是如果请求头中带有token或各种自定义请求头时的配置
              const opheaders = {
                // 'Content-Length': length,
                // 'token': request.headers.token !== undefined ? request.headers.token : '',
                'Content-Type': 'application/json;charset=UTF-8'
    
              }
              // store.getJson(reurl)
              if (res) {//如果命中缓存🎯
                console.log('post请求命中缓存🎯')
                response.writeHead(200, headers)
                response.end(JSON.stringify(res))
              } else {
                console.log('post请求命中....')
                axios.post(reurl, postData, { headers: opheaders })
                  .then(function (res) {
                    store.setJson(key, res.data)
                    response.writeHead(200, headers);
                    response.end(JSON.stringify(res.data));
                  })
                  .catch(function (err) {
                    console.log('posterr', err);
                  });
              }
            }))
          }))
        }
      }
    })
    
    function parseJSON (req, res, next) {
      let data = ''
      // const length = req.headers['content-length']
      req.on('data', function (chunk) {
        // chunk 默认是一个二进制数据,和 data 拼接会自动 toString
        data += chunk;
      });
      //注册end事件,所有数据接收完成会执行一次该方法
      //如果需要可以使用querystring对url进行反序列化(解析url将&和=拆分成键值对),得到一个对象
      req.on('end', function () {
        // console.log(data)
        if (data) {
          data = JSON.parse(data)
        }
        next(data)
      })
    }
    
    // 4、监听端口,开启服务
    server.listen(8099, function () {
      console.log("服务器已经启动,可访问以下地址:");
      console.log('http://localhost:8099');
    })
    
    • 安装依赖axios,md5-node,入口文件的思路很简单,在收到请求后先截取/mock/后的url用来作为store的key值。
    • 在本地json中读取到这个key值则直接返回value值不去请求后端接口,如果没有key值则请求后端接口并将后端的返回值写入本地的json文件中,之后再返回给前端。

    服务的启动与使用

    1. npm install supervisor -g安装这个依赖可以使我们服务热更新便于调试。

      image
    2. 运行npm run hot 此时项目已经启动

    3. 前端服务在原先的地址上加入此时node地址,例如原先前端请求地址为172.16.18.147:8080/xxx/xxxx则此时在前端axios请求配置为
      http://node服务ip:8099/mock/172.16.18.147:8080/xxx/xxxx

      image
    4. 页面正常的接口请求后,所有的返回数据会保存在本地的json文件中


      image
    5. 服务开启时,如果请求命中🎯缓存则不会再走网络请求,而是直接获取本地json中的值


      image

    小结

    至此node服务的功能大致已经介绍完毕啦。以后再有演示或者脱离后端的情况下只要你开启node服务
    就可以用本地缓存来展示数据啦~

    做完这个后又想着做一个electron版本的服务了,这样就可以时时自定义请求头和接口参数,这部分就下次再更新了

    这是我的github项目地址有需要的朋友们可以去看看然后点个star~

    相关文章

      网友评论

        本文标题:手把手做一个node缓存服务

        本文链接:https://www.haomeiwen.com/subject/lgrdvktx.html