Vueecharts模拟后端数据流程详解

// 服务端入口文件
// 1. 创建KOA的实例对象
const Koa = require('koa') // 引入koa
const app = new Koa() // 创建koa 实例
// 2.绑定中间件
// 第一层 响应时间的中间件
const resDuration = require('./middleware/response_duration')
app.use(resDuration)
// 第二层 设置响应头的中间件
const resHeader = require('./middleware/response_header')
app.use(resHeader)
// 第三层 处理业务逻辑的中间件
const resData = require('./middleware/response_data')
app.use(resData)
// 3.绑定端口号
app.listen(2903)
const websocketService = require('./service/web_Socket_service')
// 开启服务器的监听，监听客户端的链接
// 当某一个客户端连接成功之后，就会对这个客户端进行message 事件的监听
webSocketService.listen()

// 计算响应总耗时的中间件
module.exports = async (context,next) =>{
// 记录开始时间
  const start = Date.now()
// 让内层的中间件得到执行
  await next()
// 记录结束的时间
  const end = Date.now()
// 准备时间数据
  const  duration = end - start
// 设置响应头 X-Response-Time
  context.set('X-Response-Time',duration + 'ms')
}

// 设置响应头的中间件
module.exports = async (context,next) =>{
  // 增加响应头 解读 json文件  utf-8格式防止乱码
  const  contentType = 'application/json; charset=utf-8'
  context.set('Content-Type',contentType)
  // 下面两行增加跨域配置
  context.set('Access-Control-Allow-Origin','*')
  context.set('Access-Control-Allow-Methods','OPTIONS,GET,PUT,POST,DELETE')
  //context.response.body = '{"success":true}'
  await next()
}

// 处理业务逻辑的中间件 读取某个json文件的数据
// 引入 node path内置模块 用于拼接路径
const path = require('path')
// 具体处理对应文件的工具
const fileUtils = require('../utils/file_utils')
module.exports = async (context,next) => {
  // 根据url 提取关键字 再拼接绝对路径
  const url = context.request.url // /api/seller
  let filePath = url.replace('/api','')
  filePath = path.join('../data',filePath,'.json') // ../data/seller.json
  filePath = path.join(__dirname,filePath)
try {
  const ret = await fileUtils.getFileJsonData(filePath)
  context.response.body = ret
}catch (e) {
  const errMsg = {
    message:'读取文件内容失败，文件资源不存在',
    status:404
  }
  context.response.body = JSON.stringify(errMsg)
}
  //console.log(filePath)
  await next()
}

// 读取文件的工具方法
const fs = require('fs') // 引入fs文件模块  fs.readFile 用来读取文件
module.exports.getFileJsonData = (filePath) =>{
return new Promise((resolve, reject) => {
  // fs.readFile 三个参数  1.文件的路径 2.文件所要读取的编码 3.promise 函数
  fs.readFile(filePath,'utf-8',(error,data)=>{
    if (error){
      // 读取文件失败
      reject(error)
    }else {
      // 读取文件成功
      resolve(data)
    }
  })
})
}