如何让SpringCloud Gateway网关自定义过滤器也能获取到请求体body的内容？不存在的问题！

Spring Cloud Gateway 自定义过滤器中的请求体处理

Spring Cloud Gateway 作为微服务网关，提供了一系列强大的功能，包括添加自定义过滤器以满足特定需求。然而，早期版本的 Gateway 无法直接访问请求体内容，给开发人员带来不便。本文将介绍 Spring Cloud Gateway 中引入的 ServerWebExchangeUtils 工具类，帮助我们获取请求体数据，并解决流无法重复读取的问题。

获取请求体内容

在自定义过滤器中，我们可以通过以下步骤获取请求体数据：

1. 注入 ServerWebExchangeUtils 工具类：

import org.springframework.web.util.pattern.PathPattern;
import org.springframework.web.util.pattern.PathPatternParser;
import reactor.core.publisher.Mono;

public class MyGatewayFilterFactory extends AbstractGatewayFilterFactory {
    @Override
    public GatewayFilter apply(Config config) {
        return (exchange, chain) -> {
            // 获取请求体中的数据
            ServerHttpRequest request = exchange.getRequest();
            Mono<String> body = ServerWebExchangeUtils.getRequestBodyToMono(exchange);

            // 使用 body 进行相关处理

            return chain.filter(exchange);
        };
    }
}

2. 使用 getRequestBodyToMono 方法获取数据：

Mono<String> body = ServerWebExchangeUtils.getRequestBodyToMono(exchange);

3. 使用 Mono 操作符处理数据：

body.map(s -> {
    // 将请求体中的数据转换成 JSON 对象
    JSONObject jsonObject = new JSONObject(s);

    // 使用 jsonObject 进行相关处理

    return jsonObject;
});

解决流不可重复读取问题

获取请求体数据时，我们需要注意流不可重复读取的问题。为了解决这个问题，可以使用 FluxCache 类缓存请求体数据：

FluxCache cache = new FluxCache();
body = cache.mono(ServerWebExchangeUtils.getRequestBodyToMono(exchange));

常见问题解答

1. 如何使用 FluxCache 缓存请求体数据？

通过 cache.mono(ServerWebExchangeUtils.getRequestBodyToMono(exchange)) 即可缓存请求体数据。

2. 如何将请求体数据转换成 JSON 对象？

可以使用 map() 操作符将请求体数据转换成 JSON 对象：

body.map(s -> new JSONObject(s));

3. 如何解决网关过滤器中未找到 ServerWebExchangeUtils 问题？

确保已导入 ServerWebExchangeUtils 类：

import org.springframework.web.server.ServerWebExchangeUtils;

4. 如何避免请求体数据被重复读取？

使用 FluxCache 缓存请求体数据即可避免重复读取。

5. 如何获取请求体中的原始字节流？

可以使用 getBody 方法获取原始字节流：

Flux<DataBuffer> body = exchange.getRequest().getBody();

结论

本文介绍了如何在 Spring Cloud Gateway 自定义过滤器中获取请求体内容，以及如何解决流不可重复读取问题。通过 ServerWebExchangeUtils 工具类和 FluxCache 类的使用，开发者可以轻松访问和处理请求体数据，为网关层添加更多自定义功能。