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测试数据/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测试数据mons.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测试数据/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'