为什么SpringMVC中请求的body不支持多次读取

 更新时间:2019年12月31日 14:14:28   作者:2的32次方  
这篇文章主要介绍了为什么SpringMVC中请求的body不支持多次读取,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧

前言

在Springboot的项目中使用Servlet的Filter来实现方法签名时,发现请求的body不支持多次读取。我是通过getInputStream()来获取流,然后通过读取流来获取请求的body。

虽然网上有很多解决方案的例子,但是我发现没有一篇文章解释为什么会这样的文章,所以决定自己去研究源码。

问题表现

Content-Type为application/json的POST请求时,会返回状态码为400的响应,响应的body如下:

{
  "timestamp": "2019-12-27T02:48:50.544+0000",
  "status": 400,
  "error": "Bad Request",
  "message": "Required request body is missing: ...省略非关键信息...",
  "path": "/"
}

而在日志中则有以下关键日志

2019-12-27 10:48:50.543  WARN 18352 --- [nio-8080-exec-2] .w.s.m.s.DefaultHandlerExceptionResolver : Resolved [org.springframework.http.converter.HttpMessageNotReadableException:...省略非关键信息... 

初步分析

根据提示信息可以得知,由于请求的body没有了,所以才会抛出这个异常。但是为什么body会没有了呢?是否因为通过getInputStream()获取到的流被读取了所以引起这个问题呢?

复盘代码

于是我编写了一个复盘的示例,就是一个在日志中打印请求body的Filter,关键代码如下:

@Slf4j
@WebFilter
public class InputStreamFilter implements Filter {

  @Override
  public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws ServletException, IOException {
    ServletInputStream inputStream=servletRequest.getInputStream();
    String charSetStr = servletRequest.getCharacterEncoding();
    if (charSetStr == null) {
      charSetStr = "UTF-8";
    }
    Charset charSet = Charset.forName(charSetStr);
    log.info("请求的body为:\n{}",StreamUtils.copyToString(inputStream,charSet));
    filterChain.doFilter(servletRequest,servletResponse);
  }

RequestResponseBodyMethodProcessor

首先是找出抛出HttpMessageNotReadableException的方法和对应的类,关键类为RequestResponseBodyMethodProcessor的readWithMessageConverters()方法:

  @Override
 protected <T> Object readWithMessageConverters(NativeWebRequest webRequest, MethodParameter parameter,
  Type paramType) throws IOException, HttpMediaTypeNotSupportedException, HttpMessageNotReadableException {
    ...省略非关键代码...
    // 关键代码
 Object arg = readWithMessageConverters(inputMessage, parameter, paramType);
 if (arg == null && checkRequired(parameter)) {
  throw new HttpMessageNotReadableException("Required request body is missing: " +
   parameter.getExecutable().toGenericString(), inputMessage);
 }
 return arg;
 }

从上面的代码可以得知,异常是由于readWithMessageConverters()方法返回null且这个参数是必填引起,现在主要关注为什么返回null。所以查看readWithMessageConverters()方法

AbstractMessageConverterMethodArgumentResolver

而实际上其实是调用了AbstractMessageConverterMethodArgumentResolver的readWithMessageConverters()方法,而在这个方法中其实是通过调用AbstractMessageConverterMethodArgumentResolver的内部类EmptyBodyCheckingHttpInputMessage的构造方法来获取流。

readWithMessageConverters()关键代码如下:

  @Nullable
 protected <T> Object readWithMessageConverters(HttpInputMessage inputMessage, MethodParameter parameter,
  Type targetType) throws IOException, HttpMediaTypeNotSupportedException, HttpMessageNotReadableException {
    ...省略非关键代码...
 EmptyBodyCheckingHttpInputMessage message;
 try {
   // 此处调用构造方法时进行了流的读取
  message = new EmptyBodyCheckingHttpInputMessage(inputMessage);
      for (HttpMessageConverter<?> converter : this.messageConverters) {
  Class<HttpMessageConverter<?>> converterType = (Class<HttpMessageConverter<?>>) converter.getClass();
  GenericHttpMessageConverter<?> genericConverter =
   (converter instanceof GenericHttpMessageConverter ? (GenericHttpMessageConverter<?>) converter : null);
  if (genericConverter != null ? genericConverter.canRead(targetType, contextClass, contentType) :
   (targetClass != null && converter.canRead(targetClass, contentType))) {
   if (message.hasBody()) {
   ...省略非关键代码...
   }
   else {
     // 此处是处理流读取返回null的情况
   body = getAdvice().handleEmptyBody(null, message, parameter, targetType, converterType);
   }
   break;
  }
  }
 }
 catch (IOException ex) {
  throw new HttpMessageNotReadableException("I/O error while reading input message", ex, inputMessage);
 }

 ...省略非关键代码...

 MediaType selectedContentType = contentType;
 Object theBody = body;
 LogFormatUtils.traceDebug(logger, traceOn -> {
  String formatted = LogFormatUtils.formatValue(theBody, !traceOn);
  return "Read \"" + selectedContentType + "\" to [" + formatted + "]";
 });

 return body;
 }
 

EmptyBodyCheckingHttpInputMessage关键构造方法如下:

    // 从请求中获取到的InputStream对象
    @Nullable
 private final InputStream body;

 public EmptyBodyCheckingHttpInputMessage(HttpInputMessage inputMessage) throws IOException {
  this.headers = inputMessage.getHeaders();
  InputStream inputStream = inputMessage.getBody();
  // 判断InputStream是否支持mark
  if (inputStream.markSupported()) {
    // 标记流的起始位置
  inputStream.mark(1);
  // 读取流
  this.body = (inputStream.read() != -1 ? inputStream : null);
  // 重置流,下次读取会从起始位置重新开始读取
  inputStream.reset();
  }
  else {
    // 回退输入流,支持重复读取的InputStream
  PushbackInputStream pushbackInputStream = new PushbackInputStream(inputStream);
  // 读取流
  int b = pushbackInputStream.read();
  if (b == -1) {
    // 返回-1表示流无数据存在
   this.body = null;
  }
  else {
    // 流存在数据,直接赋值
   this.body = pushbackInputStream;
   // 回退流到起始位置,等价于reset()方法
   pushbackInputStream.unread(b);
  }
  }
 }

从上面的代码可以得知,起始SpringMVC是支持对请求的InputStream进行多次读取的以及InputStream其实可以支持流重复读取。但是实际上却出现不支持流重复读取的情况,这是为什么呢?

下面会通过分析Jetty应用服务器对InputStream的实现来进行分析。

HttpInput

Jetty中继承InputStrean的类是org.eclipse.jetty.server.HttpInputOverHTTP,而关键的代码在其父类HttpInput上。

首先HttpInput继承了ServletInputStream(这个抽象类继承了·InputStream抽象类),且并未重写markSupported()方法(这个方法默认实现为返回false)。所以问题应该是由于HttpInput流重复读取会直接返回-1引起的。这里不做展开,有兴趣的朋友可以自行跟踪源码的运行

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。

相关文章

  • 使用Java的方式模拟Flutter的Widget实现多层括号嵌套

    使用Java的方式模拟Flutter的Widget实现多层括号嵌套

    这篇文章主要介绍了使用Java的方式模拟Flutter的Widget的实现多层括号嵌套问题,本文给大家介绍的非常详细,具有一定的参考借鉴价值,需要的朋友可以参考下
    2019-07-07
  • java实现动态上传多个文件并解决文件重名问题

    java实现动态上传多个文件并解决文件重名问题

    这篇文章主要为大家详细介绍了java实现动态上传多个文件,并解决文件重名问题的方法,感兴趣的小伙伴们可以参考一下
    2016-03-03
  • Java 虚拟机栈详解分析

    Java 虚拟机栈详解分析

    在线程创建时,JVM会为每个线程创建一个单独的栈空间。JVM的栈内存不需要是连续的。JVM在栈上会进行两个操作:压入和弹出栈帧。对于一个特定的线程来说,栈被称为运行时栈。这个线程调用的每个方法会被存储在响应的运行时栈里,包括了参数,局部变量,计算媒介和其他数据
    2021-11-11
  • Java日期操作类常见用法示例

    Java日期操作类常见用法示例

    这篇文章主要介绍了Java日期操作类常见用法,结合实例形式分析了java针对日期时间的获取、转换常见操作技巧,需要的朋友可以参考下
    2019-07-07
  • 使用SpringBoot2.x配置静态文件缓存

    使用SpringBoot2.x配置静态文件缓存

    这篇文章主要介绍了使用SpringBoot2.x配置静态文件缓存的操作,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-08-08
  • Java was started but returned exit code=13问题解决案例详解

    Java was started but returned exit code=13问题解决案例详解

    这篇文章主要介绍了Java was started but returned exit code=13问题解决案例详解,本篇文章通过简要的案例,讲解了该项技术的了解与使用,以下就是详细内容,需要的朋友可以参考下
    2021-09-09
  • 关于Tomcat出现The origin server did not find a current representation for the target resourc...的问题

    关于Tomcat出现The origin server did not find a current represent

    这篇文章主要介绍了关于Tomcat出现The origin server did not find a current representation for the target resourc...的问题,感兴趣的小伙伴们可以参考一下
    2020-08-08
  • 基于JAVA中Jersey处理Http协议中的Multipart的详解

    基于JAVA中Jersey处理Http协议中的Multipart的详解

    之前在基于C#开发彩信用最原始的StringBuilder拼接字符串方式处理过Multipart。现在在做一个项目的时候,由于之前的技术路线都是使用Jersey处理Http这块,为了保持技术路线一致,研究了一下如何使用Jersey处理Http协议中的Multipart
    2013-05-05
  • eclipse里没有“Dynamic Web Project“这个选项的问题解决

    eclipse里没有“Dynamic Web Project“这个选项的问题解决

    本文主要介绍了eclipse里没有“Dynamic Web Project“这个选项的问题解决,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2022-08-08
  • 深入Java注解原理Annotation

    深入Java注解原理Annotation

    这篇文章主要介绍了深入Java注解原理Annotation,注解可以附加在package,class,method,field等上面,可相当于添加了额外的辅助信息,可以通过反射机制编程实现对这些元数据的访问,需要的朋友可以参考下
    2023-10-10

最新评论