spring:  redis:    host: localhost    port: 6379    password: 123123    database: 8    lettuce:      pool:        maxActive: 8        maxIdle: 100        minIdle: 10        maxWait: -1

@Componentpublic class BrushProofFilter implements GlobalFilter, Ordered {
  private final ReactiveStringRedisTemplate reactiveStringRedisTemplate ;    public BrushProofFilter(ReactiveStringRedisTemplate reactiveStringRedisTemplate) {    this.reactiveStringRedisTemplate = reactiveStringRedisTemplate ;  }    @Override  public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {    // 获取客户端的请求ip    InetAddress address = exchange.getRequest().getRemoteAddress().getAddress();    // 获取请求的URI    String path = exchange.getRequest().getPath().toString() ;    // 将其组合为Redis中的Key    String key = ("ratelimiter:" + address + ":" + path) ;    // 通过抛出异常的方式终止序列，然后通过自定义的WebExceptionHandler处理异常信息     return this.reactiveStringRedisTemplate.opsForValue()        // 这里固定设置每30s，访问10次        .setIfAbsent(key, "10", Duration.ofSeconds(30))        .flatMap(exist -> {          return this.reactiveStringRedisTemplate.opsForValue().decrement(key) ;        })        .doOnNext(num -> {          if (num < 0) {            throw new BrushProofException("你访问太快了") ;          }        })        .then(chain.filter(exchange)) ;  }
  @Override  public int getOrder() {    return -2 ;  }
}

public class BrushProofException extends RuntimeException {
  private static final long serialVersionUID = 1L;    public BrushProofException(String message) {    super(message) ;  }  }

@Componentpublic class RatelimiterWebExceptionHandler implements WebExceptionHandler {
  @Override  public Mono handle(ServerWebExchange exchange, Throwable ex) {    if (ex instanceof RatelimiterException re) {      ServerHttpResponse response = exchange.getResponse() ;      response.setStatusCode(HttpStatus.INTERNAL_SERVER_ERROR) ;      response.getHeaders().add("Content-Type", "text/html;charset=utf8") ;      // 直接输出了，异常不进行传递      return response.writeWith(Mono.just(response.bufferFactory().wrap(("你访问太快了").getBytes()))) ;    }    // 如果是其它异常，则将异常继续向下传递    return Mono.error(ex) ;  }
}