From cb2f02d60aac235f2f9e5ef777e0141fb697c264 Mon Sep 17 00:00:00 2001
From: cl <1442464845@qq.com>
Date: 星期五, 01 五月 2026 15:18:11 +0800
Subject: [PATCH] 多加入参数和修改规则
---
rsf-server/src/main/java/com/vincent/rsf/server/common/service/RedisService.java | 9 +++++++++
1 files changed, 9 insertions(+), 0 deletions(-)
diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/common/service/RedisService.java b/rsf-server/src/main/java/com/vincent/rsf/server/common/service/RedisService.java
index 33f12ea..45882e8 100644
--- a/rsf-server/src/main/java/com/vincent/rsf/server/common/service/RedisService.java
+++ b/rsf-server/src/main/java/com/vincent/rsf/server/common/service/RedisService.java
@@ -36,6 +36,9 @@
if (null == this.pool) {
JedisPoolConfig config = new JedisPoolConfig();
config.setTestOnBorrow(false);
+ config.setMaxWaitMillis(5000L);
+ int maxTotal = redisProperties.getMax() > 0 ? redisProperties.getMax() : 32;
+ config.setMaxTotal(maxTotal);
this.index = redisProperties.getIndex();
// 绌虹櫧瀵嗙爜浼� null锛屼笉鍚戞湭寮�璁よ瘉鐨� Redis 鍙� AUTH
String pwd = StringUtils.trimToNull(redisProperties.getPassword());
@@ -256,6 +259,8 @@
return jedis.get(flag + LINK + key);
} catch (Exception e) {
log.error(this.getClass().getSimpleName(), e);
+ } finally {
+ jedis.close();
}
return null;
}
@@ -277,6 +282,8 @@
return jedis.del(keys);
} catch (Exception e) {
log.error(this.getClass().getSimpleName(), e);
+ } finally {
+ jedis.close();
}
return null;
}
@@ -595,6 +602,8 @@
} catch (Exception e) {
log.error(this.getClass().getSimpleName(), e);
return true;
+ } finally {
+ jedis.close();
}
}
--
Gitblit v1.9.1