From 34ae5e09dfbefd17db9b19cc17234a82e6bee54c Mon Sep 17 00:00:00 2001 From: "chen.ma" Date: Sat, 20 Nov 2021 02:44:36 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=A2=E6=88=B7=E7=AB=AF=E4=B8=8E=E6=9C=8D?= =?UTF-8?q?=E5=8A=A1=E7=AB=AF=E6=96=AD=E5=BC=80=E5=B9=B6=E9=87=8D=E6=96=B0?= =?UTF-8?q?=E5=BB=BA=E7=AB=8B=E8=BF=9E=E6=8E=A5=E6=97=B6=E6=89=93=E5=8D=B0?= =?UTF-8?q?=E6=97=A5=E5=BF=97.?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/cn/hippo4j/starter/core/ClientWorker.java | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/core/ClientWorker.java b/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/core/ClientWorker.java index e2e3315c..8fc146a8 100644 --- a/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/core/ClientWorker.java +++ b/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/core/ClientWorker.java @@ -44,6 +44,8 @@ public class ClientWorker { private AtomicBoolean isHealthServer = new AtomicBoolean(true); + private AtomicBoolean isHealthServerTemp = new AtomicBoolean(true); + private final ConcurrentHashMap cacheMap = new ConcurrentHashMap(16); @SuppressWarnings("all") @@ -95,8 +97,14 @@ public class ClientWorker { @SneakyThrows private void checkStatus() { + if (Objects.equals(isHealthServerTemp.get(), Boolean.FALSE) + && Objects.equals(isHealthServer.get(), Boolean.TRUE)) { + isHealthServerTemp.set(Boolean.TRUE); + log.info("🚀 The client reconnects to the server successfully."); + } // 服务端状态不正常睡眠 30s if (!isHealthServer.get()) { + isHealthServerTemp.set(Boolean.FALSE); log.error("[Check config] Error. exception message, Thread sleep 30 s."); Thread.sleep(30000); }