koa2Example

参考链接

koa生成器一键生成koa项目

项目生成

npm 生成

npm install koa-generator -g
koa2 projectName

项目结构

bin
    www             --入口文件
node_modules
app
    model           --数据库表结构
    service         --数据库CRUD操作
    util            --工具方法
config              --配置文件，如数据库连接密码
middleware          --中间件(拦截器)
public              --mvc相关资源(mvvm则缺省)
    images
    javascripts
    stylesheets
routes(controller)  --路由(接收请求处理逻辑)
    ***.js
views               --mvc视图(mvvm则在其中建项目)
    ***.pug
app.js              --主程序配置
package.json

中间件

中间件可理解为拦截器，处理请求和响应

中间件引入样例

app.js

const json = require('koa-json')
app.use(json())

普通中间件

app.use(async (ctx, next) => {
    const start = new Date()
    await next()
    const ms = new Date() - start
    console.log(`${ctx.method} ${ctx.url} - ${ms}ms`)
})

抽离到文件,在app.js引入即可

function doSomething(ctx) {
    console.log('doSomething')
}

var interceptor = () => async (ctx,next) => {
    doSomething(ctx)
    await next()
}

module.exports = interceptor;

路由中间件

let authoization = async (ctx, next) => {
    //不满足条件，可直接响应，没next则没后续
    //ctx.body = {
    //    message: 'exception',
    //    code: -1
    //}

    //ctx.response.redirect('/');

    //满足条件就next
    //await next()
}

router.all('*', async (ctx, next) => {
    authoization(ctx, next)
})

module.exports = router;

日志

参考： koa2学习笔记02 - 给koa2添加系统日志 —— node日志管理模块log4js

控制台打印

使用koa-logger
文件日志

使用koa-log4

密文密码

参考：

Koa2用户注册生成密文密码及用户登录时生成token返回

nodejs中的bcryptjs密码加密

bcrypt报错则使用bcryptjs

npm install bcryptjs --save
var bcrypt = require('bcryptjs');
var hash = bcrypt.hashSync('bacon', 10);
bcrypt.compareSync("bacon", hash);
bcrypt.compareSync("not_bacon", hash);

路由循环引入

配置路由路径对象

const routePath = {
    'test': '../routes/test',
    ...
}

middleware提供循环方法，传入app

let activateRoutes = (app) => {
    let routes = [];
    let index = 0;
    for(let key in routePath){
        routes[index] = require(routePath[key]);
        app.use(routes[index].routes(), routes[index].allowedMethods());
        index++;
    }
    return app;
}

跨域配置

router.all('*', async (ctx, next) => {
    //console.log('all: /api/mockServer')
    ctx.set("Access-Control-Allow-Origin", "*");  // 规定允许访问该资源的外域 URI
    ctx.set('Access-Control-Allow-Methods', '*');  // 请求方式
    ctx.set("Access-Control-Max-Age", "3600");  // 设定预检请求结果的缓存时间
    ctx.set("Access-Control-Allow-Headers", "apk");  //  规定 CORS 请求时会额外发送的头信息字段
    ctx.set("Access-Control-Allow-Credentials", "true");  // 请求可以带 Cookie 等
    //ctx.set('Access-Control-Allow-Headers', 'Content-Type, Authorization, Content-Length, X-Requested-With');
    ctx.set("Content-Type", "application/json;charset=utf-8");

    console.log('ctx.request.method:',ctx.request.method)
    // 针对预检请求
    if (ctx.request.method == "OPTIONS") {
        ctx.response.stutas = "200"
        ctx.body = 'OPTIONS';
    }

    try {
        await next();
        //console.log("处理通过");
    } catch (e) {
        //console.log("处理错误");
        ctx.response.status = e.statusCode || err.status || 500;
        ctx.response.body = {
            message: e.message
        }
    }
})

白名单模拟路由匹配

const path = [
    '/',
    '/index',
    '/api/*'
]
const url = '/api/check'
function passThrough(path,url) {
    let flag = false;
    for(let i = 0;i < path.length;i++){
        if(path[i] === '*'){
            flag = true;
            break;
        }else{
            let pathParts = path[i].split('/');
            let urlParts = url.split('/');
            let pathMatch = true;
            for(let j = 0;j < pathParts.length;j++){
                if(pathParts[j] !== urlParts[j] && pathParts[j] !== '*'){
                    pathMatch = false;
                }
            }
            if(pathMatch){
                flag = true;
                break;
            }
        }
    }
    return flag;
}

SQL模拟LINQ

const tableName = 'users';

const usersRepository = {
    findAllUser: async () => {
        return await new connector().selectAllFromTable(tableName).execute();
    },
    addUserData: async (model) => {
        return await new connector().insertDataToTable(tableName,model).execute();
    },
    findUser: async (name) => {
        return await new connector().selectAllFromTable(tableName).whereAllEquals({name:name}).execute();
    },
}

let pools = {};

//判断是否存在连接池不用每次都创建
if (!pools.hasOwnProperty('data')) {
    pools['data'] = mysql.createPool({
        host: config.database.HOST,
        user: config.database.USERNAME,
        password: config.database.PASSWORD,
        database: config.database.DATABASE
    });
}

// 查询  
// sql 是sql语句
// values 是sql语句中的具体值
// sql values 可查看官方文档 https://github.com/mysqljs/mysql#performing-queries
const query = (sql, values) => {
    return new Promise((resolve, reject) => {
        //初始化连接池
        pools['data'].getConnection((err, connection) => {
            if (err) {
                console.log(err,'数据库连接失败');
                reject(err);
            }
            else{
            	console.log('数据库连接成功');
                //操作数据库
	            connection.query(sql, values, (err, results) => {
	                if (err) {
                        console.log(err);
	                	reject(err);
	                } else {
                        console.log(results);
	                	connection.release();
	                	resolve(results);
	                }
	            });
            }
        })
    });
}

const connector = class{
    constructor(){
        this.sql = ''
    }
    
    getStatement() {
        return this.sql;
    }
    execute() {
        global.logHandle('execute')
        return query(this.sql);
    }
    columnName(name) {
        global.logHandle('columnName')
        this.sql += ` ${name}`;
        global.logHandle(this.sql);
        return this;
    }
    operator(operation) {
        global.logHandle('operator')
        this.sql += ` ${operation}`;
        global.logHandle(this.sql);
        return this;
    }
    condition(condition) {
        global.logHandle('condition')
        this.sql += ` ${condition}`;
        global.logHandle(this.sql);
        return this;
    }
    selectAllFromTable(tableName) {
        global.logHandle('selectAllFromTable')
        this.sql += `select * from ${tableName}`;
        global.logHandle(this.sql);
        return this;
    }
    selectSomeFromTable(tableName,columnNames,distinct = false,top = '') {
        global.logHandle('selectSomeFromTable')
        if(distinct){
            if(top){
                this.sql += `select distinct top ${top} ${columnNames.join(" ")} from ${tableName}`;
            }else{
                this.sql += `select distinct ${columnNames.join(" ")} from ${tableName}`;
            }
        }else{
            if(top){
                this.sql += `select top ${top} ${columnNames.join(" ")} from ${tableName}`;
            }else{
                this.sql += `select ${columnNames.join(" ")} from ${tableName}`;
            }
        }
        global.logHandle(this.sql);
        return this;
    }
    insertDataToTable(tableName,model) {
        global.logHandle('insertDataToTable')
        this.sql += `insert into ${tableName} set `;
        let index = 0;
        for(let key in model){
            if(index === 0){
                this.sql += `${key} = '${model[key]}'`;
                index++;
            }
            else{
                this.sql += `,${key} = '${model[key]}'`;
            }
        }
        global.logHandle(this.sql);
        return this;
    }
    whereStatement(statement) {
        global.logHandle('whereStatement')
        this.sql += ` where ${statement}`;
        global.logHandle(this.sql);
        return this;
    }
    whereAllEquals(model) {
        global.logHandle('whereAllEquals')
        let index = 0;
        for(let key in model){
            if(index === 0){
                this.sql += ` where ${key} = '${model[key]}'`;
                index++;
            }
            else{
                this.sql += ` and ${key} = '${model[key]}'`;
            }
        }
        global.logHandle(this.sql);
        return this;
    }
    orderBy(key) {
        global.logHandle('orderBy')
        this.sql += ` order by ${key}`;
        global.logHandle(this.sql);
        return this;
    }
    orderByDesc(key) {
        global.logHandle('orderByDesc')
        this.sql += ` order by ${key} desc`;
        global.logHandle(this.sql);
        return this;
    }
    groupBy(key,condition = '') {
        global.logHandle('groupBy')
        this.sql += ` group by ${key}`;
        if(condition){
            this.sql += ` ${condition}`;
        }
        global.logHandle(this.sql);
        return this;
    }
    limit(begin,count = '') {
        global.logHandle('limit')
        this.sql += ` limit ${begin}`;
        if(count){
            this.sql += `,${count}`;
        }
        global.logHandle(this.sql);
        return this;
    }
    combine(sql) {
        global.logHandle('combine')
        this.sql += ` ${sql}`;
        global.logHandle(this.sql);
        return this;
    }
}

前端埋点监控信息记录

无埋点方案
- 多页面
  
  每次进入页面采集浏览器信息、性能数据，点击、复制、错误触发上报，关闭上报停留时间
- 单页面
  
  只采集一次浏览器信息、性能数据，URL改变触发hashchange、pushstate上报停留时间，点击、复制、错误触发上报，关闭上报停留时间

监听单页面URL变化

let historyEvent = function(type) {
    let origin = history[type];
    return function() {
        let result = origin.apply(this, arguments);
        let event = new Event(type);
        event.arguments = arguments;
        window.dispatchEvent(event);
        return result;
    };
};
history.pushState = historyEvent('pushState');
history.replaceState = historyEvent('replaceState');

window.addEventListener('replaceState', function(e) {
    console.log('replaceState');
});
window.addEventListener('pushState', function(e) {
    console.log('pushState');
});

function getClientIP(req) {
    return (req.headers ? (req.headers['x-forwarded-for'] || req.headers['x-real-ip']) : null) || // 判断是否有反向代理 IP
        (req.connection ? (req.connection.remoteAddress || (req.connection.socket ? req.connection.socket.remoteAddress : null)) : null) || // 判断 connection 的远程 IP
        (req.socket ? req.socket.remoteAddress : null) || // 判断后端的 socket 的 IP
        'unknown';
}

let model = myUtil.deepClone(monitorBrowserModel);
let body = JSON.parse(ctx.request.body);
for(let key in model){
    model[key] = JSON.stringify(body[key]);
}
model.ip = myUtil.getClientIP(ctx.request.header);
model.time = new Date().getTime();
delete model.id;
let result = await monitorRepository.addBrowserData(model);

browser

CREATE TABLE `browser_monitor` (
  `id` int(10) unsigned NOT NULL AUTO_INCREMENT,
  `browserVersion` varchar(100) DEFAULT NULL,
  `browserVersionNumber` varchar(100) DEFAULT NULL,
  `browserName` varchar(100) DEFAULT NULL,
  `os` varchar(100) DEFAULT NULL,
  `netType` varchar(100) DEFAULT NULL,
  `language` varchar(100) DEFAULT NULL,
  `platform` varchar(100) DEFAULT NULL,
  `model` varchar(100) DEFAULT NULL,
  `domain` varchar(100) DEFAULT NULL,
  `url` varchar(300) DEFAULT NULL,
  `title` varchar(100) DEFAULT NULL,
  `referrer` varchar(300) DEFAULT NULL,
  `lastModified` varchar(100) DEFAULT NULL,
  `cookie` varchar(500) DEFAULT NULL,
  `characterSet` varchar(100) DEFAULT NULL,
  `screenHeight` varchar(100) DEFAULT NULL,
  `screenWidth` varchar(100) DEFAULT NULL,
  `colorDepth` varchar(100) DEFAULT NULL,
  `devicePixelRatio` varchar(100) DEFAULT NULL,
  `dnsTime` varchar(100) DEFAULT NULL,
  `tcpTime` varchar(100) DEFAULT NULL,
  `firstPaintTime` varchar(100) DEFAULT NULL,
  `FirstContentfulPaintTime` varchar(100) DEFAULT NULL,
  `domRenderTime` varchar(100) DEFAULT NULL,
  `loadTime` varchar(100) DEFAULT NULL,
  `ip` varchar(100) DEFAULT NULL,
  `time` varchar(200) DEFAULT NULL,
  `performance` varchar(2000) DEFAULT NULL,
  `redirectTime` varchar(200) DEFAULT NULL,
  `redirectCount` int(11) DEFAULT NULL,
  `sslTime` varchar(200) DEFAULT NULL,
  `requestTime` varchar(200) DEFAULT NULL,
  `responseTime` varchar(200) DEFAULT NULL,
  `domExplainTime` varchar(200) DEFAULT NULL,
  `resourceLoadTime` varchar(200) DEFAULT NULL,
  `domAnalysisTime` varchar(200) DEFAULT NULL,
  `blankTime` varchar(200) DEFAULT NULL,
  `firstInteractiveTime` varchar(200) DEFAULT NULL,
  `domReadyTime` varchar(200) DEFAULT NULL,
  `loadCompleteTime` varchar(200) DEFAULT NULL,
  `entriesInfo` varchar(2000) DEFAULT NULL,
  `jsCount` int(11) DEFAULT NULL,
  `cssCount` int(11) DEFAULT NULL,
  `xhrCount` int(11) DEFAULT NULL,
  `imgCount` int(11) DEFAULT NULL,
  `resourceCount` int(11) DEFAULT NULL,
  `jsLoadTime` varchar(200) DEFAULT NULL,
  `cssLoadTime` varchar(200) DEFAULT NULL,
  `xhrLoadTime` varchar(200) DEFAULT NULL,
  `imgLoadTime` varchar(200) DEFAULT NULL,
  `userAgent` varchar(200) DEFAULT NULL,
  PRIMARY KEY (`id`),
  UNIQUE KEY `idbrowser_monitor_UNIQUE` (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=36 DEFAULT CHARSET=utf8;

error

CREATE TABLE `error_monitor` (
  `id` int(10) unsigned NOT NULL AUTO_INCREMENT,
  `url` varchar(200) DEFAULT NULL,
  `type` varchar(100) DEFAULT NULL,
  `row` int(11) DEFAULT NULL,
  `col` int(11) DEFAULT NULL,
  `source` varchar(200) DEFAULT NULL,
  `msg` varchar(2000) DEFAULT NULL,
  `ip` varchar(100) DEFAULT NULL,
  `time` varchar(200) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=17 DEFAULT CHARSET=utf8;

event

CREATE TABLE `event_monitor` (
  `id` int(10) unsigned NOT NULL AUTO_INCREMENT,
  `eventType` varchar(100) DEFAULT NULL,
  `happenTime` varchar(200) DEFAULT NULL,
  `content` varchar(2000) DEFAULT NULL,
  `ip` varchar(100) DEFAULT NULL,
  `time` varchar(200) DEFAULT NULL,
  `url` varchar(200) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=65 DEFAULT CHARSET=utf8;

request

CREATE TABLE `request_monitor` (
  `id` int(10) unsigned NOT NULL AUTO_INCREMENT,
  `requestMethod` varchar(20) DEFAULT NULL,
  `requestOriginalUrl` varchar(200) DEFAULT NULL,
  `ip` varchar(200) DEFAULT NULL,
  `requestContent` varchar(2000) DEFAULT NULL,
  `responseTime` varchar(200) DEFAULT NULL,
  `responseStatus` varchar(200) DEFAULT NULL,
  `responseContent` varchar(2000) DEFAULT NULL,
  `time` varchar(200) DEFAULT NULL,
  PRIMARY KEY (`id`),
  UNIQUE KEY `id_UNIQUE` (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=29 DEFAULT CHARSET=utf8;

stay

CREATE TABLE `stay_monitor` (
  `id` int(10) unsigned NOT NULL AUTO_INCREMENT,
  `url` varchar(200) DEFAULT NULL,
  `stayTime` int(11) DEFAULT NULL,
  `ip` varchar(100) DEFAULT NULL,
  `time` varchar(200) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=33 DEFAULT CHARSET=utf8;

blob视频流

首页

dash.js ffmpeg mp4->m4s url.createObjectURL

为什么视频网站的视频链接地址是blob？

详解并探究blob:http:// 视频格式流

通过BLOB加密视频文件

前端video标签播放m3u8格式视频

生产环境pm2相关

使用PM2将Node.js的集群变得更加容易

PM2常用命令

任意一个工作线程挂掉了，PM2会立即将其重启

命令
- 启动
  
  pm2 start <应用入口> (-i <线程数>)
- 重启
  
  pm2 restart all
  
  pm2 restart <进程int>
- 重载
  
  pm2 reload all
  
  pm2 reload <进程int>
- 增加线程
  
  pm2 scale <应用入口> <线程数>
- 服务器重启后自动运行之前的应用
  
  start后执行:pm2 save
  
  这将在~/.pm2目录下生成一个dump.pm2文件，里面描述了当前PM2上运行着的所有应用。然后执行命令：pm2 startup (<当前的系统环境>)
- 停止
  
  pm2 stop all
  
  pm2 stop <进程int>
- 删除进程
  
  pm2 delete all
  
  pm2 delete <进程int>
- 日志
  
  pm2 logs [--raw]
  
  pm2 flush
  
  pm2 reloadLogs
- 监控
  
  pm2 monit
- 查看进程
  
  pm2 list
  
  pm2 show <进程int>
  
  pm2 info <进程int>

chromeDebug

node --inspect bin/www

打开devtools工具

chrome console 可展开object

单元测试

koa单元测试

自动生成文档

swagger-jsdoc

koa2-swagger-ui

Swagger Petstore

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Repository files navigation

koa2Example

参考链接

目录

项目生成

中间件

日志

密文密码

路由循环引入

跨域配置

白名单模拟路由匹配

SQL模拟LINQ

前端埋点监控信息记录

blob视频流

生产环境pm2相关

chromeDebug

单元测试

自动生成文档

About

Releases

Packages

Languages

Name		Name	Last commit message	Last commit date
Latest commit History 35 Commits
app		app
bin		bin
config		config
middleware		middleware
public		public
routes		routes
test		test
views		views
.gitignore		.gitignore
app.js		app.js
package-lock.json		package-lock.json
package.json		package.json
readme.md		readme.md

zhaoyangkanshijie/koa2Example

Folders and files

Latest commit

History

Repository files navigation

koa2Example

参考链接

目录

项目生成

中间件

日志

密文密码

路由循环引入

跨域配置

白名单模拟路由匹配

SQL模拟LINQ

前端埋点监控信息记录

blob视频流

生产环境pm2相关

chromeDebug

单元测试

自动生成文档

About

Topics

Resources

Stars

Watchers

Forks

Releases

Packages 0

Languages

Packages