private void initConf() {
try {
String logpath = context.getConfigPath() + File.separator + "log4j.properties";
PropertyConfigurator.configure(logpath);
logger.info(String.format("log4j path:%s", logpath));
String serverpath = context.getConfigPath() + File.separator + "server.properties";
NettyServerConfig config = GuiceDI.getInstance(NettyServerConfig.class);
PropertiesHelper pro = new PropertiesHelper(serverpath);
config.setSelectorThreads(pro.getInt("selectorThreads"));
config.setWorkerThreads(pro.getInt("workerThreads"));
config.setListenPort(pro.getInt("server.Port"));
config.setUsezk(pro.getBoolean("use.zk"));
config.setZkhosts(pro.getString("zk.hosts"));
logger.info(JSON.toJSONString(config));
} catch (Exception e) {
logger.error("", e);
}
}
RPCServer.java 文件源码
java
阅读 30
收藏 0
点赞 0
评论 0
项目:TakinRPC
作者:
评论列表
文章目录