spring cloud gateway + Sentinel 流量限流、熔断自定义响应内容

在Spring Cloud Gateway中使用Sentinel进行流量控制和熔断时，可以通过定制BlockExceptionHandler来响应限流和熔断时的情况。以下是一个简单的例子：

1. 添加依赖（确保你的项目已经引入了Spring Cloud Gateway和Spring Cloud Alibaba Sentinel的相关依赖）

<!-- Spring Cloud Alibaba Sentinel -->
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>

2. 创建一个BlockExceptionHandler类：

import com.alibaba.csp.sentinel.adapter.gateway.sc.exception.SentinelGatewayBlockExceptionHandler;
import org.springframework.core.Ordered;
import org.springframework.core.io.buffer.DataBuffer;
import org.springframework.http.HttpStatus;
import org.springframework.http.MediaType;
import org.springframework.stereotype.Component;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;
 
@Component
public class CustomBlockExceptionHandler implements SentinelGatewayBlockExceptionHandler, Ordered {
 
    @Override
    public Mono<Void> handle(ServerWebExchange exchange, Throwable ex) {
        // 定制响应的状态码和内容
        exchange.getResponse().setStatusCode(HttpStatus.TOO_MANY_REQUESTS);
        exchange.getResponse().getHeaders().setContentType(MediaType.APPLICATION_JSON);
        String body = "{\"code\": \"429\", \"message\": \"Too Many Requests\"}";
        DataBuffer buffer = exchange.getResponse().bufferFactory().wrap(body.getBytes());
        return exchange.getResponse().writeWith(Mono.just(buffer));
    }
 
    @Override
    public int getOrder() {
        // 定义处理器的顺序，数字越小优先级越高
        return 0;
    }
}

在上述代码中，我们定义了一个CustomBlockExceptionHandler类，实现了SentinelGatewayBlockExceptionHandler接口，并设置了响应的状态码和自定义的JSON内容。当Sentinel触发限流或熔断时，Gateway会调用这个处理器返回定制的响应。

3. 确保在Spring Cloud Gateway的配置中启用了Sentinel：

spring:
  cloud:
    gateway:
      sentinel:
        enabled: true

通过以上步骤，你可以为Spring Cloud Gateway与Sentinel结合使用时的限流和熔断设置自定义响应内容。