Spring cloud 限流的多种方式

Spring Cloud 提供了几种限流的方式，以下是一些常见的方式：

1. 使用 Spring Cloud Netflix Hystrix 的线程池和信号量隔离执行。
2. 使用 Spring Cloud Gateway 的过滤器进行限流。
3. 使用 Spring Cloud Sleuth 集成 Zipkin 和 Brave 进行调用链级别的限流。
4. 使用 Spring Cloud CircuitBreaker 实现断路器模式。
5. 使用 Spring Cloud Security 的安全过滤器进行限流。

以下是一个使用 Spring Cloud Gateway 的过滤器进行限流的示例：

@Configuration
public class RateLimitConfig {
 
    @Bean
    public RouteLocator customRouteLocator(RouteLocator routeLocator) {
        return routeLocator.routes()
                .route("path_route", r -> r.path("/api/**")
                        .filters(f -> f.filter(new RateLimiter(1, 2)))
                        .uri("http://backend"))
                .build();
    }
 
    public class RateLimiter implements GatewayFilter, Ordered {
 
        private final int replenishRate;
        private final int burstCapacity;
 
        public RateLimiter(int replenishRate, int burstCapacity) {
            this.replenishRate = replenishRate;
            this.burstCapacity = burstCapacity;
        }
 
        @Override
        public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
            RequestRateLimiter rateLimiter = new RequestRateLimiter(
                    KeyResolver.monomorphic(),
                    () -> new ConcurrentHashMapRateLimiter(replenishRate, burstCapacity));
 
            return rateLimiter.filter(exchange, chain);
        }
 
        @Override
        public int getOrder() {
            return -1;
        }
    }
}

在这个例子中，我们定义了一个名为 RateLimiter 的 GatewayFilter 类，它实现了根据配置的速率和容量进行限流。在 customRouteLocator 方法中，我们为路由添加了这个过滤器，并指定了速率和容量。这样，对于匹配 /api/** 路径的请求，将会被此限流过滤器处理。