loadService() {
    const services = fs.readdirSync(__dirname + '/service');
    const loaded = {};

    services.forEach(serivce => {
        const name = serivce.split('.')[0];
        const mod = require(__dirname + '/service/' + services);
        loaded[name] = new mod(this);
    })

    Object.defineProperty(this.app.context, 'service', {
        get() {
            return loaded
        }
    })
}

import { Burn } from './core';
import * as cluster from 'cluster';
import * as os from 'os';
import { EventEmitter } from 'events';


export default class BurnCluster extends EventEmitter {
    constructor() {
        super();
    }

    forkWorkers() {
        const numCPUs = os.cpus().length;

        if (cluster.isMaster) {
            // Fork workers.

            console.log(`master进程#${process.pid}`)
            for (let i = 0; i < numCPUs; i++) {
                cluster.fork();
            }
            cluster.on('fork', function (worker) {
                console.log('worker ' + worker.process.pid + ' start');
                worker.on('message', (msg) => {
                    console.log(msg + 'from ' + worker.process.pid)
                })
            })

            cluster.on('online', function (worker) {
                worker.disconnect();
            })

            cluster.on('exit', function (worker, code, signal) {
                console.log('worker ' + worker.process.pid + ' died');
                // cluster.fork();
            });

            cluster.on('disconnect', function (worker) {
                if (worker.isDead) {
                    console.log('工作进程 #' + worker.id + ' 已经死亡');
                }
                console.log('工作进程 #' + worker.id + ' 断开了连接');
            })

            cluster.on('listening', (worker, address) => {

            });


        } else {
            const app = new Burn;

            app.run();

            // process.on('message', function (msg) {
            //     console.log('3:', msg);
            // });

            // (<any>process).send('你好');
        }
    }
    startCluster() {
        this.forkWorkers();
    }
}