Let me guess,读者肯定是遇到这个问题了,本文将尽量采用浅显的描述分析该问题产生的原因以及该问题的解决方法,同时也抛出一些疑问,共同探讨。“Required request body is missing”,该问题的实质是HttpServletRequest不可重复读问题。

一、问题背景分析

    遇到这个问题的读者应该使用了如下一种或几种技术:

  1. 使用POST提交Http请求;
  2. 使用了Filter或者拦截器(Interceptor)对HttpServletRequest对象提交的数据进行了读取操作;
  3. 在Controller的方法中使用了注解@RequestBody解析请求参数;

    如果与上述列出的几点不符,请读者回复补充,谢谢!

二、问题产生分析

    先打个比方,一支100ML试验管装满100ML实验液体,一次实验从该试验管抽取100ML液体使用,之后再做一次实验,从该试验管获取实验液体,请问还能得到吗?当然不能,对!
    同样的道理,如果在请求对象未到达方法之前,对HttpServletRequest对象自带的信息流(通过getInputStream方法获得)进行了读取,读取完成之后该InputStream的可读内容变为了0,那么该请求对象到达对应的处理方法之后,@RequestBody注解无法从请求对象中解析到请求参数信息,报错:“Required request body is missing”。
    基础比较扎实的同学可能会问,InputStream类有mark方法和reset方法,servlet为什么不重写这些方法使得HttpServletRequest可重复读呢?请大家发散思维。

三、问题解决方案

    解决方案仍然拿上节中的比喻来解说,首先把上述试管中的100ML液体取出来,把它赋能为具有可复制性的液体,然后把这100ML可克隆的液体封装在另一个试验管中,每做一个实验只需从该试验管抽取100ML即可,可以进行多次重复的实验。下面我们来看看代码是如何把普通液体赋能成可复制性的液体的。

package com.api.core;

import org.apache.commons.io.IOUtils;

import javax.servlet.ServletInputStream;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletRequestWrapper;
import java.io.ByteArrayInputStream;
import java.io.IOException;

/**
 * HttpServletRequest封装类
 **/
public class WrappedHttpServletRequest extends HttpServletRequestWrapper {
    private final byte[] bytes;

    public WrappedHttpServletRequest(HttpServletRequest request) throws IOException {
        super(request);

        // 读取输入流里的请求参数,并保存到bytes里
        bytes = IOUtils.toByteArray(request.getInputStream());
    }

    @Override
    public ServletInputStream getInputStream() throws IOException {
        return new BufferedServletInputStream(this.bytes);
    }

    class BufferedServletInputStream extends ServletInputStream {
        private ByteArrayInputStream inputStream;
        public BufferedServletInputStream(byte[] buffer) {
            //此处即赋能,可以详细查看ByteArrayInputStream的该构造函数;
            this.inputStream = new ByteArrayInputStream( buffer );    
        }
        @Override
        public int available() throws IOException {
            return inputStream.available();
        }
        @Override
        public int read() throws IOException {
            return inputStream.read();
        }
        @Override
        public int read(byte[] b, int off, int len) throws IOException {
            return inputStream.read( b, off, len );
        }
    }

}

    上述代码定义了HttpServletRequest对象的包装类,下面需要定义一个Filter将所有HttpServletRequest对象包装为WrappedHttpServletRequest对象。代码如下:

package com.api.core;

import javax.servlet.*;
import javax.servlet.http.HttpServletRequest;
import java.io.IOException;

/**
 * 封装HttpServletRequest为可重复读取请求
 **/
public class RepeatlyReadFilter implements Filter {
    @Override
    public void init(FilterConfig filterConfig) throws ServletException {

    }

    @Override
    public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException {
        if(request instanceof HttpServletRequest) {
            request = new WrappedHttpServletRequest((HttpServletRequest) request);
        }
        chain.doFilter(request, response);
    }

    @Override
    public void destroy() {

    }
}

    最后,在web.xml中配置上述Fileter生效。

    <filter>
        <filter-name>repeatlyReadRequestFilter</filter-name>
        <filter-class>com.api.core.RepeatlyReadFilter</filter-class>
    </filter>
    <filter-mapping>
        <filter-name>repeatlyReadRequestFilter</filter-name>
        <url-pattern>/*</url-pattern>
    </filter-mapping>
文章作者:xiaohui249
本文链接:https://javatech.wang/index.php/archives/106/
版本所有 ©转载时必须以链接形式注明作者和原始出处