### 配置 Spring Cloud Gateway 缓存并记录 HTTP 请求 Body 和 Form 数据 为了实现这一目标，在 `Spring Cloud Gateway` 中可以利用自定义过滤器来处理请求体的读取和缓存。由于默认情况下，HTTP 请求流只能被消费一次，因此需要创建一个能够重新构建输入流的工具类以便多次访问请求内容。 对于特定类型的媒体格式如 JSON 或者 URL 编码形式的数据，可以通过扩展 `AbstractRequestLoggingGatewayFilterFactory` 类来自定义日志记录逻辑[^1]。具体来说： #### 创建可重读的 Request Wrapper 首先编写一个继承自 `ServletServerHttpRequest` 的包装类用于保存原始字节数据，并允许后续操作再次获取这些数据。此部分代码如下所示： ```java import org.springframework.http.server.ServletServerHttpRequest; import javax.servlet.ReadListener; import javax.servlet.ServletInputStream; import java.io.ByteArrayInputStream; public class CachedBodyHttpServletRequest extends ServletServerHttpRequest { private final byte[] cachedBody; public CachedBodyHttpServletRequest(ServletServerHttpRequest request, byte[] body) { super(request.getServletRequest()); this.cachedBody = body; } @Override public ServletInputStream getInputStream() throws IOException { ByteArrayInputStream bais = new ByteArrayInputStream(cachedBody); return new DelegatingServletInputStream(bais); } } ``` 这里还涉及到一个小辅助类 `DelegatingServletInputStream` ，它负责将给定的输入流转成符合接口要求的形式。 #### 自定义 Filter 实现 接着定义一个新的网关过滤器工厂，用来拦截指定路径下的所有请求并将它们的内容存储起来供之后的日志模块调用: ```java @Component @Slf4j public class CustomLogginFilter extends AbstractGatewayFilterFactory<CustomLogginFilter.Config> { @Autowired private ObjectMapper objectMapper; public static class Config {} @Override public GatewayFilter apply(Config config) { return (exchange, chain) -> { ServerWebExchange mutatedExchange = exchange.mutate().request(wrapRequest(exchange.getRequest())).build(); return chain.filter(mutatedExchange).then(Mono.fromRunnable(() -> logResponse(mutatedExchange))); }; } private ServerHttpRequest wrapRequest(ServerHttpRequest request){ // 只有当 Content-Type 是 application/json 或 form-data 才执行特殊处理 if (!isSupportedContentType(request)) { return request; } try{ String bodyString = StreamUtils.copyToString(request.getBody(), Charset.defaultCharset()); Map<String,Object> map = null; MediaType mediaType = request.getHeaders().getContentType(); switch(mediaType.getTypeSubtype()){ case "application/json": map = objectMapper.readValue(bodyString,Map.class); break; case "application/x-www-form-urlencoded": map = parseUrlEncodedForm(bodyString); break; default: throw new RuntimeException("Unsupported Media Type"); } byte[] updatedBody = objectMapper.writeValueAsBytes(map); HttpEntity<byte[]> entity = new HttpEntity<>(updatedBody,request.getHeaders()); return new CachedBodyHttpServletRequest(new ServletServerHttpRequest(entity),updatedBody); }catch(Exception e){ log.error(e.getMessage(),e); return request; } } private boolean isSupportedContentType(ServerHttpRequest request){ List<MediaType> supportedMediaTypes = Arrays.asList(MediaType.APPLICATION_JSON, MediaType.APPLICATION_FORM_URLENCODED); return supportedMediaTypes.stream() .anyMatch(type-> type.includes(request.getHeaders().getContentType())); } private void logResponse(ServerWebExchange exchange){ ClientResponse response = ... ;// 获取响应对象的方式取决于实际场景 StringBuilder sb = new StringBuilder("\n--\n"); sb.append("Status Code: ").append(response.statusCode()).append('\n'); sb.append("Headers:\n").append(formatHeaders(response.headers())); if(isSupportedContentType(exchange.getRequest())){ Mono<String> responseBodyMono = response.bodyToMono(String.class); responseBodyMono.subscribe(bodyText -> { sb.append("Body:\n").append(bodyText); logger.info(sb.toString()); }); }else{ logger.info(sb.toString()); } } ... } ``` 上述代码片段展示了如何捕获符合条件的请求及其负载信息，并通过日志输出至控制台或其他目的地。需要注意的是，这段程序仅适用于所列明的支持介质类型[^2]。