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

fix: global concurrents -1

Browse Source
This commit is contained in:
hongqiaowei
2021-01-15 11:30:24 +08:00
parent c79fed3f9d
commit 20a5068739
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/main/java/we/filter/AbsFlowControlFilter.java
View File

@@ -66,10 +66,11 @@ public abstract class AbsFlowControlFilter extends ProxyAggrFilter {
b.append(exceed) .append(config.resource) .append(concurrents) .append(config.concurrents).append(orQps).append(config.qps);
log.warn(b.toString(), LogService.BIZ_ID, exchange.getRequest().getId());
ResourceRateLimitConfig globalConfig = resourceRateLimitConfigService.getResourceRateLimitConfig(ResourceRateLimitConfig.GLOBAL);
ServerHttpResponse resp = exchange.getResponse();
resp.setStatusCode(HttpStatus.OK);
resp.getHeaders().add(HttpHeaders.CONTENT_TYPE, config.responseType);
return resp.writeWith(Mono.just(resp.bufferFactory().wrap(config.responseContent.getBytes())));
resp.getHeaders().add(HttpHeaders.CONTENT_TYPE, globalConfig.responseType);
return resp.writeWith(Mono.just(resp.bufferFactory().wrap(globalConfig.responseContent.getBytes())));
}
protected void inTheEnd(ServerWebExchange exchange, String resource, long start, long currentTimeSlot, boolean success) {