diff --git a/web/src/main/java/com/zhehekeji/web/service/InitService.java b/web/src/main/java/com/zhehekeji/web/service/InitService.java index d4b381a..307609d 100644 --- a/web/src/main/java/com/zhehekeji/web/service/InitService.java +++ b/web/src/main/java/com/zhehekeji/web/service/InitService.java @@ -110,6 +110,7 @@ public class InitService implements ApplicationRunner { ksecNettyClient.createClient(ksec); }catch (Exception e){ log.error("kesc connect error,url:{},port:{}",ksec.getIp(),ksec.getPort()); + ksecNettyClient.reconnect(1); } }else { log.error("ksec no config"); diff --git a/web/src/main/java/com/zhehekeji/web/service/ksec/KsecNettyClient.java b/web/src/main/java/com/zhehekeji/web/service/ksec/KsecNettyClient.java index 438bb60..cf3bbd0 100644 --- a/web/src/main/java/com/zhehekeji/web/service/ksec/KsecNettyClient.java +++ b/web/src/main/java/com/zhehekeji/web/service/ksec/KsecNettyClient.java @@ -69,7 +69,9 @@ public class KsecNettyClient { //没连上 继续 catch (Exception e) { //关闭当前链接 - channel.close(); + if(channel!=null) { + channel.close(); + } log.error("reconnect error num:{}", num); num++; try{