From b3ee22903d12461ee5bf6e3b38e1684a6daa61ea Mon Sep 17 00:00:00 2001
From: 许鹏程 <1821349743@qq.com>
Date: 星期四, 26 九月 2024 10:04:51 +0800
Subject: [PATCH] 底层redis迭代修改不兼容代码
---
src/main/java/com/product/datasource/service/RedisService.java | 8 --------
1 files changed, 0 insertions(+), 8 deletions(-)
diff --git a/src/main/java/com/product/datasource/service/RedisService.java b/src/main/java/com/product/datasource/service/RedisService.java
index 86919b3..51a6076 100644
--- a/src/main/java/com/product/datasource/service/RedisService.java
+++ b/src/main/java/com/product/datasource/service/RedisService.java
@@ -34,7 +34,6 @@
private JSONObject curObj;
private static final int CONNECTION_TIMEOUT = 60000;// 杩炴帴瓒呮椂鏃堕棿
private static final int SO_TIMEOUT = 60000;// 璇诲彇瓒呮椂鏃堕棿
- private boolean localFlag;
private static Map<JSONObject, JedisPool> map = Maps.newHashMap();
private static Map<JSONObject, JedisSentinelPool> sentinelPoolMap = Maps.newHashMap();
private static Map<JSONObject, RedisSentinelUtil> redisSentinelUtil = Maps.newHashMap();
@@ -51,10 +50,6 @@
} catch (Exception e) {
throw new BaseException(ErrorCode.GET_REDIS_CONNECTION_FAIL);
}
- }
-
- public RedisService() {
- this.localFlag = true;
}
public void close() {
@@ -75,9 +70,6 @@
* @return Jedis
*/
public Jedis getJedis() {
- if (localFlag) {
- return RedisUtil.getJedis();
- }
String dbType = curObj.getString("db_type");
Jedis jedis;
if ("6".equals(dbType)) {
--
Gitblit v1.9.2