pomelo源码分析.docx

Pomelo 框架

Pomelo 启动流程

1.create app 创建应用 // application.js

2.Init app 初始化 //application.js

3.defaultConfiguration 配置// apputil.js

4.setupEnv //配置环境 apputil.js

5.Load master //加载 master apputil.js loadConfigBaseApp //application.js

6.Load servers //加载 servers apputil.js

return this.settings[setting];

}

this.settings[setting] = val;

if(attach) {

this[setting] = val;

}

return this;

};

Application.get = function (setting) {

return this.settings[setting];

utils.invokeCallback(cb, new Error('application has already start.'));

return;

}

var self = this;

appUtil.startByType(self, function() {

appUtil.loadDefaultComponents(self);

var startUp = function() {

appUtil.optComponents(self.loaded, Constants.RESERVED.START, function(err) {

self.state = STATE_START;

if(err) {

Pomelo 框架

};

var beforeFun = self.lifecycleCbs[Constants.LIFECYCLE.BEFORE_STARTUP];

if(!!beforeFun) {

beforeFun.call(null, self, startUp);

} else {

startUp();

}

});

};

加载默认组件 apputil.js

// This.setting[masterconfig]=function{new master;};pomelo.master='__master__'

Pomelo.components[master]=new master; this.loaded={new master }

} else {

app.load(pomelo.proxy, app.get('proxyConfig'));

This.setting[proxyConfig]=function{new proxy;};pomelo.proxy='__proxy__'

Pomelo.components[proxy]=new proxy; this.loaded={new proxy}

if (app.getCurServer().port) {

app.load(pomelo.remote, app.get('remoteConfig'));

This.setting[remoteConfig]=function{new remote;};pomelo.remote='__remote__'

Pomelo.components[remote]=new remote; this.loaded={new remote}

}

app.load(pomelo.connection, app.get('connectionConfig'));

app.load(pomelo.connector, app.get('connectorConfig'));

}

}

app.load(pomelo.backendSession, app.get('backendSessionConfig'));

//This.setting[backendseession]=function{new backendseession;};pomelo.master='__backendseession__'

Pomelo.components[backendseession]=new backendseession; this.loaded={new master,new backendseession }

Pomelo 框架

app.load(pomelo.channel, app.get('channelConfig'));

app.load(pomelo.server, app.get('serverConfig'));

This.setting[serverconfig]=function{new server;};pomelo.channel='__server__'

Pomelo.components[server]=new server; this.loaded={new master,new backendseession,new channel,new server }

}

app.load(pomelo.monitor, app.get('monitorConfig'));

This.setting[monitorconfig]=function{new monitor;};pomelo.channel='__monitor__'

Pomelo.components[monitor]=new monitor; this.loaded={new master,new backendseession,new channel,new server ,new monitor}

Application.load = function(name, component, opts) {

name = component.name;

}

}

if(typeof component === 'function') {

component = component(this, opts);

}

if(!name && typeof component.name === 'string') {

name = component.name;

}

if(name && this.components[name]) {

logger.warn('ignore duplicate component: %j', name);

return;

}

return this;

Pomelo get 追加属性 pomelo.js

_____________pomelo.backendSession ___________load:module.exports = new backendseesion

_____________pomelo.channel ___________load:module.exports = new channel

_____________pomelo.connection ____________load:module.exports = new connection

_____________pomelo.connector ____________load:module.exports = new connector

_____________pomelo.dictionary____________ load:module.exports = new dictionary

_____________pomelo.master____________ load:module.exports = new master

_____________pomelo.monitor____________ load:module.exports = new monitor

Pomelo 框架

fs.readdirSync(__dirname + '/components').forEach(function (filename) {

if (!/\.js$/.test(filename)) {

return;

}

var name = path.basename(filename, '.js');

var _load = load.bind(null, './components/', name);

Pomelo.components.__defineGetter__(name, _load);

Pomelo.__defineGetter__(name, _load);

});

_____________pomelo.serial ___________load:module.exports = new Filter

return;

}

var name = path.basename(filename, '.js');

var _load = load.bind(null, './filters/handler/', name);

Pomelo.filters.__defineGetter__(name, _load);

Pomelo.__defineGetter__(name, _load);

});

_____________pomelo.rpcLog ___________load:module.exports = new Filter

____________ pomelo.toobusy ___________load:module.exports = new Filter

fs.readdirSync(__dirname + '/filters/rpc').forEach(function (filename) {

return;

}

function load(path, name) {

if (name) {

return require(path + name);

}

return require(path);

Start 启动

Application.start = function(cb) {

//开始时间

this.startTime = Date.now();