From 8654b5eef8582b5b7abf5cae2ec23cf834645f5d Mon Sep 17 00:00:00 2001
From: Redkale <8730487+redkale@users.noreply.github.com>
Date: Thu, 14 Jan 2021 13:37:45 +0800
Subject: [PATCH]

---
 .../redkale/cluster/CacheClusterAgent.java    | 37 +++++++------------
 1 file changed, 14 insertions(+), 23 deletions(-)

diff --git a/src/org/redkale/cluster/CacheClusterAgent.java b/src/org/redkale/cluster/CacheClusterAgent.java
index cb49cd6b1..b082cdce3 100644
--- a/src/org/redkale/cluster/CacheClusterAgent.java
+++ b/src/org/redkale/cluster/CacheClusterAgent.java
@@ -100,27 +100,21 @@ public class CacheClusterAgent extends ClusterAgent implements Resourcable {
                 return t;
             });
 
-            //delay为了错开请求
             this.scheduler.scheduleAtFixedRate(() -> {
-                checkApplicationHealth();
-                checkHttpAddressHealth();
-            }, 18, Math.max(2000, ttls * 1000 - 168), TimeUnit.MILLISECONDS);
-
-            this.scheduler.scheduleAtFixedRate(() -> {
-                loadMqtpAddressHealth();
-            }, 88 * 2, Math.max(2000, ttls * 1000 - 168), TimeUnit.MILLISECONDS);
-
-            this.scheduler.scheduleAtFixedRate(() -> {
-                localEntrys.values().stream().filter(e -> !e.canceled).forEach(entry -> {
-                    checkLocalHealth(entry);
-                });
-            }, 128 * 3, Math.max(2000, ttls * 1000 - 168), TimeUnit.MILLISECONDS);
-
-            this.scheduler.scheduleAtFixedRate(() -> {
-                remoteEntrys.values().stream().filter(entry -> "SNCP".equalsIgnoreCase(entry.protocol)).forEach(entry -> {
-                    updateSncpTransport(entry);
-                });
-            }, 188 * 4, Math.max(2000, ttls * 1000 - 168), TimeUnit.MILLISECONDS);
+                try {
+                    checkApplicationHealth();
+                    checkHttpAddressHealth();
+                    loadMqtpAddressHealth();
+                    localEntrys.values().stream().filter(e -> !e.canceled).forEach(entry -> {
+                        checkLocalHealth(entry);
+                    });
+                    remoteEntrys.values().stream().filter(entry -> "SNCP".equalsIgnoreCase(entry.protocol)).forEach(entry -> {
+                        updateSncpTransport(entry);
+                    });
+                } catch (Exception e) {
+                    logger.log(Level.SEVERE, "scheduleAtFixedRate check error", e);
+                }
+            }, Math.max(2000, ttls * 1000), Math.max(2000, ttls * 1000), TimeUnit.MILLISECONDS);
         }
     }
 
@@ -150,14 +144,11 @@ public class CacheClusterAgent extends ClusterAgent implements Resourcable {
     }
 
     protected void checkLocalHealth(final ClusterEntry entry) {
-        AddressEntry oldaddr = (AddressEntry) source.hget(entry.checkname, entry.checkid, AddressEntry.class);
         AddressEntry newaddr = new AddressEntry();
         newaddr.addr = entry.address;
         newaddr.nodeid = this.nodeid;
         newaddr.time = System.currentTimeMillis();
         source.hset(entry.checkname, entry.checkid, AddressEntry.class, newaddr);
-        boolean ok = oldaddr != null && (System.currentTimeMillis() - oldaddr.time) / 1000 < ttls;
-        if (!ok) logger.log(Level.SEVERE, entry.checkid + " check error: " + oldaddr);
     }
 
     @Override //获取MQTP的HTTP远程服务的可用ip列表, key = servicename的后半段