redis 增加重连解决告警问题

jack
Commit 54b22fb1f629c41ebfc80a01e7fb71692941970c 1 parent 6bafe8e2
Showing 1 changed file with 7 additions and 7 deletions
monitor-service-middleware/src/main/java/com/monitor/middleware/redis/task/RedisTask.java
--- a/monitor-service-middleware/src/main/java/com/monitor/middleware/redis/task/RedisTask.java
View file @54b22fb
+++ b/monitor-service-middleware/src/main/java/com/monitor/middleware/redis/task/RedisTask.java
View file @54b22fb
@@ -62,17 +62,17 @@ public class RedisTask extends Task {
         connect();
-        //等待两秒重连
-        try {
+        if (null == client || !client.isConnected()) {
+            //等待两秒重连
+            try {
-            Thread.sleep(200);
+                Thread.sleep(200);
-        } catch (InterruptedException e) {
+            } catch (InterruptedException e) {
-            DEBUG.error("Failed to wait for reconnect to redis {}", super.url);
-        }
+                DEBUG.error("Failed to wait for reconnect to redis {}", super.url);
+            }
-        if (null == client || !client.isConnected()) {
             connect();
         }