1. 前置环境部署

1.1  安装node，请自行百度
1.2  创建一个文件夹放置node项目
1.3  在新建的node文件夹中执行npm init, 文件会生成一个package.json的文件
1.4  安装express框架, 及相关依赖

	npm install express
	npm install body-parser
	npm install cors --save

1.5  创建相关文件目录

 	db文件夹：放置数据库操作语句（.js文件）
	router文件夹：放置接口文件（.js文件）
 	connect.js文件：链接数据库前端等相关操作
    index.js文件：主文件，引用各个文件，拦截请求，后端路由

2. connect.js

const mysql = require('mysql')
const express = require('express')
const app = express()
const router = express.Router();
const cors = require('cors');  // 跨域
// 引入express-session模块并设置中间件，做登录验证等需要操作session和cookie需要引入的模块
const session = require("express-session");
const cookieParser=require("cookie-parser")
app.use(cors());
// 解析参数
const bodyParser = require('body-parser')
// json请求
app.use(express.json())
// 表单请求
app.use(express.urlencoded({
    extended: false}))
// 设置session和cookie配置项
app.use(cookieParser());
app.use(
  session({
    
    secret:'keyboard cat',  // 服务端生成申明可随意写
    resave:true,      // 强制保存session即使他没有什么变化
    saveUninitialized:true,   // 强制将来初始化的session存储
    cookie:{
      // session是基于cookie的，所以可以在配置session的时候配置cookie
      maxAge:1000*60*30,  // 设置过期时间
      secure:false      // true的话表示只有https协议才能访问cookie
     }
}))
/**
 * 配置mysql
 */
const option = {
    
 host: 'localhost',
 user: '*****',
 password: '*****',
 port: '3306',
 database: '*****',
 connectTimeout: 5000, //连接超时
 multipleStatements: false //是否允许一个query中包含多条sql语句
}

/**
 * 设置请求头，解决跨域
 */
var allowCors = function(req, res, next) {
     
  res.header("Access-Control-Allow-Origin", req.headers.origin); // 设置允许来自哪里的跨域请求访问（req.headers.origin为当前访问来源的域名与端口）
  res.header("Access-Control-Allow-Methods", "GET,PUT,POST,DELETE,OPTIONS"); // 设置允许接收的请求类型
  res.header("Access-Control-Allow-Headers", "Content-Type,request-origin"); // 设置请求头中允许携带的参数
  res.header("Access-Control-Allow-Credentials", "true"); // 允许客户端携带证书式访问。保持跨域请求中的Cookie。注意：此处设true时，Access-Control-Allow-Origin的值不能为 '*'
  res.header("Access-control-max-age", 1000); // 设置请求通过预检后多少时间内不再检验，减少预请求发送次数
  next();
};
app.use(allowCors);
let pool;
repool()

// 处理接口返回数据，规范返回格式
function Res ({
     code = 200, msg = '', data = {
    } }) {
    
  this.code = code;
  this.msg = msg;
  this.data = data;
}
function resJson (_res, result) {
    
  if(result){
    
    return _res.json(new Res(result))
  }else{
    
    return
  }

}
// 断线重连机制
function repool() {
    
// 创建连接池
 pool = mysql.createPool({
      // 创建连接池
    ...option,
    waitForConnections: true,   // 当无连接池可用时，等待（true）还是抛错（false）
    connectionLimit: 100,   // 连接数限制
    queueLimit: 0      // 最大连接等待数（0为不限制）
 })
 pool.on('error', err => {
    
    err.code === 'PROTOCOL_CONNECTION_LOST' && setTimeout(repool, 2000)
 })
 app.all('*', (_,__, next) => {
    
    pool.getConnection( err => {
    
        err && setTimeout(repool, 2000) || next()
    })
 })
}
module.exports = {
     app, pool, router, resJson }

3. db文件夹（sql操作语句）

const SQL = {
    
  queryAll: 'select * from biaoming order by si asc',   // 查询并升序排序
  updateArt: 'update biaoming set si=? where si=?',// 更改
  deleteArt: 'delete from biaoming where si=?', // 删除
  addArt: 'insert into biaoming values (?,?,?,?,?,?)', //添加
  queryByIndex: 'select * from biaoming where si=?',  // 序号索引查询
  queryByLike: 'select * from biaoming where title like ?' // 模糊查询
}

module.exports = SQL

4. router文件夹（接口文件）

//导入相关模块，本文以登陆功能为例,带参请求http://localhost:8088/user/login?name=yourval&password=yourval
const {
     pool, router, resJson } = require('../connect')
const userSQL = require('../db/userSQL')
const stringRandom = require('string-random'); // 生成随机数，用于登录验证

 /**
 * 登录
 */
router.get('/login', (req, res) => {
       //本地接口路径http://localhost:8088/user/login
  let user = {
    
    username: req.query.name,
    password: req.query.password
  }
  let _res = res;

  // 判断参数是否为空
  if (!user.username) {
    
    return resJson(_res, {
    
        code: -1,
        msg: '用户名不能为空'
    })
  }
  if (!user.password) {
    
    return resJson(_res, {
    
        code: -1,
        msg: '密码不能为空'
    })
  }

  let _data;
  const sessran = stringRandom(16, {
     numbers: true })
  var usersess = req.session;
  // 从连接池获取连接
  pool.getConnection((err, conn) => {
     //数据库链接
    conn.query(userSQL.queryByNamePassword, [user.username, user.password], (e, result) => {
     //操作数据库
        if (e) _data = {
    
            code: -1,
            msg: e
        }
        //通过用户名和密码索引查询数据，有数据说明用户存在且密码正确，只能返回登录成功，否则返回用户名不存在或登录密码错误
        if (result && result.length) {
    
            _data = {
    
                msg: '登录成功',
                data: {
    
                    userInfo: {
    
                        session: sessran
                    }
                }
            }
            req.session.userinfo = sessran; // 设置session
        } else {
    
            _data = {
    
                code: -1,
                msg: '用户名不存在或登录密码错误'
            }
        }
        setTimeout(() => {
    
            //把操作结果返回给前台页面
            resJson(_res, _data)
        }, 500);
    })
    pool.releaseConnection(conn) // 释放连接池，等待别的连接使用
  })
})
module.exports = router;

5. index.js 入口文件

const {
     app, pool } =require('./connect')
const user = require('./router/user')
const page = require('./router/page')

//这里处理全局拦截，一定要写在最上面
app.all('*', (req, res, next) => {
    
  next()
})

//首页路由
app.get('/', (req,res) => {
    
  res.sendFile(__dirname+'/'+'index.html')
})
app.all('/', (req, res) => {
    
  pool.getConnection((err, conn) => {
    
    res.json({
     type: 'test'})
    pool.releaseConnection(conn) // 释放连接池，等待别的连接使用
  })
})

app.use('/user', user)
app.use('/page', page)

// 运行端口
app.listen(8088, () => {
    
  console.log('服务启动','localhost:8088')
})

6. 启动服务

node index.js