优化端口获取不到的情况

Author: xlorne

transaction-springcloud/src/main/java/com/codingapi/ribbon/loadbalancer/LcnLoadBalancerRule.java

@@ -1,8 +1,6 @@
 package com.codingapi.ribbon.loadbalancer;
 
 
-import com.alibaba.fastjson.JSONObject;
-
 import com.codingapi.tx.aop.bean.TxTransactionLocal;
 import com.lorne.core.framework.utils.encode.MD5Util;
 import com.netflix.loadbalancer.Server;

transaction-springcloud/src/main/java/com/codingapi/ribbon/loadbalancer/LcnRibbonConfiguration.java

@@ -32,10 +32,6 @@ public ILoadBalancer ribbonLoadBalancer(IClientConfig config,
 		return new LcnZoneAwareLoadBalancerProxy(config, rule, ping, serverList,
 				serverListFilter, serverListUpdater);
 	}
-	
-	/*@Bean
-	public IRule ribbonRule(){
-		return new LcnRandomRuleProxy();
-	}*/
+
 
 }

transaction-springcloud/src/main/java/com/codingapi/tx/springcloud/feign/TransactionRestTemplateInterceptor.java

@@ -16,6 +16,7 @@ public class TransactionRestTemplateInterceptor implements RequestInterceptor {
 
     @Override
     public void apply(RequestTemplate requestTemplate) {
+
         TxTransactionLocal txTransactionLocal = TxTransactionLocal.current();
         String groupId = txTransactionLocal == null ? null : txTransactionLocal.getGroupId();
         int maxTimeOut = txTransactionLocal == null ? 0 : txTransactionLocal.getMaxTimeOut();

tx-client/src/main/java/com/codingapi/tx/listener/service/impl/InitServiceImpl.java

@@ -3,7 +3,6 @@
 import com.codingapi.tx.Constants;
 import com.codingapi.tx.listener.service.InitService;
 import com.codingapi.tx.listener.service.ModelNameService;
-import com.codingapi.tx.listener.service.TimeOutService;
 import com.codingapi.tx.netty.service.NettyService;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -21,9 +20,6 @@ public class InitServiceImpl implements InitService {
     @Autowired
     private NettyService nettyService;
 
-    @Autowired
-    private TimeOutService timeOutService;
-
 
     @Autowired
     private ModelNameService modelNameService;
@@ -41,8 +37,5 @@ public void start() {
         nettyService.start();
         logger.info("socket-start..");
 
-        //timeOutService.loadOutTime();
-
-
     }
 }

tx-client/src/main/java/com/codingapi/tx/netty/handler/TransactionHandler.java

@@ -58,26 +58,27 @@ public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws E
     }
 
     @Override
-    public void channelUnregistered(ChannelHandlerContext ctx) throws Exception {
-        super.channelUnregistered(ctx);
+    public void channelInactive(ChannelHandlerContext ctx) throws Exception {
+        super.channelInactive(ctx);
+
+        logger.info("connection -->" + ctx);
 
         SocketManager.getInstance().setNetState(false);
         //链接断开,重新连接
         nettyControlService.restart();
-
     }
 
     @Override
     public void channelActive(ChannelHandlerContext ctx) throws Exception {
         super.channelActive(ctx);
         SocketManager.getInstance().setCtx(ctx);
 
-        logger.info("try connection -->" + ctx);
-
-        nettyControlService.uploadModelInfo();
+        logger.info("disconnection -->" + ctx);
 
         //通道激活后进行心跳检查
         SocketUtils.sendMsg(ctx, heartJson);
+
+        nettyControlService.uploadModelInfo();
     }
 
 

tx-client/src/main/java/com/codingapi/tx/netty/service/impl/NettyControlServiceImpl.java

@@ -3,9 +3,11 @@
 import com.alibaba.fastjson.JSONObject;
 import com.codingapi.tx.control.service.TransactionControlService;
 import com.codingapi.tx.framework.utils.SocketManager;
+import com.codingapi.tx.listener.service.ModelNameService;
 import com.codingapi.tx.netty.service.MQTxManagerService;
 import com.codingapi.tx.netty.service.NettyControlService;
 import com.codingapi.tx.netty.service.NettyService;
+import com.codingapi.tx.netty.utils.IpAddressUtils;
 import com.lorne.core.framework.utils.task.ConditionUtils;
 import com.lorne.core.framework.utils.task.IBack;
 import com.lorne.core.framework.utils.task.Task;
@@ -36,6 +38,9 @@ public class NettyControlServiceImpl implements NettyControlService {
     @Autowired
     private MQTxManagerService mqTxManagerService;
 
+    @Autowired
+    private ModelNameService modelNameService;
+
 
     private Executor threadPool = Executors.newFixedThreadPool(100);
 
@@ -56,7 +61,7 @@ public void uploadModelInfo() {
         new Thread(new Runnable() {
             @Override
             public void run() {
-                while (!SocketManager.getInstance().isNetState()) {
+                while (!SocketManager.getInstance().isNetState()|| !IpAddressUtils.isIpAddress(modelNameService.getIpAddress())) {
                     try {
                         Thread.sleep(1000 * 5);
                     } catch (InterruptedException e) {

tx-client/src/main/java/com/codingapi/tx/netty/utils/IpAddressUtils.java

@@ -0,0 +1,20 @@
+package com.codingapi.tx.netty.utils;
+
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+
+/**
+ * create by lorne on 2017/12/12
+ */
+public class IpAddressUtils {
+
+    private final static String ipAddressRegex = "([1-9]|[1-9]\\d|1\\d{2}|2[0-4]\\d|25[0-5])(\\.(\\d|[1-9]\\d|1\\d{2}|2[0-4]\\d|25[0-5])){3}:([0-9]|[1-9]\\d{1,3}|[1-5]\\d{4}|6[0-5]{2}[0-3][0-5])";
+
+    private final static Pattern pattern = Pattern.compile(ipAddressRegex);
+
+    public static boolean isIpAddress(String ipAddress){
+        Matcher matcher = pattern.matcher(ipAddress);
+        return matcher.matches();
+    }
+
+}