bugfix redis collector create too many instance case oom (#734)

* bugfix redis collector create too many instance * bugfix redis collector create too many instance * bugfix redis collector create too many instance
apache · Mar 14, 2023 · 4b2a117 · 4b2a117
1 parent 9d8d9ac
commit 4b2a117
Show file tree

Hide file tree

Showing 14 changed files with 227 additions and 330 deletions.
diff --git a/collector/src/main/java/com/usthe/collector/collect/common/cache/RedisConnect.java b/collector/src/main/java/com/usthe/collector/collect/common/cache/RedisConnect.java
@@ -18,7 +18,6 @@
 package com.usthe.collector.collect.common.cache;
 
 import io.lettuce.core.api.StatefulConnection;
-import io.lettuce.core.api.StatefulRedisConnection;
 import lombok.extern.slf4j.Slf4j;
 
 /**

diff --git a/collector/src/main/java/com/usthe/collector/collect/mongodb/MongodbSingleCollectImpl.java b/collector/src/main/java/com/usthe/collector/collect/mongodb/MongodbSingleCollectImpl.java
@@ -23,6 +23,7 @@
 import java.util.Optional;
 
 import com.mongodb.MongoServerUnavailableException;
+import com.mongodb.MongoTimeoutException;
 import com.usthe.collector.collect.common.cache.CacheIdentifier;
 import com.usthe.collector.collect.common.cache.CommonCache;
 import com.usthe.collector.collect.common.cache.MongodbConnect;
@@ -116,7 +117,7 @@ public void collect(Builder builder, long appId, String app, Metrics metrics) {
             }
             fillBuilder(metrics, valueRowBuilder, document);
             builder.addValues(valueRowBuilder.build());
-        } catch (MongoServerUnavailableException unavailableException) {
+        } catch (MongoServerUnavailableException | MongoTimeoutException unavailableException) {
             builder.setCode(CollectRep.Code.UN_CONNECTABLE);
             String message = CommonUtil.getMessageFromThrowable(unavailableException);
             builder.setMsg(message);

diff --git a/collector/src/main/java/com/usthe/collector/collect/redis/RedisClusterCollectImpl.java b/collector/src/main/java/com/usthe/collector/collect/redis/RedisClusterCollectImpl.java