Spring Cloud Gateway配置固定请求负载的实现方法咨询

你可以通过两种方式实现向目标服务传递固定请求负载的需求，以下是具体方案：

方案一：使用内置ModifyRequestBody过滤器（配置文件方式） #

直接利用Spring Cloud Gateway提供的ModifyRequestBody过滤器，将用户请求体替换为你指定的固定JSON内容。完整路由配置如下：

spring:
  cloud:
    gateway:
      routes:
        - id: example_route
          uri: http://example.com
          predicates:
            - Path=/example/**
          filters:
            # 补全路径重写规则（可根据实际需求调整）
            - RewritePath=/example/(?<segment>.*), /$\{segment}
            # 替换请求体为固定JSON
            - ModifyRequestBody=java.lang.String, java.lang.String, |
              {
                "Fname": "abc",
                "Lname": "xyz"
              }

参数说明： #

• ModifyRequestBody的三个参数依次为原始请求体类型、目标请求体类型、要替换的固定内容，这里因为是JSON字符串，所以统一使用java.lang.String。
• 竖线|用于换行书写JSON内容，保证配置格式清晰易读。

方案二：自定义GatewayFilter（代码方式） #

如果需要更灵活的逻辑控制（比如根据请求参数动态切换固定负载），可以自定义过滤器：

1. 编写自定义过滤器类：

import org.springframework.cloud.gateway.filter.GatewayFilter;
import org.springframework.cloud.gateway.filter.GatewayFilterChain;
import org.springframework.core.Ordered;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.http.server.reactive.ServerHttpRequest;
import org.springframework.stereotype.Component;
import org.springframework.web.reactive.function.BodyInserters;
import reactor.core.publisher.Mono;

@Component
public class FixedRequestBodyFilter implements GatewayFilter, Ordered {

    // 定义固定请求负载
    private static final String FIXED_REQUEST_BODY = "{\"Fname\": \"abc\", \"Lname\": \"xyz\"}";

    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        // 构建修改后的请求，替换请求体并设置正确的Content-Type
        ServerHttpRequest modifiedRequest = exchange.getRequest().mutate()
                .header(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE)
                .body(BodyInserters.fromValue(FIXED_REQUEST_BODY))
                .build();
        
        // 传递修改后的请求到下一个过滤器链
        return chain.filter(exchange.mutate().request(modifiedRequest).build());
    }

    @Override
    public int getOrder() {
        // 设置执行顺序，确保在路径重写等过滤器之后、请求转发之前执行
        return -1;
    }
}

2. 在配置文件中引用自定义过滤器：

spring:
  cloud:
    gateway:
      routes:
        - id: example_route
          uri: http://example.com
          predicates:
            - Path=/example/**
          filters:
            - RewritePath=/example/(?<segment>.*), /$\{segment}
            # 引用自定义过滤器
            - name: FixedRequestBodyFilter

注意事项： #

• 无论使用哪种方案，都要确保目标服务能识别设置的Content-Type（这里为application/json）。
• 自定义过滤器的Order值需合理设置，避免与其他过滤器的执行顺序冲突。

内容的提问来源于stack exchange，提问作者Anit Agrawal