node.js接口復習及使用案例解析

更新時間：2023年07月24日 10:00:39 作者：Heymar

這篇文章主要為大家介紹了node.js接口的復習及使用案例解析，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪

引言

其實復習一次的作用真實太大了，真的，自從上次ajax開始其實就開始i有點懵懵懂懂的感覺，一直拖想到了node在去回顧一遍，這一次回去復習，ajax已經(jīng)很熟練了，node之前搞不懂那些原理也順清楚了好多，其實這次復習沒有什么需要說的知識點，因為要說的前面都說過了，我來說一下這個做的一個大項目吧，這個項目真的，應該是我不熟練的愿意那邊，就是用express寫接口，用postman來測試，三個模塊，三個數(shù)據(jù)庫，基本上都在我的代碼里面了，寫的很詳細步驟，用到的技術，基本上是用node的express模塊，去寫接口，然后中途中到了一些中間件，比如規(guī)定語義規(guī)則的joi，比如給密碼解碼加密的bcryptjs，我做了一天才做下來這一個案例

一個項目初試化，首先要創(chuàng)立一個單獨的項目文件夾，然后終端npm init直接安裝package.json，api.js接口文件，路由模塊創(chuàng)立一個文件夾夾，路由函數(shù)又要分為一個模塊，再把數(shù)據(jù)庫創(chuàng)立好，基本就可以開始完成功能需求了，用后端node完成增刪改查

項目文件分類：

接口文件

// 1.初始化
// 1.1創(chuàng)建項目
const express = require('express')
const app = express()
// 1.2配置跨域
const cors = require('cors')
app.use(cors())
// 1.3配置解析表單中間件
// 錯誤點：記住要有參數(shù)
app.use(express.urlencoded({extended : false}))
// 2.3因為后面處理函數(shù)用到了很多res.send所以封裝為一個全局中間件，給res綁定一個函數(shù)，那后面的中間件路由都可以用到這個函數(shù)了
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發(fā)布文章路由導入
const cates = require('./router/cate')
app.use('/my/article', cates)
// 2.2.3定義規(guī)則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');
})

路由創(chuàng)建模塊

寫好接口文件該去給路由創(chuàng)建模塊

// 1.4初始化路由相關文件夾 不光要給路由分裝一個模塊 里面的處理函數(shù)也要有一個模塊
const express = require('express')
const { append } = require('express/lib/response')
const router = express.Router()
// 1.4.2導入路由處理函數(shù)
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添加語法規(guī)則，可以直接用注冊的
router.post('/login',expressJOI(schema_user_info), routerHandler.getLogin)
module.exports = router

處理函數(shù)模塊

// 1.4.1初始化路由處理函數(shù)模塊
//注冊
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用到我們前面定義的全局中間件優(yōu)化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 ?'
        // -------------注意一下這里插入數(shù)據(jù)庫的參數(shù)怎么寫的
        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根據(jù)用戶名查詢用戶的數(shù)據(jù)
    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有數(shù)據(jù)就去判斷密碼是否正確
        // 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向客戶端發(fā)送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對新密碼加密后更新到數(shù)據(jù)庫
        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
}

api入口文件測試

這個時候就可以去api入口文件測試一下了，然后在數(shù)據(jù)庫寫好我們的數(shù)據(jù)表，創(chuàng)立一個js文件鏈接數(shù)據(jù)庫

// 2.登錄注冊
// 2.1建好數(shù)據(jù)庫后配置數(shù)據(jù)庫
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

jwt認證機制生成token

沒記錯的話，在登錄接口應該使用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添加驗證規(guī)則
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的驗證規(guī)則

module.exports = {
    secretKey : 'sdfafsfds'
}

user的驗證規(guī)則

上面就是整個user部分的接口了包括登錄注冊，添加刪除修改賬號或者密碼等，下面是我們的user的驗證規(guī)則

// 2.2注冊
// 2.2.1對表單數(shù)據(jù)驗證，這里就不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更新用戶信息規(guī)則
const id = joi.number().integer().min(1).required()
const nickname = joi.string().required()
const email = joi.string().email().required()
// 3.4.2更換頭像規(guī)則
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重置密碼規(guī)則
    body : {
        oldPwd : password,
        // --------------錯誤點這里就算是變量也要添加引號
        newPwd : joi.not(joi.ref('oldPwd')).concat(password)
    }
}
module.exports.schema_updatee_avatar = {
    body : {
        avatar
    }
}

判斷是否重名

這個部分是對文章的名字和別名的增刪改查的操作了，這里面的難點在于要去理解那個怎么來判斷是否重名哪里

// 4.1.1文章分類列表函數(shù)
const { result } = require('@hapi/joi/lib/base')
const db = require('../mysql')
function getArticleList(req, res) {
    // res.send('文章分類列表')
    // 4.1.3獲取文章數(shù)據(jù)
    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實現(xiàn)文章分類新增
        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根據(jù)idshanchuwenzhan
function deleteCate(req, res) {
    // 4.3.3實現(xiàn)刪除功能
    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根據(jù)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 : '獲取文章分類數(shù)據(jù)成功',
            data : results[0]
        })
    })
}
// 4.5.1根據(jù)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
}

處理函數(shù)

這是路由模塊，上面是路由的處理函數(shù)

// 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根據(jù)id刪除文章
const {delete_id_cate} = require('../schema/article')
router.get('/deletecate/:id',expressJoi(delete_id_cate),routerhanlder.deleteCate)
// 4.4根據(jù)id獲取文章分類數(shù)據(jù)
router.get('/cates/:id',expressJoi(delete_id_cate), routerhanlder.requireArt)
// 4.5根據(jù)id更新文章分類數(shù)據(jù)
const {update_id_Art} = require('../schema/article')
router.post('/updatecate',expressJoi(update_id_Art) ,routerhanlder.updateArt)
module.exports = router

然后我們的規(guī)則

const joi = require('joi')
// 4.2.2新增文章規(guī)則
const name = joi.string().required()
const alias = joi.string().alphanum().required()
// 4.3.2根據(jù)id刪除文章 注意這個id是動態(tài)的而且是get請求，所以不再是body數(shù)據(jù)
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
    }
}

添加文章功能

最后是我們的添加文章這個功能，就是往每一個剛才創(chuàng)建好的文章里面，添加新文章，直接看邏輯的實現(xiàn)吧

// 5.1.1發(fā)布文章函數(shù)
const path = require('path')
const db = require('../mysql')
function addCate(req, res) {
    // 5.1.5因為上傳表單無法用joi所以要單獨規(guī)定
    if (!req.file || req.file.fieldname !== 'cover_img') return res.cc('請上傳圖片')
    // 5.1.6事先發(fā)布文章功能
    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('發(fā)布文章失敗')
        res.cc('發(fā)布文章成功', 0)
    })
}
module.exports = {
    addCate
}

// 1.4初始化路由相關文件夾 不光要給路由分裝一個模塊 里面的處理函數(shù)也要有一個模塊
const express = require('express')
const { append } = require('express/lib/response')
const router = express.Router()
// 1.4.2導入路由處理函數(shù)
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添加語法規(guī)則，可以直接用注冊的
router.post('/login',expressJOI(schema_user_info), routerHandler.getLogin)
module.exports = router

以上就是node.js接口復習及使用案例解析的詳細內(nèi)容，更多關于node.js接口使用的資料請關注腳本之家其它相關文章！

您可能感興趣的文章:

node
接口

nodejs+express實現(xiàn)文件上傳下載管理網(wǎng)站
這篇文章主要為大家詳細介紹了nodejs+express實現(xiàn)文件上傳下載管理的網(wǎng)站，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下
2017-03-03
Nodejs實戰(zhàn)心得之eventproxy模塊控制并發(fā)
本篇文章給大家分享我的nodejs實戰(zhàn)心得，如何使用eventproxy模塊控制并發(fā)，感興趣的朋友可以參考下
2015-10-10
nodejs中fs模塊三種讀寫文件方法的使用區(qū)別
Node.js的fs模塊有多種文件操作API,readFile、read、createReadStream讀取文件,writeFile、write、createWriteStream寫入文件,readFile和writeFile將文件寫入緩存區(qū),適合小文件操作,read和write分步驟讀寫,適合大文件,createReadStream和createWriteStream通過流處理文件
2024-10-10
Node.js利用debug模塊打印出調(diào)試日志的方法
debug日志打印模塊主要實現(xiàn)功能是帶命名空間（模塊名）、時間戳、色彩輸出日志；將日志寫入文件；瀏覽器端使用；格式化函數(shù)；支持自定義方法。下面這篇文章主要介紹了Node.js利用debug模塊打印出調(diào)試日志的方法，需要的朋友可以參考借鑒，下面來一起看看吧。
2017-04-04
node.js使用Moment.js js 時間計算方法示例小結
這篇文章主要介紹了node.js使用Moment.js js 時間計算方法,結合實例形式分析了Moment.js js模塊時間計算的常用操作技巧與相關注意事項,需要的朋友可以參考下
2023-05-05
Node.JS文件系統(tǒng)解析實例詳解
這篇文章主要介紹了Node.JS文件系統(tǒng)解析實例詳解的相關資料,需要的朋友可以參考下
2017-05-05
nodejs開發(fā)微博實例
本文給大家分享的是使用node.js實現(xiàn)開發(fā)微博的實例，主要是看了nodejs開發(fā)指南之后發(fā)現(xiàn)書上的代碼很多已經(jīng)不能用了，原因是express版本升級了，所以今天就嘗試著吧開發(fā)微博的實例也升下級，推薦給大家。
2015-03-03
詳解Node.js讀寫中文內(nèi)容文件操作
在本篇文章中我們給大家分享了關于Node.js讀寫中文內(nèi)容文件操作的相關知識點內(nèi)容，有需要的朋友們可以學習下。
2018-10-10
nodejs動態(tài)創(chuàng)建二維碼的方法
這篇文章主要為大家詳細介紹了nodejs動態(tài)創(chuàng)建二維碼的方法，具有一定的參考價值，感興趣的小伙伴們可以參考一下
2017-08-08
websocket+node.js實現(xiàn)實時聊天系統(tǒng)問題咨詢
最近新學習websocket，做了一個實時聊天。用Node.js搭建的服務:serevr.js. 兩個相互通信頁面：client.html 和server.html 但是就是有很多問題，下面通過本文給大家分享下
2017-05-05