获取端口号为0时等待

Author: xlorne

transaction-springcloud/src/main/java/com/codingapi/tx/springcloud/service/impl/ModelNameServiceImpl.java

@@ -1,8 +1,8 @@
 package com.codingapi.tx.springcloud.service.impl;
 
-import com.lorne.core.framework.utils.encode.MD5Util;
 import com.codingapi.tx.listener.service.ModelNameService;
 import com.codingapi.tx.springcloud.listener.ServerListener;
+import com.lorne.core.framework.utils.encode.MD5Util;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.annotation.Configuration;
@@ -32,7 +32,7 @@ public String getModelName() {
         return modelName;
     }
 
-    private String getIp(){
+    private String getIp() {
         if (host == null) {
             try {
                 host = InetAddress.getLocalHost().getHostAddress();
@@ -43,16 +43,36 @@ private String getIp(){
         return host;
     }
 
+    private int getPort() {
+        int port = serverListener.getPort();
+        int count = 0;
+        while (port == 0) {
+            try {
+                Thread.sleep(10);
+            } catch (InterruptedException e) {
+                e.printStackTrace();
+            }
+            port = serverListener.getPort();
+            count++;
+
+            if(count==2000){
+                throw new RuntimeException("get server port error.");
+            }
+        }
+
+        return port;
+    }
+
     @Override
     public String getUniqueKey() {
-        String address = getIp()+serverListener.getPort();
-        return  MD5Util.md5(address.getBytes());
+        String address = getIp() + getPort();
+        return MD5Util.md5(address.getBytes());
     }
 
 
     @Override
     public String getIpAddress() {
-        String address = getIp() + ":" + serverListener.getPort();
+        String address = getIp() + ":" + getPort();
         return address;
     }
 }