Spring Cloud Gateway 截获请求的body

Spring Cloud Gateway 是一个基于 Spring Framework 的轻量级、高性能的 API 网关，它允许开发者路由、过滤、增强和拦截网络流量，包括 HTTP 请求的 body 部分。

在 Spring Cloud Gateway 中，你可以通过 `WebFlux` 的响应拦截器机制来截获并处理请求的 body。具体步骤如下：

1. **创建拦截器**：首先，你需要自定义一个 `GlobalFilter` 或 `ExchangeFilterFunction` 类，这是 Gateway 提供的用于添加全局过滤功能的接口。

import org.springframework.cloud.gateway.filter.GatewayFilter;
import org.springframework.cloud.gateway.filter.GatewayFilterFunction;
import org.springframework.stereotype.Component;

@Component
public class BodyLoggingFilter implements GatewayFilterFunction {
    @Override
    public GatewayFilter apply(String id) {
        return new LoggingBodyGatewayFilter(id);
    }
}

这里 `LoggingBodyGatewayFilter` 是一个具体的拦截器实现，它会记录请求的 body 内容。

2. **配置启用**：在 Gateway 的配置类（如 `application.yml` 或 `application.properties`）中注册这个过滤器，并指定需要应用的路径前缀。

spring:
  cloud:
    gateway:
      filters:
        - Predicates:
            path=/api/**
          filter-factory: com.example.BodyLoggingFilter

这表示对所有路径以 `/api` 开头的请求都会应用你的拦截器。

3. **拦截逻辑**：在 `LoggingBodyGatewayFilter` 中，你可以获取到 `ServerWebExchange` 对象，从中读取请求体的内容，然后进行处理、日志记录等操作。

@Component
public class LoggingBodyGatewayFilter extends ServerWebExchangeConverter {

    private final String id;

    public LoggingBodyGatewayFilter(String id) {
        this.id = id;
    }

    @Override
    protected Mono<Void> doFilter(ServerWebExchange exchange, WebFilterChain chain) {
        return chain.filter(exchange).flatMap(response -> {
            // 这里可以访问 request body
            Object requestBody = exchange.getAttributes().get(BodyExtractor.REQUEST_BODY_ATTRIBUTE);
            log.info("Received request with ID {} and body: {}", id, requestBody);

            return response;
        });
    }
}