szz
/
ShiShiYiBan
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

【功能优化】限流的配置，增加 expire 过期，原因参见 https://t.zsxq.com/lcR0W 场景

This commit is contained in:
YunaiV 2025-03-16 14:45:09 +08:00
parent 7516738330
commit fc8e4662bb
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
yudao-framework/yudao-spring-boot-starter-protection/src/main/java/cn/iocoder/yudao/framework/ratelimiter/core/redis/RateLimiterRedisDAO.java
View File

@ -44,6 +44,7 @@ public class RateLimiterRedisDAO {
RateLimiterConfig config = rateLimiter.getConfig(); RateLimiterConfig config = rateLimiter.getConfig();
if (config == null) { if (config == null) {
rateLimiter.trySetRate(RateType.OVERALL, count, rateInterval, RateIntervalUnit.SECONDS); rateLimiter.trySetRate(RateType.OVERALL, count, rateInterval, RateIntervalUnit.SECONDS);
rateLimiter.expire(rateInterval, TimeUnit.SECONDS); // 原因参见 https://t.zsxq.com/lcR0W
return rateLimiter; return rateLimiter;
} }
// 2. 如果存在，并且配置相同，则直接返回 // 2. 如果存在，并且配置相同，则直接返回
@ -54,6 +55,7 @@ public class RateLimiterRedisDAO {
} }
// 3. 如果存在，并且配置不同，则进行新建 // 3. 如果存在，并且配置不同，则进行新建
rateLimiter.setRate(RateType.OVERALL, count, rateInterval, RateIntervalUnit.SECONDS); rateLimiter.setRate(RateType.OVERALL, count, rateInterval, RateIntervalUnit.SECONDS);
rateLimiter.expire(rateInterval, TimeUnit.SECONDS); // 原因参见 https://t.zsxq.com/lcR0W
return rateLimiter; return rateLimiter;
} }