fizzgate/fizz-gateway-node
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: decr global concurrents before response if apply api/service/service_default rate limit config

Browse Source
This commit is contained in:
hongqiaowei
2021-01-11 13:21:36 +08:00
parent c27235e9ef
commit ca2a7d9992
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/java/we/filter/FlowControlFilter.java
View File

@@ -114,6 +114,10 @@ public class FlowControlFilter extends ProxyAggrFilter {
if (concurrentOrRpsExceed) {
if (rlc.type == ResourceRateLimitConfig.Type.API || rlc.type == ResourceRateLimitConfig.Type.SERVICE || rlc.type == ResourceRateLimitConfig.Type.SERVICE_DEFAULT) {
flowStat.decrConcurrentRequest(ResourceRateLimitConfig.GLOBAL, currentTimeSlot);
}
StringBuilder b = ThreadContext.getStringBuilder();
b.append(WebUtils.getClientService(exchange)).append(Constants.Symbol.SPACE).append(WebUtils.getClientReqPath(exchange));
b.append(exceed).append(rlc.resource).append(concurrents).append(rlc.concurrents).append(orQps).append(rlc.qps);
@@ -137,7 +141,8 @@ public class FlowControlFilter extends ProxyAggrFilter {
t -> {
inTheEnd(exchange, start, currentTimeSlot, false);
}
).doOnCancel(
)
.doOnCancel(
() -> {
inTheEnd(exchange, start, currentTimeSlot, false);
}