优化项目

Author: twjitm

src/main/java/com/twjitm/core/bootstrap/Bootstrap.java

@@ -34,6 +34,7 @@ public class Bootstrap {
 
  public static void main(String[] args) {
  getBuddha();
+
  SystemService.getSystem();
  Bootstrap.init();
  Bootstrap.startServer();

src/main/java/com/twjitm/core/common/config/global/NettyGameServiceConfig.java

@@ -74,6 +74,10 @@ public class NettyGameServiceConfig {
  * 是否开启生命周期任务
  */
  private boolean lifeCycleOpen;
+ /**
+ * 是否开启kafka组件
+ */
+ private boolean kakfkaOpen;
 
 
  public void init() {
@@ -95,7 +99,8 @@ public void init() {
  rpcSendProxyThreadSize = Integer.parseInt(properties.getProperty("rpcSendProxyThreadSize"));
  rpcOpen = Boolean.parseBoolean(properties.getProperty("rpcOpen"));
  zookeeperOpen = Boolean.parseBoolean(properties.getProperty("zookeeperOpen"));
- lifeCycleOpen=Boolean.parseBoolean(properties.getProperty("lifeCycleOpen"));
+ lifeCycleOpen = Boolean.parseBoolean(properties.getProperty("lifeCycleOpen"));
+ kakfkaOpen=Boolean.parseBoolean(properties.getProperty("kafkaOpen"));
  } catch (IOException e) {
  e.printStackTrace();
  }
@@ -205,4 +210,8 @@ public boolean isLifeCycleOpen() {
  public void setLifeCycleOpen(boolean lifeCycleOpen) {
  this.lifeCycleOpen = lifeCycleOpen;
  }
+
+ public boolean isKakfkaOpen() {
+ return kakfkaOpen;
+ }
 }

src/main/java/com/twjitm/core/common/utils/PackageScaner.java

@@ -134,9 +134,10 @@ public static void main(String[] args) {
 
  /**
  * get parent class to subclass
- * @param parentClass
- * @param packagePath
- * @return
+ *
+ * @param parentClass 父类
+ * @param packagePath 位置
+ * @return 子类集和
  */
  public static List<Class> getSubClasses(final Class parentClass,
  final String packagePath) {

src/main/java/com/twjitm/core/service/rpc/service/HelloWorldImpl.java

@@ -1 +1 @@
-package com.twjitm.core.service.rpc.service;import com.twjitm.core.common.annotation.NettyRpcServiceAnnotation;import com.twjitm.core.utils.logs.LoggerUtils;import org.apache.log4j.Logger;import org.springframework.stereotype.Repository;/** * @author twjitm - [Created on 2018-08-20 10:26] * @jdk java version "1.8.0_77" * 这个地方一定是注入的是业务对象的接口~~~~~~~~~~~~~~~~ */@NettyRpcServiceAnnotation(IHelloWorld.class)@Repositorypublic class HelloWorldImpl implements IHelloWorld { private Logger logger = LoggerUtils.getLogger(HelloWorldImpl.class); @Override public String getHelloWorld(int number) { StringBuilder builder = new StringBuilder(); for (int i = number; i > 0; i--) { builder.append("helloworld"); builder.append(i); } System.out.println("rpc 远程调用方法成功。。。。。，即将返回给远程客户端调用"); return builder.toString(); }}
+package com.twjitm.core.service.rpc.service;import com.twjitm.core.common.annotation.NettyRpcServiceAnnotation;import com.twjitm.core.utils.logs.LoggerUtils;import org.apache.log4j.Logger;import org.springframework.stereotype.Repository;/** * @author twjitm - [Created on 2018-08-20 10:26] * @jdk java version "1.8.0_77" * 这个地方一定是注入的是业务对象的接口~~~~~~~~~~~~~~~~ */@NettyRpcServiceAnnotation(IHelloWorld.class)@Repositorypublic class HelloWorldImpl implements IHelloWorld { private Logger logger = LoggerUtils.getLogger(HelloWorldImpl.class); @Override public String getHelloWorld(int number) { StringBuilder builder = new StringBuilder(); for (int i = number; i > 0; i--) { builder.append("helloworld"); builder.append(i); } System.out.println("rpc 远程调用方法成功。。。。。，即将返回给远程客户端调用"); return builder.toString(); } class Task implements Runnable{ @Override public void run() { } }}

src/main/java/com/twjitm/core/spring/SpringServiceManager.java

@@ -1,8 +1,12 @@
 package com.twjitm.core.spring;
 
+import com.twjitm.core.common.config.global.NettyGameServiceConfig;
 import org.apache.log4j.Logger;
 import org.springframework.context.support.ClassPathXmlApplicationContext;
 
+import java.util.ArrayList;
+import java.util.List;
+
 /**
  * spring service manager
  *
@@ -13,14 +17,24 @@ public class SpringServiceManager {
  static Logger logger = Logger.getLogger(SpringServiceManager.class);
 
  public static void init() {
+ NettyGameServiceConfig gameServiceConfig=new NettyGameServiceConfig();
+ gameServiceConfig.init();
  logger.info("--------------------init spring bootstrap----------------");
+ List<String> application = new ArrayList<>();
+ application.add("classpath:spring/applicationContext.xml");
+ application.add("classpath:spring/applicationContext-spring.xml");
+ application.add("classpath:spring/applicationContext-async-task.xml");
+ if(gameServiceConfig.isKakfkaOpen()){
+ application.add("classpath:spring/applicationContext-kafka-producer.xml");
+ application.add("classpath:spring/applicationContext-kafka.consumer.xml");
+ }
+
+ String[] strings = new String[application.size()];
+ for (int i=0;i<application.size();i++) {
+ strings[i]=application.get(i);
+ }
+ ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext(strings);
 
- ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext(
- "classpath:spring/applicationContext.xml",
- "classpath:spring/applicationContext-spring.xml",
- "classpath:spring/applicationContext-async-task.xml",
- "classpath:spring/applicationContext-kafka-producer.xml",
- "classpath:spring/applicationContext-kafka.consumer.xml");
 
  logger.info("--------------------init spring end------------------");
  springLoadService = (SpringLoadServiceImpl) applicationContext.getBean("springLoadService");

src/main/resources/bean/game-properties.properties

@@ -1 +1 @@
-#版本号serverVersion=0.0.100#主机地址serverHost=0.0.0.0#端口号serverPort=11010#服务器idserverId=18001#rpc服务的包名字rpcServicePackageName=com.twjitm.core.service.rpc.service#异步线程池核心大小asyncThreadPoolCoreSize=5#异步线程最大大小asyncThreadPoolMaxSize=5#rpc回调超时时间rpcFutureDeleteTimeOut=2000#rpc请求超时时间rpcTimeOut=5000#rpc连接线程池大小rpcConnectThreadSize=5#rpc连接线程池大小rpcSendProxyThreadSize=5#开启rpcrpcOpen=true#是否开启zookeeperzookeeperOpen=false#是否开启周期性检测lifeCycleOpen=false
+#版本号serverVersion=0.0.100#主机地址serverHost=0.0.0.0#端口号serverPort=11010#服务器idserverId=18001#rpc服务的包名字rpcServicePackageName=com.twjitm.core.service.rpc.service#异步线程池核心大小asyncThreadPoolCoreSize=5#异步线程最大大小asyncThreadPoolMaxSize=5#rpc回调超时时间rpcFutureDeleteTimeOut=2000#rpc请求超时时间rpcTimeOut=5000#rpc连接线程池大小rpcConnectThreadSize=5#rpc连接线程池大小rpcSendProxyThreadSize=5#开启rpcrpcOpen=true#是否开启zookeeperzookeeperOpen=false#是否开启周期性检测lifeCycleOpen=false#是否开启kafkakafkaOpen=true

src/main/resources/bean/rpc-server-register.xml

@@ -2,7 +2,8 @@
 <servers>
 
  <world>
- <server serverId="8001" domain="127.0.0.1" domainPort="11010" ip="127.0.0.1" port="11010" weight="100" maxNumber="1000" rpcPort="11040" rpcClientNumber="3"/>
+ <server serverId="18001" domain="127.0.0.1" domainPort="11010" ip="127.0.0.1" port="11010" weight="100" maxNumber="1000" rpcPort="11040" rpcClientNumber="3"/>
+
  <server serverId="9001" domain="47.93.22.194" domainPort="11010" ip="47.93.22.194" port="11010" weight="100" maxNumber="1000" rpcPort="11040" rpcClientNumber="3"/>
  </world>
 

src/test/java/com/twjitm/rpc/HelloWorldServiceTest.java

@@ -1 +1 @@
-package com.twjitm.rpc;import com.twjitm.TestSpring;import com.twjitm.core.common.enums.NettyGameTypeEnum;import com.twjitm.core.common.service.rpc.client.NettyRpcContextHolder;import com.twjitm.core.common.service.rpc.client.NettyRpcContextHolderObject;import com.twjitm.core.common.service.rpc.service.NettyRpcProxyService;import com.twjitm.core.service.rpc.service.IHelloWorld;import com.twjitm.core.spring.SpringServiceManager;import org.slf4j.Logger;import org.slf4j.LoggerFactory;/** * @author EGLS0807 - [Created on 2018-08-20 15:16] * @company http://www.g2us.com/ * @jdk java version "1.8.0_77" * * 同步阻塞调用 */public class HelloWorldServiceTest { Logger logger=LoggerFactory.getLogger(HelloWorldServiceTest.class); private NettyRpcProxyService nettyRpcProxyService; public static void main(String[] args) { TestSpring.initSpring(); HelloWorldServiceTest helloServiceTest = new HelloWorldServiceTest(); helloServiceTest.init(); helloServiceTest.helloTest1(); helloServiceTest.setTear(); } private void init() { nettyRpcProxyService=SpringServiceManager.getSpringLoadService().getNettyRpcProxyService(); } private void helloTest1() { IHelloWorld helloWorld = nettyRpcProxyService.createProxy(IHelloWorld.class); int serverId=9001; NettyRpcContextHolderObject rpcContextHolderObject = new NettyRpcContextHolderObject(NettyGameTypeEnum.WORLD, serverId); NettyRpcContextHolder.setContextHolder(rpcContextHolderObject); String result = helloWorld.getHelloWorld(5); logger.info(result); } public void setTear(){ if (nettyRpcProxyService != null) { try { nettyRpcProxyService.shutdown(); } catch (Exception e) { e.printStackTrace(); } } }}
+package com.twjitm.rpc;import com.twjitm.TestSpring;import com.twjitm.core.common.enums.NettyGameTypeEnum;import com.twjitm.core.common.service.rpc.client.NettyRpcContextHolder;import com.twjitm.core.common.service.rpc.client.NettyRpcContextHolderObject;import com.twjitm.core.common.service.rpc.service.NettyRpcProxyService;import com.twjitm.core.service.rpc.service.IHelloWorld;import com.twjitm.core.spring.SpringServiceManager;import org.slf4j.Logger;import org.slf4j.LoggerFactory;/** * @author EGLS0807 - [Created on 2018-08-20 15:16] * @company http://www.g2us.com/ * @jdk java version "1.8.0_77" * * 同步阻塞调用 */public class HelloWorldServiceTest { Logger logger=LoggerFactory.getLogger(HelloWorldServiceTest.class); private NettyRpcProxyService nettyRpcProxyService; public static void main(String[] args) { TestSpring.initSpring(); HelloWorldServiceTest helloServiceTest = new HelloWorldServiceTest(); helloServiceTest.init(); helloServiceTest.helloTest1(); helloServiceTest.setTear(); } private void init() { nettyRpcProxyService=SpringServiceManager.getSpringLoadService().getNettyRpcProxyService(); } private void helloTest1() { IHelloWorld helloWorld = nettyRpcProxyService.createProxy(IHelloWorld.class); int serverId=18001; NettyRpcContextHolderObject rpcContextHolderObject = new NettyRpcContextHolderObject(NettyGameTypeEnum.WORLD, serverId); NettyRpcContextHolder.setContextHolder(rpcContextHolderObject); String result = helloWorld.getHelloWorld(5); logger.info(result); } public void setTear(){ if (nettyRpcProxyService != null) { try { nettyRpcProxyService.shutdown(); } catch (Exception e) { e.printStackTrace(); } } }}