当前位置：首页 > news >正文

住房和创新建设部网站网站的功能板块

news 2025/10/21 22:00:47

住房和创新建设部网站,网站的功能板块,网站流程图设计,网站版权信息修改简介 HTTP 请求 RequestBody 只能被读取一次：HttpServletRequest 的输入流 (InputStream) 在被读取后会被关闭，导致后续无法再次读取。本文将介绍如何通过请求包装类 (RequestWrapper) 来解决这个问题。问题背景当我们需要在以下场景中多次读取 Reques…

简介

HTTP 请求 RequestBody 只能被读取一次：HttpServletRequest 的输入流 (InputStream) 在被读取后会被关闭，导致后续无法再次读取。
本文将介绍如何通过 请求包装类 (RequestWrapper) 来解决这个问题。

问题背景

当我们需要在以下场景中多次读取 RequestBody 时，就会遇到这个问题：

日志记录：需要在拦截器或过滤器中记录请求体
参数校验：需要在多个地方校验请求体数据
数据解析：需要在不同的组件中解析请求体（如 Spring 的 @RequestBody 和手动解析）

直接尝试多次读取 InputStream 会导致异常：

// 第一次读取（可以成功）
String body1 = IOUtils.toString(request.getInputStream(), "UTF-8");// 第二次读取
// 场景一：（抛出异常：Stream closed）
String body2 = IOUtils.toString(request.getInputStream(), "UTF-8");
// 场景二：Controller层的@RequestBody直接报错 org.springframework.http.converter.HttpMessageNotReadableException: Required request body is missing: ...

解决方案：缓存请求体

我们可以通过自定义 HttpServletRequestWrapper 来缓存请求体，使得它可以被多次读取。

1. 实现 RequestWrapper

import javax.servlet.ReadListener;
import javax.servlet.ServletInputStream;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletRequestWrapper;
import java.io.*;public class RequestWrapper extends HttpServletRequestWrapper {//参数字节数组@Getterprivate byte[] requestBody;//Http请求对象private final HttpServletRequest request;public RequestWrapper(HttpServletRequest request) throws IOException {super(request);this.request = request;}@Overridepublic ServletInputStream getInputStream() throws IOException {/*每次调用此方法时将数据流中的数据读取出来，然后再回填到InputStream之中解决通过@RequestBody和@RequestParam（POST方式）读取一次后控制器拿不到参数问题*/if (null == this.requestBody) {ByteArrayOutputStream baos = new ByteArrayOutputStream();IOUtils.copy(request.getInputStream(), baos);this.requestBody = baos.toByteArray();}final ByteArrayInputStream bais = new ByteArrayInputStream(requestBody);return new ServletInputStream() {@Overridepublic boolean isFinished() {return false;}@Overridepublic boolean isReady() {return false;}@Overridepublic void setReadListener(ReadListener listener) {}@Overridepublic int read() {return bais.read();}};}@Overridepublic BufferedReader getReader() throws IOException {return new BufferedReader(new InputStreamReader(this.getInputStream()));}
}

2. 使用 RequestWrapper

在 Filter 中包装原始请求：

@Component
@Order(Ordered.HIGHEST_PRECEDENCE)	// 最高优先级
public class RequestCachingFilter implements Filter {@Overridepublic void doFilter(ServletRequest request, ServletResponse response, FilterChain chain)throws IOException, ServletException {// 包装原始请求RequestWrapper wrappedRequest = new RequestWrapper((HttpServletRequest) request);// 注意这里传的是request的装饰类 RequestWrapper chain.doFilter(wrappedRequest, response);}
}