一、问题背景分析

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

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生效。

            
     
      repeatlyReadRequestFilter
             
     
      com.api.core.RepeatlyReadFilter
         
        
            
     
      repeatlyReadRequestFilter
             
     
      /*
         
    

文章作者：

本文链接： 版本所有 ©转载时必须以链接形式注明作者和原始出处