使用SPRING CLOUD框架多次读取ServerHttpRequest里的内容

在Spring Cloud框架中，可以通过使用Spring Cloud Gateway网关来读取和处理HTTP请求。Spring Cloud Gateway提供了一些过滤器（Filter）来处理HTTP请求和响应，其中包括读取请求体内容的过滤器。

如果需要多次读取请求体内容，可以在自定义的过滤器中实现。具体步骤如下：

1. 创建一个自定义的过滤器类，实现GatewayFilter接口，并重写它的filter方法，示例代码如下：

@Component
public class RequestBodyCachingFilter implements GatewayFilter {

    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        return DataBufferUtils.join(exchange.getRequest().getBody())
                .flatMap(dataBuffer -> {
                    byte[] bytes = new byte[dataBuffer.readableByteCount()];
                    dataBuffer.read(bytes);
                    DataBufferUtils.release(dataBuffer);
                    // 将请求体内容缓存到ServerWebExchange中
                    exchange.getAttributes().put("cachedRequestBody", bytes);
                    return Mono.just(bytes);
                })
                .then(chain.filter(exchange));
    }
}

2. 在Spring Cloud Gateway配置类中注册自定义的过滤器，示例代码如下：

@Configuration
public class GatewayConfig {

    @Autowired
    private RequestBodyCachingFilter requestBodyCachingFilter;

    @Bean
    public RouteLocator customRouteLocator(RouteLocatorBuilder builder) {
        return builder.routes()
                .route(r -> r.path("/api/**")
                        .filters(f -> f.filter(requestBodyCachingFilter)) // 注册自定义过滤器
                        .uri("http://localhost:8080"))
                .build();
    }
}

以上代码中，我们创建了一个名为RequestBodyCachingFilter的自定义过滤器，它实现了GatewayFilter接口，并在filter方法中将请求体内容缓存到ServerWebExchange中。同时，在GatewayConfig配置类中注册了该过滤器，并将其应用于所有路径以“/api/”开头的请求中。

这样，每次发送符合条件的HTTP请求时，就会先执行RequestBodyCachingFilter过滤器，将请求体内容缓存到ServerWebExchange中，后续需要读取时，就可以直接从ServerWebExchange中获取。