限流策略修改
This commit is contained in:
@@ -107,17 +107,16 @@ public class RateLimitAspect {
|
|||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
if (rateHolder.containsKey(key)) {
|
|
||||||
return rateHolder.get(key);
|
|
||||||
}
|
|
||||||
RateLimiter rateLimiter = RateLimiter.create(rateLimit.limit());
|
|
||||||
rateHolder.put(key, rateLimiter);
|
|
||||||
//超过固定阈值,清空,重构
|
//超过固定阈值,清空,重构
|
||||||
if (rateHolder.size() > MAX_HOLDER_SIZE) {
|
if (rateHolder.size() > MAX_HOLDER_SIZE) {
|
||||||
rateHolder.clear();
|
rateHolder.clear();
|
||||||
}
|
}
|
||||||
return rateLimiter;
|
if (rateHolder.containsKey(key)) {
|
||||||
|
return rateHolder.get(key);
|
||||||
|
}
|
||||||
|
RateLimiter rateLimiter = RateLimiter.create(rateLimit.limit());
|
||||||
|
rateHolder.putIfAbsent(key, rateLimiter);
|
||||||
|
return rateHolder.get(key);
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user