网关过滤器获取body参数

网关过滤器通常用于处理HTTP请求和响应，在网关层面进行拦截、处理和转发。在使用网关过滤器获取请求体（body）参数时，需要注意请求体的类型和内容大小。通常，如果请求体是JSON格式，可以通过解析JSON来获取参数；如果请求体是表单数据，则可以按照表单的格式解析获取参数。

以Java中Spring Cloud Gateway为例，可以使用`GatewayFilter`接口实现自定义的过滤逻辑来读取和修改请求体。以下是一个简单的示例：

import org.springframework.cloud.gateway.filter.GatewayFilter;
import org.springframework.cloud.gateway.filter.factory.AbstractGatewayFilterFactory;
import org.springframework.http.server.reactive.ServerHttpRequest;
import org.springframework.http.server.reactive.ServerHttpResponse;
import org.springframework.stereotype.Component;
import reactor.core.publisher.Mono;

@Component
public class BodyFilter extends AbstractGatewayFilterFactory<BodyFilter.Config> {

    public BodyFilter() {
        super(Config.class);
    }

    @Override
    public GatewayFilter apply(Config config) {
        return (exchange, chain) -> {
            ServerHttpRequest request = exchange.getRequest();
            // 检查请求体是否可读
            if (request.getMethodValue().equalsIgnoreCase("POST") &&
                request.getHeaders().getContentType().equals(MediaType.APPLICATION_JSON)) {
                Mono<String> modifiedBody = request.getBody()
                    .map(data -> {
                        // 将数据转换为字符串
                        String requestBody = new String(data.array());
                        // 解析JSON字符串并获取参数
                        // 示例：假设我们要获取一个名为"param"的参数
                        // String paramValue = ...;
                        // 修改参数后重新设置请求体
                        // requestBody = requestBody.replace("旧值", "新值");
                        return requestBody;
                    })
                    .defaultIfEmpty("")
                    .map(body -> exchange.getRequest().mutate().body(BodyInserters.fromValue(body)).build());
                
                // 使用修改后的请求体创建新的ServerHttpRequest
                ServerHttpRequest mutableReq = modifiedBody.map(body -> exchange.getRequest().mutate().body(BodyInserters.fromValue(body)).build()).block();
                return chain.filter(exchange.mutate().request(mutableReq).build());
            }
            return chain.filter(exchange);
        };
    }

    public static class Config {
        // 配置字段
    }
}

在这个示例中，过滤器只处理了POST请求，并且只处理了内容类型为`application/json`的请求体。如果请求体是JSON格式，它会被转换为字符串，然后可以进行进一步的解析和修改。注意，由于`ServerHttpRequest.BodyContent`是一个只读的流，所以这里使用了`map`来转换和重新封装请求体。