From 305de5dc7e0f00c454e4dd5c87431593b95b44d6 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?LAPTOP-S9HJSOEB=5C=E6=98=8A=E5=A4=A9?=
 <wang.haotian@hzleaper.com>
Date: Sat, 21 Oct 2023 12:22:07 +0800
Subject: [PATCH] =?UTF-8?q?=E6=98=86=E8=88=B9=E6=9C=AA=E8=BF=9E=E6=8E=A5?=
 =?UTF-8?q?=E4=B9=9F=E8=BF=9B=E8=A1=8C=E9=87=8D=E8=BF=9E=E6=93=8D=E4=BD=9C?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 web/src/main/java/com/zhehekeji/web/service/InitService.java  | 1 +
 .../java/com/zhehekeji/web/service/ksec/KsecNettyClient.java  | 4 +++-
 2 files changed, 4 insertions(+), 1 deletion(-)

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{