gateway springcloud限流

以下是使用Spring Cloud Gateway实现限流的方法：

1. 添加依赖

在pom.xml文件中添加以下依赖：

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-gateway</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
<dependency>
    <groupId>com.alibaba.csp</groupId>
    <artifactId>sentinel-core</artifactId>
    <version>1.8.1</version>
</dependency>
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-alibaba-sentinel-gateway</artifactId>
    <version>2.2.1.RELEASE</version>
</dependency>

2. 配置Sentinel

在application.yml文件中添加以下配置：

spring:
  cloud:
    sentinel:
      transport:
        dashboard: localhost:8080
        port: 8719
      filter:
        enabled: true

3. 配置限流规则

在Sentinel Dashboard中配置限流规则，例如：

- QPS限流：每秒最多只能处理10个请求

- 线程数限流：最多只能同时处理5个请求

4. 配置Gateway

在application.yml文件中添加以下配置：

spring:
  cloud:
    gateway:
      routes:
        - id: test_route
          uri: http://localhost:8080
          predicates:
            - Path=/test/**
          filters:
            - name: Sentinel
              args:
                blockHandler: 'handleBlock'
                blockExceptionClass: 'java.lang.RuntimeException'

其中，`test_route`是路由的ID，`http://localhost:8080`是目标服务的地址，`/test/**`是路由的匹配规则，`Sentinel`是过滤器的名称，`handleBlock`是限流时的处理方法，`java.lang.RuntimeException`是限流时的异常类型。

5. 编写限流处理方法

在代码中编写限流时的处理方法，例如：

public Mono<Void> handleBlock(ServerWebExchange exchange, Throwable ex) {
    return Mono.defer(() -> {
        ServerHttpResponse response = exchange.getResponse();
        response.setStatusCode(HttpStatus.TOO_MANY_REQUESTS);
        response.getHeaders().setContentType(MediaType.APPLICATION_JSON);
        String message = "{\"code\":429,\"message\":\"Too Many Requests\"}";
        DataBuffer buffer = response.bufferFactory().wrap(message.getBytes(StandardCharsets.UTF_8));
        return response.writeWith(Mono.just(buffer));
    });
}

6. 测试

启动应用程序并访问`http://localhost:8080/test`，如果超过限流规则设置的阈值，则会返回`429 Too Many Requests`错误。