SpringCloud Gateway 网关请求中body、query、header参数的获取和修改

在Spring Cloud Gateway中，可以使用GatewayFilter和GatewayFilterFactory来获取和修改请求中的body、query、header参数。以下是如何操作的示例代码：

@Component
public class CustomGatewayFilterFactory extends AbstractGatewayFilterFactory<CustomGatewayFilterFactory.Config> {
    private static final Log log = LogFactory.getLog(CustomGatewayFilterFactory.class);
 
    public CustomGatewayFilterFactory() {
        super(Config.class);
    }
 
    @Override
    public GatewayFilter apply(Config config) {
        return (exchange, chain) -> {
            ServerHttpRequest request = exchange.getRequest();
 
            // 获取请求的header参数
            HttpHeaders headers = request.getHeaders();
            // 获取请求的query参数
            MultiValueMap<String, String> queryParams = request.getQueryParams();
 
            // 可以根据需要修改header或query参数
            // 例如修改header参数
            // headers.set("new-header", "new-value");
 
            // 重建请求（如果需要修改body参数）
            // 注意：这里不能直接修改原有的请求体，需要读取原有请求体内容，然后重新构建请求
            // Flux<DataBuffer> body = request.getBody();
            // body.map(buffer -> {
            //     // 修改buffer内容
            //     return buffer;
            // });
            // ServerHttpRequest newRequest = request.mutate().body(body).build();
 
            // 继续过滤器链
            return chain.filter(exchange.mutate().request(request).build());
        };
    }
 
    public static class Config {
        // 这里可以添加需要的配置参数
    }
}

在配置文件中使用这个自定义的GatewayFilterFactory：

spring:
  cloud:
    gateway:
      routes:
        - id: custom_filter_route
          uri: https://example.org
          filters:
            - CustomGatewayFilterFactory=your_custom_config_value

以上代码展示了如何获取和可能的修改header和query参数。如果需要修改body参数，需要先读取原有的请求体内容，然后按需修改，最后重新构建请求。注意，直接修改原有的请求体是不允许的，因此需要使用ServerHttpRequest的mutate方法来创建一个新的请求。