在Spring Boot中整合Redis实现限流，可以使用spring-boot-starter-data-redis依赖，并结合RedisRateLimiter来实现。以下是一个简单的示例：
- 添加依赖到
pom.xml：
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-webflux</artifactId>
</dependency>- 配置Redis：
@Configuration
public class RedisConfig {
@Bean
public ReactiveRedisTemplate<String, String> reactiveRedisTemplate(ReactiveRedisConnectionFactory factory) {
return new ReactiveRedisTemplate<>(factory, RedisSerializationContext.string());
}
}- 使用
RedisRateLimiter实现限流：
@Configuration
public class RateLimiterConfig {
@Bean
public KeyResolver keyResolver() {
return exchange -> Mono.just(exchange.getRequest().getPath().value());
}
@Bean
public ReactorRedisRateLimiter redisRateLimiter(ReactiveRedisTemplate<String, String> redisTemplate) {
return new ReactorRedisRateLimiter(redisTemplate, "rate_limiter_", 1, 2);
}
}- 在路由中应用限流：
@Configuration
public class RoutesConfiguration {
@Bean
public SecurityWebFilterChain springSecurityWebFilterChain(ServerHttpSecurity http) {
http
.authorizeExchange()
.pathMatchers("/limited").routeTo(route -> route.gatewayFilter(gatewayFilter).build())
.and()
// ... 其他配置
;
return http.build();
}
}在上述配置中，ReactorRedisRateLimiter使用Redis作为存储，并对路径/limited的请求实施了每秒2个请求的限流。
确保你的Redis服务器正在运行并且配置信息（如主机名、端口和密码）在application.properties或application.yml中正确设置。