opensource/RuoYi-Vue-Plus
2
0
Fork 1
mirror of https://gitee.com/dromara/RuoYi-Vue-Plus.git synced 2026-09-21 02:25:56 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

分钟、小时、天限流返回头信息自定义

Browse Source
This commit is contained in:
Wenchao Gong 2021-10-17 16:53:37 +08:00
parent 3930b70a2b
commit 4464e3d141
2 changed files with 16 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
ruoyi-extend/ruoyi-isc-gateway/src/main/java/com/ruoyi/gateway/filter/CustomerGlobalFilter.java
View File

@ -233,7 +233,6 @@ public class CustomerGlobalFilter implements GlobalFilter, Ordered {
return rateLimiterAfterSupplier.get(); return rateLimiterAfterSupplier.get();
} }
return rateLimiter(exchange, rule, route, index + 1, rateLimiterAfterSupplier); return rateLimiter(exchange, rule, route, index + 1, rateLimiterAfterSupplier);
} }
setResponseStatus(exchange, HttpStatus.TOO_MANY_REQUESTS); setResponseStatus(exchange, HttpStatus.TOO_MANY_REQUESTS);
return exchange.getResponse().setComplete(); return exchange.getResponse().setComplete();

23
ruoyi-extend/ruoyi-isc-gateway/src/main/java/com/ruoyi/gateway/ratelimit/CustomerRedisRateLimiter.java
View File

@ -1,6 +1,7 @@
package com.ruoyi.gateway.ratelimit; package com.ruoyi.gateway.ratelimit;
import cn.hutool.core.date.LocalDateTimeUtil; import cn.hutool.core.date.LocalDateTimeUtil;
import cn.hutool.core.util.StrUtil;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.cloud.gateway.filter.ratelimit.RedisRateLimiter; import org.springframework.cloud.gateway.filter.ratelimit.RedisRateLimiter;
import org.springframework.cloud.gateway.support.ConfigurationService; import org.springframework.cloud.gateway.support.ConfigurationService;
@ -14,9 +15,7 @@ import java.time.Instant;
import java.time.LocalDateTime; import java.time.LocalDateTime;
import java.time.LocalTime; import java.time.LocalTime;
import java.time.temporal.ChronoUnit; import java.time.temporal.ChronoUnit;
import java.util.ArrayList; import java.util.*;
import java.util.Arrays;
import java.util.List;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicBoolean;
@ -67,7 +66,7 @@ public class CustomerRedisRateLimiter extends RedisRateLimiter {
default: default:
return Mono.just(new Response(true, getHeaders(routeConfig, -1L))); return Mono.just(new Response(true, getHeaders(routeConfig, -1L)));
} }
return isAllowed(routeConfig, keys, time); return isAllowed(routeConfig, keys, time, timeUnit);
} }
public Mono<Response> isAllowed(Config routeConfig, String id) { public Mono<Response> isAllowed(Config routeConfig, String id) {
@ -124,7 +123,7 @@ public class CustomerRedisRateLimiter extends RedisRateLimiter {
return Mono.just(new Response(true, getHeaders(routeConfig, -1L))); return Mono.just(new Response(true, getHeaders(routeConfig, -1L)));
} }
public Mono<Response> isAllowed(Config routeConfig, List<String> keys, int time) { public Mono<Response> isAllowed(Config routeConfig, List<String> keys, int time, TimeUnit timeUnit) {
if (!this.initialized.get()) { if (!this.initialized.get()) {
throw new IllegalStateException("RedisRateLimiter is not initialized"); throw new IllegalStateException("RedisRateLimiter is not initialized");
} }
@ -151,7 +150,7 @@ public class CustomerRedisRateLimiter extends RedisRateLimiter {
return Mono.just(-1L); return Mono.just(-1L);
}).map(tokensLeft -> { }).map(tokensLeft -> {
boolean allowed = tokensLeft < replenishRate; boolean allowed = tokensLeft < replenishRate;
Response response = new Response(allowed, getHeaders(routeConfig, tokensLeft)); Response response = new Response(allowed, getHeaders(routeConfig, tokensLeft, timeUnit));
if (log.isDebugEnabled()) { if (log.isDebugEnabled()) {
log.debug("response: " + response); log.debug("response: " + response);
} }
@ -166,7 +165,17 @@ public class CustomerRedisRateLimiter extends RedisRateLimiter {
*/ */
log.error("Error determining if user allowed from redis", e); log.error("Error determining if user allowed from redis", e);
} }
return Mono.just(new Response(true, getHeaders(routeConfig, -1L))); return Mono.just(new Response(true, getHeaders(routeConfig, -1L, timeUnit)));
}
public Map<String, String> getHeaders(Config config, Long tokensLeft, TimeUnit timeUnit) {
Map<String, String> headers = new HashMap<>();
if (isIncludeHeaders()) {
String suffix = StrUtil.upperFirst(timeUnit.name().toLowerCase());
headers.put(this.getRemainingHeader() + '-' + suffix, tokensLeft.toString());
headers.put(this.getReplenishRateHeader() + '-' + suffix, String.valueOf(config.getReplenishRate()));
}
return headers;
} }
static List<String> getKeys(String id) { static List<String> getKeys(String id) {