无限重连

web/src/main/java/com/zhehekeji/web/config/ConfigProperties.java

@@ -82,6 +82,8 @@ public class ConfigProperties {
     public static class KSEC{
         private String ip;
         private Integer port;
+        private Integer reconnectNum = 10;
+        private Integer reconnectInterval = 10;
     }
 
     @Data

web/src/main/java/com/zhehekeji/web/service/ksec/KsecNettyClient.java

@@ -67,13 +67,18 @@ public class KsecNettyClient {
         } catch (InterruptedException e) {
             e.printStackTrace();
         }
-        while (num < RECONNECT_NUM && !isConnected) {
+        while ((ksec.getReconnectNum() == -1 || num < ksec.getReconnectNum() ) && !isConnected) {
             try {
                 createClient(ksec);
             } catch (Exception e) {
                 //没连上 继续
                 log.error("reconnect error num:{}", num);
                 num++;
+                try {
+                    Thread.sleep(ksec.getReconnectInterval()*1000);
+                } catch (InterruptedException ex) {
+                    throw new RuntimeException(ex);
+                }
                 continue;
             }
             isConnected = true;