其實複習一次的作用真實太大了,真的,自從上次ajax開始其實就開始i有點懵懵懂懂的感覺,一直拖想到了node在去回顧一遍,這一次回去複習,ajax已經很熟練了,node之前搞不懂那些原理也順清楚了好多,其實這次複習沒有什麼需要說的知識點,因為要說的前面都說過了,我來說一下這個做的一個大項目吧,這個項 ...
其實複習一次的作用真實太大了,真的,自從上次ajax開始其實就開始i有點懵懵懂懂的感覺,一直拖想到了node在去回顧一遍,這一次回去複習,ajax已經很熟練了,node之前搞不懂那些原理也順清楚了好多,其實這次複習沒有什麼需要說的知識點,因為要說的前面都說過了,我來說一下這個做的一個大項目吧,這個項目真的,應該是我不熟練的願意那邊,就是用express寫介面,用postman來測試,三個模塊,三個資料庫,基本上都在我的代碼裡面了,寫的很詳細步驟,用到的技術,基本上是用node的express模塊,去寫介面,然後中途中到了一些中間件,比如規定語義規則的joi,比如給密碼解碼加密的bcryptjs,我做了一天才做下來這一個案例
一個項目初試化,首先要創立一個單獨的項目文件夾,然後終端npm init直接安裝package.json,api.js介面文件,路由模塊創立一個文件夾夾,路由函數又要分為一個模塊,再把資料庫創立好,基本就可以開始完成功能需求了,用後端node完成增刪改查
項目文件分類:
1
介面文件
// 1.初始化 // 1.1創建項目 const express = require('express') const app = express() // 1.2配置跨域 const cors = require('cors') app.use(cors()) // 1.3配置解析表單中間件 // 錯誤點:記住要有參數 app.use(express.urlencoded({extended : false})) // 2.3因為後面處理函數用到了很多res.send所以封裝為一個全局中間件,給res綁定一個函數,那後面的中間件路由都可以用到這個函數了 app.use((req, res, next) => { res.cc = function(err, status = 1) { res.send({ status, msg : err instanceof Error ? err.message : err }) } next() }) // 2.4.6配置解析token的中間件 const expressJWT = require('express-jwt') const secretKey = require('./secretKey') app.use(expressJWT({secret : secretKey.secretKey, algorithms : ['HS256']}).unless({path : [/^\/api\//]})) // 1.4.4導入路由模塊 const routerUser = require('./router/user') const Joi = require('joi') const { expressjwt } = require('express-jwt') const { path } = require('express/lib/application') app.use('/api', routerUser) // 3.1.1個人中心路由導入 const infoRouter = require('./router/userinfo') app.use('/my', infoRouter) // 4.1.2文章管理導入 const article = require('./router/acticle') app.use('/my/article', article) // 5.1.2發佈文章路由導入 const cates = require('./router/cate') app.use('/my/article', cates) // 2.2.3定義規則joi的錯誤級別中間件 app.use((err, req, res, next) => { if (err instanceof Joi.ValidationError) return res.send(err.message) // 2.4.7增加jwt錯誤中間件 if (err.name == 'UnauthorizedError') return res.cc('身份認證失敗') return res.send('其他錯誤') }) app.listen(80, () => { console.log('http://127.0.0.1'); })
2.
寫好介面文件該去給路由創建模塊
// 1.4初始化路由相關文件夾 不光要給路由分裝一個模塊 裡面的處理函數也要有一個模塊 const express = require('express') const { append } = require('express/lib/response') const router = express.Router() // 1.4.2導入路由處理函數 const routerHandler = require('../router_handler/user') // 註冊 // 2.2.2導入joi驗證輸入進來的是否合法 const expressJOI = require('@escook/express-joi') const {schema_user_info} = require('../schema/user') router.post('/reguser',expressJOI(schema_user_info), routerHandler.getReguser) // 2.4登錄 // 2.4.1添加語法規則,可以直接用註冊的 router.post('/login',expressJOI(schema_user_info), routerHandler.getLogin) module.exports = router
3.
處理函數模塊
// 1.4.1初始化路由處理函數模塊 //註冊 const db = require('../mysql') //導入密碼加密解密包 const bcrypt = require('bcryptjs') function getReguser(req, res) { // res.send('這裡是註冊模塊') // 2.2.4檢測用戶名是否被占用 導入mysql let selectUser = 'select * from users where username = ?' db.query(selectUser, req.body.username, (err, results) => { // 2.3.1用到我們前面定義的全局中間件優化res.send if (err) return res.cc(err) if (results.length == 1) return res.cc('用戶名已被占用') // 2.2.5如果過了前兩關的驗證 基本可以驗證成功了 就先對密碼進行加密處理安裝bcryptjs req.body.password = bcrypt.hashSync(req.body.password, 10) // console.log(req.body.password); // 2.2.6插入新用戶 let insertUser = 'insert into users set ?' // -------------註意一下這裡插入資料庫的參數怎麼寫的 db.query(insertUser, [{username : req.body.username, password : req.body.password}], (err, results) => { if (err) return res.cc(err) if (results.affectedRows !== 1) return res.cc('註冊失敗') res.cc('註冊成功',0) }) }) } //登錄 // 2.4.4.1導入jwt const jwt = require('jsonwebtoken') const secretKey = require('../secretKey') const { result } = require('@hapi/joi/lib/base') function getLogin(req, res) { // res.send('這裡是登錄模塊') // 2.4.2根據用戶名查詢用戶的數據 let selectLoginuser = 'select * from users where username = ?' db.query(selectLoginuser, req.body.username, (err, results) => { if (err) res.cc(err) if (results.length !== 1) res.cc('未找到該用戶') // 2.4.3有數據就去判斷密碼是否正確 // console.log(results); if (!bcrypt.compareSync(req.body.password, results[0].password)) return res.cc('密碼錯誤') // 2.4.4用戶名有,密碼 也對上了說明登陸成功,開始jwt身份認證 // 先剔除密碼和頭像的值 let user = {...results[0], password : '', user_pic: '',algorithms : ['HS256']} let userToken = jwt.sign(user, secretKey.secretKey, {expiresIn : '1h'}) // 2.4.5向客戶端發送token res.send({ status : 0, msg : '登錄成功', token : 'Bearer ' + userToken }) }) } // 獲取用戶基本信息 function getInfo(req,res) { // res.send('個人中心') // 3.1.2獲取用戶基本信息 let selectInfo = 'select id,username,nickname,email,user_pic from users where id = ?' db.query(selectInfo, req.user.id, (err, results) => { if (err) return res.cc(err) if (results.length !== 1) return res.cc('獲取信息失敗') res.send({ status : 0, msg : '獲取信息成功', data : results[0] }) }) } // 3.2更新用戶信息 function updateInfo(req, res) { // res.send('更新用戶信息') // 3.2.4更新用戶功能 let updateInfo = 'update users set ? where id = ?' db.query(updateInfo, [req.body, req.user.id], (err, results) => { if (err) return res.cc(err) if (results.affectedRows !== 1) return res.cc('更新信息失敗') res.cc('更新信息成功', 0) }) } // 3.3重置密碼 function updatePwd(req, res) { // res.send('重置密碼') // 3.3.2查詢用戶是否存在 let selectExist = 'select * from users where id = ?' db.query(selectExist, req.user.id, (err, results) => { if (err) return res.cc(err) if (results.length !== 1) return res.cc('用戶不存在') // 3.3.3前面那一步雖然無所謂但這一步必須的 判斷輸入的舊密碼是否正確 if(!bcrypt.compareSync(req.body.oldPwd, results[0].password)) return res.cc('輸入密碼錯誤') // 3.3.4對新密碼加密後更新到資料庫 let password = bcrypt.hashSync(req.body.newPwd) let updatePwd = 'update users set password =? where id =?' db.query(updatePwd, [password,req.user.id], (err, results) => { if (err) return res.cc(err) if (results.affectedRows !== 1) return res.cc('修改密碼失敗') res.cc('更新密碼成功', 0) }) }) } // 3.4更換頭像 function updateAvatar(req, res) { // res.send('更換頭像') // 3.4.3 let updateAvatar = 'update users set user_pic = ? where id = ?' db.query(updateAvatar, [req.body.avatar, req.user.id], (err, results) => { if (err) return res.cc(err) if (results.affectedRows !== 1) return res.cc('更新頭像失敗') res.cc('更新頭像成功', 0) }) } module.exports = { getLogin, getReguser, getInfo, updateInfo, updatePwd, updateAvatar }
4.
這個時候就可以去api入口文件測試一下了,然後在資料庫寫好我們的數據表,創立一個js文件鏈接資料庫
// 2.登錄註冊 // 2.1建好資料庫後配置資料庫 const { result } = require('@hapi/joi/lib/base') const mysql = require('mysql') const db = mysql.createPool({ host : '127.0.0.1', user : 'root', password : 'admin123', database : 'mydb' }) // 測試 /* db.query('select 1' , (err, results) => { if(err) return console.log(err.message); return console.log(results); }) */ module.exports = db
5.
沒記錯的話,在登錄介面應該使用jwt認證機制生成token吧
const express = require('express') const router = express.Router() const routerHandler = require('../router_handler/user') // 3.個人中心 // 3.1獲取用戶基本信息 router.get('/userinfo', routerHandler.getInfo) // 3.2.1更新用戶信息 // 3.2.3添加驗證規則 const expressJoi = require('@escook/express-joi') const {schema_update_info, schema_update_avatar} = require('../schema/user') router.post('/userinfo',expressJoi(schema_update_info),routerHandler.updateInfo) // 3.3.1重置密碼 const {schema_update_pwd} = require('../schema/user') router.post('/updatepwd',expressJoi(schema_update_pwd), routerHandler.updatePwd) // 3.4.1更換頭像 const {schema_updatee_avatar} = require('../schema/user') router.post('/update/avatar',expressJoi(schema_updatee_avatar), routerHandler.updateAvatar) module.exports = router
token的驗證規則
module.exports = { secretKey : 'sdfafsfds' }
上面就是整個user部分的介面了包括登錄註冊,添加刪除修改賬號或者密碼等,下麵是我們的user的驗證規則
// 2.2註冊 // 2.2.1對錶單數據驗證,這裡就不if else了直接用上joi來驗證 joi要下最新版而且直接導入joi const { number } = require('joi') const joi = require('joi') const username = joi.string().alphanum().min(1).max(10).required() // 錯誤點:正則{}裡面的量詞之間不能以空格隔開 const password = joi.string().pattern(/^[\S]{6,12}$/).required() // 3.2.2更新用戶信息規則 const id = joi.number().integer().min(1).required() const nickname = joi.string().required() const email = joi.string().email().required() // 3.4.2更換頭像規則 const avatar = joi.string().dataUri().required() module.exports.schema_user_info = { body : { username, password } } module.exports.schema_update_info = { body : { id, nickname, email } } module.exports.schema_update_pwd = { // 3.3.2重置密碼規則 body : { oldPwd : password, // --------------錯誤點這裡就算是變數也要添加引號 newPwd : joi.not(joi.ref('oldPwd')).concat(password) } } module.exports.schema_updatee_avatar = { body : { avatar } }
6.
這個部分是對文章的名字和別名的增刪改查的操作了,這裡面的難點在於要去理解那個怎麼來判斷是否重名哪裡
// 4.1.1文章分類列表函數 const { result } = require('@hapi/joi/lib/base') const db = require('../mysql') function getArticleList(req, res) { // res.send('文章分類列表') // 4.1.3獲取文章數據 let selectArticleList = 'select * from article where is_delete = 0' db.query(selectArticleList, (err, results) => { if (err) return res.cc(err) res.send({ status : 0, msg : '獲取文章分類列表成功', data : results }) }) } // 4.2.1新增文章分類 function addCates(req,res) { // 4.2.3名字與別名是否重名 let selectDuplicate = 'select * from article where name = ? or alias = ?' db.query(selectDuplicate, [req.body.name, req.body.alias], (err, results) => { if(err) return res.cc(err) if(results.length == 2) return res.cc('文章名字和別名已被占用') if(results.length == 1 && results[0].name == req.body.name && results[0].alias == req.body.alias) return res.cc('文章名字和別名已被占用') if(results.length == 1 && results[0].name == req.body.name) return res.cc('文章名字被占用') if(results.length == 1 && results[0].alias == req.body.alias) return res.cc('文章別名被占用') // 4.2.4實現文章分類新增 let addArt = 'insert into article set ?' db.query(addArt, req.body, (err, results) => { if(err) return res.cc(err) if (results.affectedRows !== 1) return res.cc('新增文章失敗') res.cc('新增文章分類成功', 0) }) }) } // 4.3.1根據idshanchuwenzhan function deleteCate(req, res) { // 4.3.3實現刪除功能 let deleteId = 'update article set is_delete = 1 where id = ?' db.query(deleteId, req.params.id, (err, results) => { if (err) return res.cc(err) if (results.affectedRows !== 1) return res.cc('刪除文章失敗') res.cc('刪除文章分類成功', 0) }) } // 4.4.1根據id獲取文章分類 function requireArt(req,res) { // 4.4.2 let selectArt = 'select * from article where id = ?' db.query(selectArt, req.params.id, (err, results) => { if (err) return res.cc(err) if (results.length !== 1 || results[0].is_delete == 1) return res.cc('沒有該文章') res.send({ status : 0, msg : '獲取文章分類數據成功', data : results[0] }) }) } // 4.5.1根據id更新文章 function updateArt(req, res) { // 4.5.2查看是否重名 // -----------------這裡需要先將自己這一項排除出來 let selectIdDuplicate = 'select * from article where id != ? and (name = ? or alias = ?)' db.query(selectIdDuplicate, [req.body.id, req.body.name, req.body.alias], (err, results) => { if (err) return res.cc(err) if (results.length == 2) return res.cc('文章名稱和別名已被占用') if (results.length == 1 && results[0].name == req.body.name && results[0].alias == req.body.alias) return res.cc('文章名稱和別名已被占用') if (results.length == 1 && results[0].name == req.body.name) return res.cc('文章名稱已被占用') if (results.length == 1 && results[0].alias == req.body.alias) return res.cc('別名已被占用') let updateIdArt = 'update article set ? where id = ?' db.query(updateIdArt, [req.body, req.body.id] , (err,results) => { if (err) return res.cc(err) if (results.affectedRows !== 1) return res.cc('文章更新失敗') res.cc('更新分類信息成功', 0) }) }) } module.exports = { getArticleList, addCates, deleteCate, requireArt, updateArt }
這是路由模塊,上面是路由的處理函數
// 4.文章類別管理 const express = require('express') const router = express.Router() const routerhanlder = require('../router_handler/article') // 4.1獲取文章分類列表 router.get('/cates',routerhanlder.getArticleList) // 4.2新增文章分類 const expressJoi = require('@escook/express-joi') const {add_article_list, update_id_cate} =require('../schema/article') router.post('/addcates',expressJoi(add_article_list),routerhanlder.addCates) // 4.3根據id刪除文章 const {delete_id_cate} = require('../schema/article') router.get('/deletecate/:id',expressJoi(delete_id_cate),routerhanlder.deleteCate) // 4.4根據id獲取文章分類數據 router.get('/cates/:id',expressJoi(delete_id_cate), routerhanlder.requireArt) // 4.5根據id更新文章分類數據 const {update_id_Art} = require('../schema/article') router.post('/updatecate',expressJoi(update_id_Art) ,routerhanlder.updateArt) module.exports = router
然後我們的規則
const joi = require('joi') // 4.2.2新增文章規則 const name = joi.string().required() const alias = joi.string().alphanum().required() // 4.3.2根據id刪除文章 註意這個id是動態的而且是get請求,所以不再是body數據 const id = joi.number().integer().min(1).required() module.exports.add_article_list = { body : { name, alias } } module.exports.delete_id_cate = { params : { id } } module.exports.update_id_Art = { body : { id : id, name : name, alias : alias } }
7.
最後是我們的添加文章這個功能,就是往每一個剛纔創建好的文章裡面,添加新文章,直接看邏輯的實現吧
// 5.1.1發佈文章函數 const path = require('path') const db = require('../mysql') function addCate(req, res) { // 5.1.5因為上傳表單無法用joi所以要單獨規定 if (!req.file || req.file.fieldname !== 'cover_img') return res.cc('請上傳圖片') // 5.1.6事先發佈文章功能 const cateObj = { ...req.body, cover_img : path.join('/uploads', req.file.filename), pub_date : new Date(), author_id : req.user.id } let addInsert = 'insert into articles set ?' db.query(addInsert, cateObj, (err, results) => { if (err) return res.cc(err) if (results.affectedRows !== 1) return res.cc('發佈文章失敗') res.cc('發佈文章成功', 0) }) } module.exports = { addCate }
// 1.4初始化路由相關文件夾 不光要給路由分裝一個模塊 裡面的處理函數也要有一個模塊 const express = require('express') const { append } = require('express/lib/response') const router = express.Router() // 1.4.2導入路由處理函數 const routerHandler = require('../router_handler/user')
// 註冊 // 2.2.2導入joi驗證輸入進來的是否合法 const expressJOI = require('@escook/express-joi') const {schema_user_info} = require('../schema/user') router.post('/reguser',expressJOI(schema_user_info), routerHandler.getReguser)
// 2.4登錄 // 2.4.1添加語法規則,可以直接用註冊的 router.post('/login',expressJOI(schema_user_info), routerHandler.getLogin)
module.exports = router