org.springframework.boot
spring-boot-starter-data-redis-reactive
3.2 修改配置文件
3.3 配置文件说明 在上面的配置文件,配置了 redis 的信息,并配置了 RequestRateLimiter 的限流过滤器,该过滤器需要配置三个参数: burstCapacity:令牌桶总容量。 replenishRate:令牌桶每秒填充平均速率。 key-resolver:用于限流的键的解析器的 Bean 对象的名字。它使用 SpEL 表达式根据
3.4 创建配置类 RequestRateLimiterConfig
@Configuration
public class RequestRateLimiterConfig {
/**
* IP 限流
* 把用户的 IP 作为限流的 Key
*
* @return
*/
@Bean
@Primary
public KeyResolver hostAddrKeyResolver() {
return (exchange) -> Mono.just(exchange.getRequest().getRemoteAddress().getHostName());
}
/**
* 用户 id 限流
* 把用户 ID 作为限流的 key
*
* @return
*/
@Bean
public KeyResolver userKeyResolver() {
return exchange -> Mono.just(exchange.getRequest().getQueryParams().getFirst("userId"));
}
/**
* 请求接口限流
* 把请求的路径作为限流 key
*
* @return
*/
@Bean
public KeyResolver apiKeyResolver() {
return exchange -> Mono.just(exchange.getRequest().getPath().value());
}
}
3.5 启动快速访问测试 http://localhost/info?token=asdad 快速访问后报 429 查看 redis