spring cloud gateway 获取body体中的内容

在Spring Cloud Gateway中，你可以通过ServerWebExchange获取请求体（body）中的内容。以下是一个简单的过滤器示例，它打印请求体中的内容：

import org.springframework.cloud.gateway.filter.GatewayFilterChain;
import org.springframework.cloud.gateway.filter.GlobalFilter;
import org.springframework.core.io.buffer.DataBufferUtils;
import org.springframework.http.server.reactive.ServerHttpRequest;
import org.springframework.http.server.reactive.ServerHttpResponse;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;
 
import java.nio.charset.StandardCharsets;
 
public class LogRequestBodyFilter implements GlobalFilter {
 
    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        ServerHttpRequest request = exchange.getRequest();
 
        // 仅打印POST请求的body
        if ("POST".equals(request.getMethodValue())) {
            return DataBufferUtils.join(request.getBody())
                    .flatMap(dataBuffer -> {
                        byte[] bytes = new byte[dataBuffer.readableByteCount()];
                        dataBuffer.read(bytes);
                        // 使用Spring提供的DataBufferUtils来释放缓冲区
                        DataBufferUtils.release(dataBuffer);
                        
                        String body = new String(bytes, StandardCharsets.UTF_8);
                        System.out.println("Request body: " + body);
                        
                        // 重新构建请求，以便后续过滤器可以正常处理
                        ServerHttpRequest mutatedRequest = new ServerHttpRequestDecorator(request) {
                            @Override
                            public Flux<DataBuffer> getBody() {
                                return Flux.just(bufferFactory.wrap(bytes));
                            }
                        };
                        
                        return chain.filter(exchange.mutate().request(mutatedRequest).build());
                    });
        }
 
        return chain.filter(exchange);
    }
}

在上面的代码中，我们创建了一个实现了GlobalFilter接口的类LogRequestBodyFilter。在这个过滤器中，我们检查请求方法是否为POST，如果是，我们就使用DataBufferUtils.join()来获取请求体的数据缓冲区，并将其转换为字符串打印出来。

为了确保请求体可以被后续的过滤器和处理程序正确处理，我们需要重建ServerHttpRequest对象。这是通过ServerHttpRequestDecorator类完成的，它允许我们修改请求的某些部分，而不会影响原始的请求。

最后，你需要将这个过滤器注册到你的Gateway路由中，以便它可以被应用。这可以通过配置文件或Java配置类来完成。

配置类示例：

import org.springframework.cloud.gateway.route.RouteLoc