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); }