华强北网站建设公司,网站建设列表网,建德网站seo,wordpress使用cad功能个人简介 #x1f440;个人主页#xff1a; 前端杂货铺 #x1f64b;♂️学习方向#xff1a; 主攻前端方向#xff0c;也会涉及到服务端 #x1f4c3;个人状态#xff1a; 在校大学生一枚#xff0c;已拿多个前端 offer#xff08;秋招#xff09; #x1f680;未…个人简介 个人主页 前端杂货铺 ♂️学习方向 主攻前端方向也会涉及到服务端 个人状态 在校大学生一枚已拿多个前端 offer秋招 未来打算 为中国的工业软件事业效力n年 推荐学习前端面试宝典 Vue2 Vue3 Vue2Vue3项目实战 Node.jsThree.js 个人推广每篇文章最下方都有加入方式旨在交流学习资源分享快加入进来吧 Node.js系列文章目录
内容参考链接Node.js一初识 Node.jsNode.js二Node.js——开发博客项目之接口Node.js三Node.js——一文带你开发博客项目使用假数据处理Node.js四Node.js——开发博客项目之MySQL基础Node.js五Node.js——开发博客项目之API对接MySQLNode.js六Node.js——开发博客项目之登录前置知识Node.js七Node.js——开发博客项目之登录对接完毕Node.js八Node.js——开发开发博客项目之联调Node.js九Node.js——开发博客项目之日志Node.js十Node.js——开发博客项目之安全Node.js十 一Node.js——开发博客项目之初识 ExpressNode.js十二Node.js——开发博客项目之 Express 重构文章目录Node.js系列文章目录一、前言二、实现 session三、开发路由1、安装 mysql 和 xss2、代码迁移3、修改 controller 控制器4、开发路由四、联调五、日志六、写在最后一、前言
前面我们介绍了 await / async 的基本使用学到了 koa2 框架的安装、项目的创建以及路由的基本使用。
接下来我们正式使用 koa2 对我们的 myblog 博客项目进行重构
二、实现 session
终端安装一些必要的东西koa-generic-session、koa-redis、redis更容易实现登录
npm i koa-generic-session koa-redis redis修改 app.js 文件
app.js
const session require(koa-generic-session)
const redisStore require(koa-redis)
......
// session 配置在routes前面
app.keys [Qianduan2023]
app.use(session({// 配置 cookiercookie: {path: /,httpOnly: true,maxAge: 24 * 60 * 60 * 1000},// 配置 redisstore: redisStore({all: 127.0.0.1:6379 // 本地 reids})
}))我们在 user.js 中创建一个 session-test 做测试
user.js
router.get(/session-test, async function(ctx, next) {if (ctx.session.viewCount null) {ctx.session.viewCount 0}ctx.session.viewCountctx.body {errno: 0,viewCount: ctx.session.viewCount}
})三、开发路由
1、安装 mysql 和 xss
终端键入以下代码安装 mysql 和 xss
npm i mysql xss2、代码迁移 修改 app.js 文件修改本地 redis 的写法
app.js
const { REDIS_CONF } require(./conf/db)
......// 配置 redisstore: redisStore({// all: 127.0.0.1:6379 // 本地 reidsall: ${REDIS_CONF.host}:${REDIS_CONF.port}})3、修改 controller 控制器
修改 controller 文件里的内容主要是修改成 async/await 的形式
./controller.blog.js
// 导入执行 sql 的相关内容
const xss require(xss)
const { exec } require(../db/mysql)// 获取博客列表通过作者和关键字
const getList async (author, keyword) {// 11 是为了语法的绝对正确注意以下 sql 拼接时的空格let sql select * from blogs where 11 if (author) {sql and author${author} }if (keyword) {sql and title like %${keyword}% }// 以时间的倒序sql order by createtime desc;// 返回 promisereturn await exec(sql)
}// 获取博客详情通过 id
const getDetail async (id) {const sql select * from blogs where id${id}const rows await exec(sql)return rows[0]
}// 新建博客 newBlog 若没有就给它一个空对象
const newBlog async (blogData {}) {// blogData 是一个博客对象包含 title content author 属性const title xss(blogData.title)const content xss(blogData.content)const author blogData.authorconst createTime Date.now()const sql insert into blogs (title, content, createtime, author)values (${title}, ${content}, ${createTime}, ${author});const insertData await exec(sql)return {id: insertData.insertId}
}// 更新博客通过 id 更新
const updateBlog async (id, blogData {}) {// id 就是要更新博客的 id// blogData 是一个博客对象 包含 title content 属性const title xss(blogData.title)const content xss(blogData.content)const sql update blogs set title${title}, content${content} where id${id}const updateData await exec(sql)// 更新的影响行数大于 0则返回 trueif (updateData.affectedRows 0) {return true}return false
}// 删除博客通过 id 删除
const delBlog async (id, author) {const sql delete from blogs where id${id} and author${author}const delData await exec(sql)if (delData.affectedRows 0) {return true}return false
}// 导出共享
module.exports {getList,getDetail,newBlog,updateBlog,delBlog
}./controller/user.js
const { exec, escape } require(../db/mysql)
const { genPassword } require(../utils/cryp)
// 登录通过用户名和密码
const login async (username, password) {username escape(username)// 生成加密密码password genPassword(password)password escape(password)const sql select username, realname from users where username${username} and password${password}const rows await exec(sql)return rows[0]}// 导出共享
module.exports {login
}4、开发路由
开发 ./routes 文件里的路由直接拷贝 blog-express 文件里的内容使用 koa2 规定的格式即可
./routes/blog.js
const router require(koa-router)()
// 导入博客和用户控制器相关内容
const {getList,getDetail,newBlog,updateBlog,delBlog
} require(../controller/blog)
// 导入成功和失败的模型
const {SuccessModel,ErrorModel
} require(../model/resModel)const loginCheck require(../middleware/loginCheck)
// 前缀
router.prefix(/api/blog)router.get(/list, async function (ctx, next) {// 博客的作者req.query 用在 GET 请求中let author ctx.query.author || // 博客的关键字const keyword ctx.query.keyword || if (ctx.query.isadmin) {// 管理员界面if (ctx.session.username null) {// 未登录ctx.body new ErrorModel(未登录)return}// 强制查询自己的博客author ctx.session.username}// 查询的结果const listData await getList(author, keyword)ctx.body new SuccessModel(listData)
})router.get(/detail, async function (ctx, next) {const data await getDetail(ctx.query.id)ctx.body new SuccessModel(data)
})router.post(/new, loginCheck, async function (ctx, next) {const body ctx.request.bodybody.author ctx.session.usernameconst data await newBlog(body)ctx.body new SuccessModel(data)
})router.post(/update, loginCheck, async function (ctx, next) {const val await updateBlog(ctx.query.id, ctx.body)if (val) {ctx.body new SuccessModel()} else {ctx.body new ErrorModel(更新博客失败)}
})router.post(/del, loginCheck, async function (ctx, next) {const author ctx.session.usernameconst val await delBlog(ctx.query.id, author)if (val) {ctx.body new SuccessModel()} else {ctx.body new ErrorModel(删除博客失败)}
})module.exports router./routes/user.js
const router require(koa-router)()
const { login } require(../controller/user)
const { SuccessModel, ErrorModel } require(../model/resModel)// 前缀
router.prefix(/api/user)// 路由的中间件必须是个 async 函数
router.post(/login, async function (ctx, next) {// 通过 request.body 获取const { username, password } ctx.request.bodyconst data await login(username, password)if (data.username) {// 设置 sessionctx.session.username data.usernamectx.session.realname data.realnamectx.body new SuccessModel()return}ctx.body new ErrorModel(登录失败)
})module.exports router四、联调
启动 redis开启 nginx 后端npm run dev 前端http-server -p 8001 五、日志
终端键入安装 koa-morgan
npm i koa-morgan修改 app.js 文件
app.js
const path require(path)
const fs require(fs)
const morgan require(koa-morgan)
......
// 日志记录
const ENV process.env.NODE_ENV
if (ENV ! production) {// 开发环境 / 测试环境app.use(morgan(dev))
} else {// 线上环境使用 combined写入文件const logFileName path.join(__dirname, logs, access.log)const writeStream fs.createWriteStream(logFileName, {flags: a})app.use(morgan(combined, {stream: writeStream}));
}同样的修改 package.json 文件
package.json
prd: cross-env NODE_ENVproduction nodemon ./bin/wwwnpm run prd运行文件之后打开几个页面查看 access.log 文件的内容 六、写在最后
至此我们明白了 如何使用 Koa2 框架对我们的 myblog 项目进行进一步的重构实现session、开发路由、联调、日志 本系列文章暂告一段落
如果你需要该项目的 源码请通过本篇文章最下面的方式 加入 进来~~
