Koa搭建简单服务器

"co-mysql": "^1.0.0",
"koa": "^2.7.0",
"koa-better-body": "^3.0.4",
"koa-ejs": "^4.2.0",
"koa-router": "^7.4.0",
"koa-session": "^5.12.0",
"koa-static": "^5.0.0",
"mysql": "^2.17.1"

 1 const fs = require(‘fs‘);
 2 const path = require(‘path‘);
 3 const Koa = require(‘koa‘);
 4 const Router = require(‘koa-router‘);
 5 const session = require(‘koa-session‘);
 6 const ejs = require(‘koa-ejs‘);
 7 const body = require(‘koa-better-body‘);
 8 
 9 const _static = require(‘./routers/static‘);
10 const config = require(‘./config‘);
11 
12 const app = new Koa();
13 const router = new Router();

1 router.all(‘*‘, async (ctx, next) => { // * 表示所有的请求，都会经过这里的处理
2     try {
3         await next();
4     } catch (e) {
5         ctx.throw(500, e);
6     }
7 });

1 ejs(app, {
2     root: path.resolve(__dirname, ‘template‘), // 模版路劲
3     layout: false, // 使用 render 方法渲染模版时有所区别，如果省略，会去找 template/layout.ejs
　　　　　　　　　　　　 // false: ctx.render(‘admin/index.ejs‘) ‘abc‘: ctx.render(‘abc/admin/index.ejs‘)
4     viewExt: ‘ejs‘,// 模版后缀名
5     cache: false,  // 缓存
6     debug: false   // 如果是 true，会把编译之后的内容全部输出
7 });

1 router.use(‘/admin‘, require(‘./routers/admin‘)); // localhost:8080/admin/xxx
2 router.use(‘/api‘, require(‘./routers/api‘)); // localhost:8080/api/xxx
3 router.use(‘‘, require(‘./routers/www‘)); // ‘‘ 表示根，localhost:8080/xxx

_static(router, {
    imageMaxAge: config.imageMaxAge,
    scriptMaxAge: config.scriptMaxAge,
    styleMaxAge: config.styleMaxAge,
    htmlMaxAge: config.htmlMaxAge,
    otherMaxAge: config.otherMaxAge
});
/*
　　// 上面只是封装了, 比如
　　// ...
　　const static = require(‘koa-static‘);
　　// ...
　　router.all(/\.jsx?/i, static(path, options));
*/

1 app.keys = fs.readFileSync(‘.keys‘).toString().split(‘\r\n‘);
2 app.use(session({
3     maxAge: 20 * 60 * 1000, // 缓存时间 20 分钟
4     renew: true // 自动续期
5 }, app));

1 app.use(body({
2     uploadDir: config.UPLOAD_DIR
3 }));

1 app.context.db = require(‘./libs/database‘); // app.context 相当于 ctx 的原型，所以，可以使用 ctx.db,query(sql语句) 来操作数据库

1 app.context.config = config;

1 app.listen(config.HTTP_PORT, () => console.log(`Server running on ${config.HTTP_PORT}...`));
2 app.use(router.routes());

 1 const mysql = require(‘mysql‘);
 2 const co = require(‘co-mysql‘);
 3 
 4 const config = require(‘../config‘);
 5 
 6 const conn = mysql.createPool({
 7     host: config.DB_HOST,
 8     user: config.DB_USER,
 9     password: config.DB_PASS,
10     port: config.DB_PORT,
11     database: config.DB_NAME
12 });
13 
14 module.exports = co(conn);

 1 const crypto = require(‘crypto‘);
 2 const config = require(‘../config‘);
 3 
 4 module.exports = {
 5     // 生成 md5 值
 6     md5 (buffer) {
 7         const obj = crypto.createHash(‘md5‘);
 8         obj.update(buffer + config.MD5_KEYS);
 9         return obj.digest(‘hex‘);
10     }
11 };