spring应用中多次读取http post方法中的流遇到的问题

@RequestMapping("/XXX.do")  public void XXX(HttpServletRequest request, HttpServletResponse response) throws IOException {    JSONObject jsonObject = WebUtils.getParameters(request);　　　　 //业务处理    ResponseUtil.setResponse(response, MessageFactory.createSuccessMsg());  }

  public static JSONObject getParameters(HttpServletRequest request) throws IOException {    InputStream is = null;    is = new BufferedInputStream(request.getInputStream(), BUFFER_SIZE);    int contentLength = Integer.valueOf(request.getHeader("Content-Length"));    byte[] bytes = new byte[contentLength];    int readCount = 0;    while (readCount < contentLength) {      readCount += is.read(bytes, readCount, contentLength - readCount);    }    String requestJson = new String(bytes, AppConstants.UTF8);    if (StringUtils.isBlank(requestJson)) {      return new JSONObject();    }    JSONObject jsonObj = JsonUtils.toJSONObject(requestJson);    return jsonObj;  }

javax.servlet.ServletRequest#getInputStream

/** * */package com.ckl.filter;import com.ckl.utils.BaseWebUtils;import com.ckl.utils.MultiReadHttpServletRequest;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.core.annotation.Order;import org.springframework.http.HttpMethod;import org.springframework.http.MediaType;import javax.servlet.*;import javax.servlet.annotation.WebFilter;import javax.servlet.http.HttpServletRequest;import java.io.IOException;/** * Web流多次读写过滤器 * * 拦截所有请求，主要是针对第三方提交过来的请求. * 为什么要做成可多次读写的流，因为可以在aop层打印日志。 * 但是不影响controller层继续读取该流 * * 该filter的原理：https://stackoverflow.com/questions/10210645/http-servlet-request-lose-params-from-post-body-after-read-it-once/17129256#17129256 * @author ckl */@Order(1)@WebFilter(filterName = "cacheRequestFilter", urlPatterns = "*.do")public class CacheRequestFilter implements Filter {  private static final Logger logger = LoggerFactory.getLogger(CacheRequestFilter.class);  @Override  public void init(FilterConfig filterConfig) throws ServletException {    // TODO Auto-generated method stub  }  @Override  public void doFilter(ServletRequest request, ServletResponse response,             FilterChain chain) throws IOException, ServletException {    HttpServletRequest httpServletRequest = (HttpServletRequest) request;    logger.info("request uri:{}",httpServletRequest.getRequestURI());    if (BaseWebUtils.isFormPost(httpServletRequest)){      httpServletRequest = new MultiReadHttpServletRequest(httpServletRequest);      String parameters = BaseWebUtils.getParameters(httpServletRequest);      logger.info("CacheRequestFilter receive post req. body is {}", parameters);    }else if (isPost(httpServletRequest)){      //文件上传请求，没必要缓存请求      if (request.getContentType().contains(MediaType.MULTIPART_FORM_DATA_VALUE)){      }else {        httpServletRequest = new MultiReadHttpServletRequest(httpServletRequest);        String parameters = BaseWebUtils.getParameters(httpServletRequest);        logger.info("CacheRequestFilter receive post req. body is {}", parameters);      }    }    chain.doFilter(httpServletRequest, response);  }  @Override  public void destroy() {    // TODO Auto-generated method stub  }  public static boolean isPost(HttpServletRequest request) {    return HttpMethod.POST.matches(request.getMethod());  }}MultiReadHttpServletRequest.java:import org.apache.commons.io.IOUtils;import javax.servlet.ServletInputStream;import javax.servlet.http.HttpServletRequest;import javax.servlet.http.HttpServletRequestWrapper;import java.io.BufferedReader;import java.io.ByteArrayOutputStream;import java.io.IOException;import java.io.InputStreamReader;/** * desc: * https://stackoverflow.com/questions/10210645/http-servlet-request-lose-params-from-post-body-after-read-it-once/17129256#17129256 * @author : ckl * creat_date: 2018/8/2 0002 * creat_time: 13:46 **/public class MultiReadHttpServletRequest extends HttpServletRequestWrapper {  private ByteArrayOutputStream cachedBytes;  public MultiReadHttpServletRequest(HttpServletRequest request) {    super(request);    cachedBytes = new ByteArrayOutputStream();    ServletInputStream inputStream = null;    try {      inputStream = super.getInputStream();      IOUtils.copy(inputStream, cachedBytes);    } catch (IOException e) {      e.printStackTrace();    }  }  @Override  public ServletInputStream getInputStream() throws IOException {    return new CachedServletInputStream(cachedBytes);  }  @Override  public BufferedReader getReader() throws IOException {    return new BufferedReader(new InputStreamReader(getInputStream()));  }}

package com.ceiec.webservice.utils;import javax.servlet.ReadListener;import javax.servlet.ServletInputStream;import java.io.ByteArrayInputStream;import java.io.ByteArrayOutputStream;import java.io.IOException;/** * An inputstream which reads the cached request body */public class CachedServletInputStream extends ServletInputStream {  private ByteArrayInputStream input;  public CachedServletInputStream(ByteArrayOutputStream cachedBytes) {    // create a new input stream from the cached request body    byte[] bytes = cachedBytes.toByteArray();    input = new ByteArrayInputStream(bytes);  }  @Override  public int read() throws IOException {    return input.read();  }  @Override  public boolean isFinished() {    return false;  }  @Override  public boolean isReady() {    return false;  }  @Override  public void setReadListener(ReadListener readListener) {  }}

curl -i -X POST /-H "Content-Type:application/json" /-d /'{"id":"32"}' /'http://localhost:8080/springmvc-multiread-post/testPost.do'