优化心跳修改时长

psugoo · Jul 19, 2019 · 884c793 · 884c793
1 parent 5e7a18f
commit 884c793
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 3 deletions.
diff --git a/jobs-admin/src/main/java/com/baomidou/jobs/admin/service/impl/JobsServiceImpl.java b/jobs-admin/src/main/java/com/baomidou/jobs/admin/service/impl/JobsServiceImpl.java
@@ -37,7 +37,7 @@ public class JobsServiceImpl implements IJobsService {
     @Override
     public boolean callback(List<HandleCallbackParam> handleCallbackParamList) {
         for (HandleCallbackParam handleCallbackParam : handleCallbackParamList) {
-            boolean callbackResult = callback(handleCallbackParamList);
+            boolean callbackResult = callback(handleCallbackParam);
             log.debug("callback {}, handleCallbackParam={}, callbackResult={}",
                     callbackResult, handleCallbackParam, callbackResult);
         }

diff --git a/jobs-spring-boot-starter/src/main/java/com/baomidou/jobs/starter/JobsConstant.java b/jobs-spring-boot-starter/src/main/java/com/baomidou/jobs/starter/JobsConstant.java
@@ -16,7 +16,7 @@ public interface JobsConstant {
     /**
      * 清理时长，需比心跳稍大
      */
-    int CLEAN_TIMEOUT = 50;
+    int CLEAN_TIMEOUT = 50000;
     String COMMA = ",";
     /**
      * API URI

diff --git a/jobs-spring-boot-starter/src/main/java/com/baomidou/jobs/starter/service/JobsHeartbeat.java b/jobs-spring-boot-starter/src/main/java/com/baomidou/jobs/starter/service/JobsHeartbeat.java
@@ -82,7 +82,10 @@ public void run() {
             // 清理异常注册节点
             ++beat;
             if (beat > JobsConstant.BEAT_TIMEOUT) {
-                jobsService.cleanTimeoutApp();
+                int result = jobsService.cleanTimeoutApp();
+                if (result > 0) {
+                    System.out.println("成功清理注册：" + result);
+                }
                 beat = 0;
             }
         }