web.server.js

// =========================================定义基本模块============================================
const path = require('path');
const UUID = require('uuid');
const morgan = require('koa-morgan');
const Koa = require('koa');
const KoaStaticCache = require('koa-static-cache');
const KoaBody = require('koa-body');
const cors = require('koa2-cors');
const createError = require('http-errors');
const ServerPort = process.env.PORT;
const ENV_Production = process.env.NODE_ENV === 'production';
// ==========================================定义全局变量===========================================
const { CookieSession } = require('./constant');
// ==========================================引入核心模块===========================================
const SBiz = require('./base/SBiz');
// ==========================================引入中间件=============================================
const Nunjucks = require('./middleware/nunjucks');
const UserSession = require('./middleware/user-session');
// ===========================================引入数据库驱动管理器====================================
const DBManager = require(`./components/db-client/index.js`);
// ===========================================引入socket===========================================
const SocketIOManager = require(`./components/socket/socket-io`);
// const WebSocket = require(`./components/socket/websocket/wss`);
// ============================================引入redis===========================================
const ClientRedis = require(`./components/db-client/client-redis.js`);
// ===============================================================================================

class WebApp {
    /**
     * 创建数据库链接、定义模型
     */
    async _initDatabase() {
        await DBManager.connectMongodb();
        SBiz.setMysqlInstance(await DBManager.connectMysql());
    }

    async _initRedis() {
        global.DB_Redis = await ClientRedis.getClient();
    }

    async createDefaultApp() {
        await this._initDatabase();
        await this._initRedis();

        const app = new Koa({ keys: CookieSession.CookieKeys });
        app.on('error', (err, ctx) => {
            console.error('Oh~Oh~Oh!!!! Find An Error Inner Api');
            console.error(err);
        });
        app.use(cors());
        app.use(morgan('dev'));
        app.use(KoaStaticCache(__dirname + '/assets', { maxAge: 30 * 24 * 60 * 60 })); //建议加cdn
        app.use(KoaBody({
            multipart: true,
            encoding: 'utf-8',
            formidable: {
                uploadDir: __dirname + '/assets/uploaded',// TODO use oss
                keepExtensions: true,
                maxFieldsSize: 5 * 1024 * 1024,
                onFileBegin: (name, file) => {
                    // console.log('onFileBegin', name, file)
                    //TODO file.path = '/data/www/web-node/upload/upload_8test.jpg';//此处可以修改file来做修改的，比如按照年/月/日创建层级目录
                },
            },
        }));

        app.use(Nunjucks(path.join(__dirname, 'view'), { noCache: !ENV_Production, watch: !ENV_Production }));
        app.use(UserSession.loadSessionFromRedis());

        const Router = require('./router');
        app.use(Router.routerWeb.routes());
        app.use(Router.routerWeb.allowedMethods());

        this.app = app;

        this.start();

        process.on('uncaughtException', function (err) {
            console.log('【Web Server uncaughtException', err);
        });
        process.on('SIGINT', this.stop);
    }

    start() {
        this.http_server = this.app.listen(ServerPort, () => {
            console.log('【web】 http://127.0.0.1:' + ServerPort + '/ 启动完成！进程号：' + process.pid);
        });
        new SocketIOManager(this.http_server).build();
        // require(`./components/socket/websocket/wss`)(this.http_server); //TODO remove me
    }

    stop(sth) {
        process.nextTick(() => {
            DBManager.close((err) => {
                console.log('【Web Server Stopped】', sth, err);
                process.exit(0);
            });
        });
    }
}

new WebApp().createDefaultApp();