gateway globalfilter 获取body

在 Spring Cloud Gateway 中，我们同样可以使用 GlobalFilter 来实现类似 Servlet Filter 的功能，对请求进行全局拦截和处理。在 GlobalFilter 中，我们同样可以获取请求体，并对其进行一些处理，例如解密、解压等操作。

以下是一个简单的 GlobalFilter 示例，用于获取请求体并打印出来：

@Component
public class BodyGlobalFilter implements GlobalFilter, Ordered {
    private static final Logger logger = LoggerFactory.getLogger(BodyGlobalFilter.class);

    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        ServerHttpRequest request = exchange.getRequest();
        String method = request.getMethodValue();
        logger.info("请求方法：{}", method);
        if ("POST".equals(method) || "PUT".equals(method)) {
            MediaType mediaType = request.getHeaders().getContentType();
            if (mediaType != null && mediaType.includes(MediaType.APPLICATION_JSON)) {
                return DataBufferUtils.join(exchange.getRequest().getBody())
                        .flatMap(dataBuffer -> {
                            byte[] bytes = new byte[dataBuffer.readableByteCount()];
                            dataBuffer.read(bytes);
                            DataBufferUtils.release(dataBuffer);
                            String body = new String(bytes, StandardCharsets.UTF_8);
                            logger.info("请求体：{}", body);
                            ServerHttpRequest mutatedRequest = new ServerHttpRequestDecorator(request) {
                                @Override
                                public Flux<DataBuffer> getBody() {
                                    return Flux.just(body)
                                            .map(b -> new DefaultDataBufferFactory().wrap(b.getBytes(StandardCharsets.UTF_8)));
                                }
                            };
                            return chain.filter(exchange.mutate().request(mutatedRequest).build());
                        });
            }
        }
        return chain.filter(exchange);
    }

    @Override
    public int getOrder() {
        return -1;
    }
}

在上面的示例中，我们使用 DataBufferUtils.join() 方法将请求体读取到一个 Flux<DataBuffer> 中，并使用 flatMap() 方法将其转换为一个 Mono<String>，即一个字符串类型的 Mono。然后对该字符串进行处理，并使用 ServerHttpRequestDecorator 类创建一个新的 ServerHttpRequest 对象，该对象包含处理后的请求体。最后，我们调用 chain.filter() 方法将请求传递给后续的过滤器或路由处理器。

需要注意的是，Gateway 中的 GlobalFilter 与 Servlet 中的 Filter 不同，它可以获取请求和响应的信息，并对它们进行修改，同时也可以进行异步处理。但是，同样需要注意内存消耗的问题，特别是对于大文件的请求体，需要进行适当的优化处理。