From dc8e6de80a96e45f9cade96ae26f623223e871d4 Mon Sep 17 00:00:00 2001
From: opensnail <598092184@qq.com>
Date: Wed, 25 Dec 2024 21:51:45 +0800
Subject: [PATCH] =?UTF-8?q?feat:(1.3.0-beta1):=20=E4=BF=AE=E5=A4=8D?=
 =?UTF-8?q?=E5=90=AF=E5=8A=A8=E5=A4=B1=E8=B4=A5=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../server/common/register/ClientRegister.java     | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)

diff --git a/snail-job-server/snail-job-server-common/src/main/java/com/aizuda/snailjob/server/common/register/ClientRegister.java b/snail-job-server/snail-job-server-common/src/main/java/com/aizuda/snailjob/server/common/register/ClientRegister.java
index 56bea37a..9520bfbc 100644
--- a/snail-job-server/snail-job-server-common/src/main/java/com/aizuda/snailjob/server/common/register/ClientRegister.java
+++ b/snail-job-server/snail-job-server-common/src/main/java/com/aizuda/snailjob/server/common/register/ClientRegister.java
@@ -22,6 +22,8 @@ import com.fasterxml.jackson.core.type.TypeReference;
 import com.google.common.collect.Lists;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Lazy;
 import org.springframework.scheduling.TaskScheduler;
 import org.springframework.stereotype.Component;
 
@@ -43,14 +45,13 @@ import java.util.stream.Collectors;
  */
 @Component(ClientRegister.BEAN_NAME)
 @Slf4j
-@RequiredArgsConstructor
 public class ClientRegister extends AbstractRegister {
-    ExecutorService executorService = Executors.newFixedThreadPool(5);
-    private final RefreshNodeSchedule refreshNodeSchedule;
     public static final String BEAN_NAME = "clientRegister";
-
     public static final int DELAY_TIME = 30;
     protected static final LinkedBlockingDeque<ServerNode> QUEUE = new LinkedBlockingDeque<>(1000);
+    @Autowired
+    @Lazy
+    private RefreshNodeSchedule refreshNodeSchedule;
 
     @Override
     public boolean supports(int type) {
@@ -124,9 +125,8 @@ public class ClientRegister extends AbstractRegister {
     }
 
     @Component
-    @Slf4j
-    @RequiredArgsConstructor
     public class RefreshNodeSchedule extends AbstractSchedule {
+        private final ExecutorService executorService = Executors.newFixedThreadPool(5);
 
         @Override
         protected void doExecute() {
@@ -161,7 +161,7 @@ public class ClientRegister extends AbstractRegister {
                     return;
                 }
 
-                SnailJobLog.LOCAL.info("start refresh client nodes：{}", waitRefreshDBClientNodes);
+                SnailJobLog.LOCAL.debug("start refresh client nodes：{}", waitRefreshDBClientNodes);
 
                 // 刷新DB
                 refreshExpireAt(waitRefreshDBClientNodes);