Koa2实现基本的登录注册

最近手头上的任务完成的及时，闲暇之余想搞一搞后端。想来想去大学的时候还会个C#写写毕设，倒腾倒腾数据库，毕业从事前端后，技能都忘得一干二净。从事前端有段时间了，想试试过去大学学的技能能不能通过Node来再捡起来，于是决定写个小小的登录注册功能Demo。

虽然现在也有egg.js think.js 等，但是koa更接近Express，也更容易理解底层思想，所以决定选择Koa来写这个功能

什么是koa框架？

koa是一个基于node实现的一个新的web框架，它是由express框架的原班人马打造的。它的特点是优雅、简洁、表达力强、自由度高。它更express相比，它是一个更轻量的node框架，因为它所有功能都通过插件实现。

文件结构

├── Koa2│   ├── config│   │   ├── DBconfig.js // 数据库配置文件|   ├── controller |   |   ├──userController.js |   ├── lib|   |   ├──mysql.js //连接Mysql|   ├── router|   |   ├──router.js // 总路由|   |   ├──userRoute.js|   ├── service|   |   ├──user.js |   ├── app.js //入口文件└── ├── package.json复制代码

文件结构尽量模仿了MVC架构开发，虽然是个小项目，但是还是按标准来比较好。

//Koa2/config/DBconfig.js/*数据库默认配置*/const database ={    database: 'elmfoodshop', //数据库名称    user: 'root', //mysql用户名    password: '123456', //mysql密码    PORT: '3306', //mysql端口号    host: "127.0.0.1" //服务器ip}module.exports = database复制代码

//Koa2/lib/mysql.js
const mysql = require("mysql")const DBConfig = require("../config/DBConfig")/*建立连接池*/let pool = mysql.createPool(DBConfig)/*连接数据库*/let allSqlAction = (sql, value) => {    return new Promise((resolve, reject) => {        pool.getConnection(function (err, connection) {            if (err) {                reject(err)            }            else {                console.log("数据库连接成功")                connection.query(sql, value, (err, row) => {                    if (err) reject(err)                    else{                        resolve(row)                    }                     connection.release()                })            }        })    })}module.exports = {    allSqlAction}复制代码

router配置

userRoute配置，把对应的请求分流到不同的controller内

//Koa2/router/router.js
const Router =require("koa-router")const controller = require("../controller/userController")const router = new Router()router.post("login","/login",controller.checkLogin)router.post("login","/register",controller.registerUser)module.exports = router复制代码

在router中注入userRouter

//Koa2/router/router.js
const Router =require("koa-router")const user = require("./userRoute")let router = new Router()router.use(user.routes())module.exports = router复制代码

controller层和service层

• controller层

controller层处理来自用户的输入数据，返回给业务层service处理后返回

//Koa2/controller/usercontroller.js
const user = require("../service/user")async function checkLogin(ctx,next){    let {phone,password} = ctx.request.body    let data = await user.checkUser(phone,password)    return ctx.response.body = data}async function registerUser(ctx,next){    let {phone,password} = ctx.request.body    let data = await user.findUser(phone,password)    return ctx.response.body = data}module.exports={    checkLogin,    registerUser}复制代码

• service层

service层查询数据库，根据查询结果判断，返回数据到controller

//Koa2/service/userservice.js
const allSqlAction = require("../lib/mysql")async function checkUser(phone, password) {    let sql = `select * from elm_user where elm_userPhone = ${phone} and elm_userPassword=${password}`    return allSqlAction.allSqlAction(sql).then(res => {        if (res.length == 1 && res[0].elm_userPhone === phone && elm_userPassword === password) {            return { msg: "登陆成功", code: 200 }        } else {            return { msg: "登录失败", code: 201 }        }    })}async function findUser(phone, password) {    let sql = `select * from elm_user where elm_userPhone = ${phone}`    return allSqlAction.allSqlAction(sql).then(res => {        if (res.length == 0) {            return registerUser(phone, password)        } else {            return { msg: "用户已存在", code: 202 }        }    })}async function registerUser(phone, password) {    let sql = `insert into elm_user (elm_userPhone,elm_userPassword) values ('${phone}','${password}')`    return allSqlAction.allSqlAction(sql).then(res => {        if (res.affectedRows == 1) {            return { msg: "注册成功", code: 200 }        } else {            return { msg: "注册失败", code: 201 }        }    })}module.exports = {    checkUser,    findUser,    registerUser}复制代码

app.js

const Koa = require("koa")const router = require("./router/router")const bodyParser = require("koa-body")var app = new Koa()app.use(bodyParser())app.use(router.routes())app.use(async (ctx) => {     console.log("404 Not Found")})console.log("项目启动http://127.0.0.1:3000")app.listen(3000)复制代码

数据库建表

数据库用的是Mysql，所以用了可视化工具Navicat

CREATE TABLE `elm_user` (
`elm_userID`  int(10) NOT NULL ,
`elm_userPhone`  varchar(11) NOT NULL ,
`elm_userPassword`  varchar(30) NOT NULL ,
PRIMARY KEY (`elm_userID`)
)
;复制代码

结语

第一次写文章，也是为了记录下自己的成长，如果有问题可以留言指出。

以上便是一个简单使用Koa2+Mysql实现的一个登录注册。 点此查看源码