Spring Cloud Gateway 过滤器获取 POST 请求体内容

在 Spring Cloud Gateway 过滤器中获取 POST 方法的请求体，可以使用 Spring Cloud Gateway 提供的 ServerWebExchange 类。以下是一个示例代码：

import org.springframework.cloud.gateway.filter.GatewayFilter;
import org.springframework.cloud.gateway.filter.GatewayFilterChain;
import org.springframework.core.io.buffer.DataBuffer;
import org.springframework.http.HttpMethod;
import org.springframework.http.server.reactive.ServerHttpRequest;
import org.springframework.http.server.reactive.ServerHttpResponse;
import org.springframework.stereotype.Component;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import org.springframework.core.io.buffer.DataBufferUtils;
import java.nio.charset.Charset;

@Component
public class CustomGatewayFilter implements GatewayFilter {
  
  @Override
  public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
    ServerHttpRequest request = exchange.getRequest();
    ServerHttpResponse response = exchange.getResponse();
    
    // 获取请求体
    if (request.getMethod() == HttpMethod.POST) {
      Flux<DataBuffer> body = request.getBody();
      
      // 将请求体转换为字符串
      return DataBufferUtils.join(body)
          .flatMap(dataBuffer -> {
            DataBufferUtils.retain(dataBuffer);
            return Mono.just(dataBuffer);
          })
          .map(dataBuffer -> {
            byte[] bytes = new byte[dataBuffer.readableByteCount()];
            dataBuffer.read(bytes);
            DataBufferUtils.release(dataBuffer);
            return new String(bytes, Charset.defaultCharset());
          })
          .flatMap(bodyStr -> {
            // 在这里处理请求体
            // ...
            
            // 继续执行过滤器链
            return chain.filter(exchange);
          })
          .then();
    }
    
    // 非POST请求直接放行
    return chain.filter(exchange);
  }
  
}

在上面的代码中，我们首先检查请求的方法是否为 POST。如果是 POST 请求，我们使用 request.getBody() 方法获取请求体的 Flux<DataBuffer>。然后，我们使用 DataBufferUtils.join() 方法将请求体的所有 DataBuffer 合并为一个 DataBuffer。接下来，我们将 DataBuffer 转换为字符串，并在这里处理请求体。最后，我们继续执行过滤器链，使用 chain.filter(exchange) 方法。如果请求方法不是 POST，我们也直接放行。