springcloud gateway修改请求体参数

Spring Cloud Gateway可以使用过滤器修改请求体参数。可以通过实现GlobalFilter或者GatewayFilter接口中的filter方法来实现。

下面是一个实现修改请求体参数的例子：

@Component
public class ModifyRequestBodyFilter implements GatewayFilter {

    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        HttpHeaders headers = exchange.getRequest().getHeaders();
        String contentType = headers.getFirst(HttpHeaders.CONTENT_TYPE);
        if (MediaType.APPLICATION_JSON_VALUE.equalsIgnoreCase(contentType)) {
            // 获取请求体参数
            return DataBufferUtils.join(exchange.getRequest().getBody())
                    .flatMap(dataBuffer -> {
                        byte[] bytes = new byte[dataBuffer.readableByteCount()];
                        dataBuffer.read(bytes);
                        DataBufferUtils.release(dataBuffer);

                        String bodyStr = new String(bytes, StandardCharsets.UTF_8);
                        // 修改请求体参数
                        JSONObject jsonObject = JSON.parseObject(bodyStr);
                        jsonObject.put("key", "value");
                        String newBodyStr = jsonObject.toJSONString();
                        byte[] newBytes = newBodyStr.getBytes(StandardCharsets.UTF_8);

                        // 将修改后的请求体设置回去
                        Flux<DataBuffer> flux = Flux.just(exchange.getResponse()
                                .bufferFactory().wrap(newBytes));
                        HttpHeaders headers1 = new HttpHeaders();
                        headers1.putAll(headers);
                        headers1.setContentLength(newBytes.length);
                        headers1.set(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE);
                        ServerHttpRequest request = exchange.getRequest().mutate()
                                .headers(h -> h.addAll(headers1))
                                .build();
                        ServerWebExchange newExchange = exchange.mutate().request(request).build();

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

在这个例子中，我们实现了一个名为ModifyRequestBodyFilter的过滤器，它会在请求头的Content-Type为application/json时修改请求体参数。具体实现步骤如下：

1. 获取请求体参数。
2. 将请求体参数转换为JSON对象并修改。
3. 将修改后的请求体设置回去。
4. 调用chain.filter方法继续处理请求。