解决spring 处理request.getInputStream()输入流只能读取一次问题

这篇文章主要介绍了解决spring 处理request.getInputStream()输入流只能读取一次问题，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧

一般我们会在InterceptorAdapter拦截器中对请求进行验证

正常普通接口请求，request.getParameter()可以获取，能多次读取

如果我们的接口是用@RequestBody来接受数据，那么我们在拦截器中

需要读取request的输入流 ，因为 ServletRequest中getReader()和getInputStream()只能调用一次

这样就会导致controller 无法拿到数据。

解决方法 ：

1、自定义一个类 BodyReaderHttpServletRequestWrapper.java

import java.io.BufferedReader; import java.io.ByteArrayInputStream; import java.io.IOException; import java.io.InputStreamReader; import javax.servlet.ReadListener; import javax.servlet.ServletInputStream; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletRequestWrapper; import org.springframework.util.StreamUtils; /** * @author WBG * @date 2020/6/22 10:42 * @describe */ public class BodyReaderHttpServletRequestWrapper extends HttpServletRequestWrapper{ private byte[] requestBody = null;//用于将流保存下来 public BodyReaderHttpServletRequestWrapper(HttpServletRequest request) throws IOException { super(request); requestBody = StreamUtils.copyToByteArray(request.getInputStream()); } @Override public ServletInputStream getInputStream() throws IOException { final ByteArrayInputStream bais = new ByteArrayInputStream(requestBody); return new ServletInputStream() { @Override public int read() throws IOException { return bais.read(); } @Override public boolean isFinished() { return false; } @Override public boolean isReady() { return false; } @Override public void setReadListener(ReadListener readListener) { } }; } @Override public BufferedReader getReader() throws IOException{ return new BufferedReader(new InputStreamReader(getInputStream())); } }

2、自定义 MyFilter 继承Filter

import javax.servlet.*; import javax.servlet.http.HttpServletRequest; import java.io.BufferedReader; import java.io.IOException; /** * @author WBG * @date 2020/6/22 14:32 * @describe */ public class MyFilter implements Filter { @Override public void init(FilterConfig filterConfig) throws servletexception { System.out.println("开始"); } @Override public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, servletexception { ServletRequest requestWrapper=null; if(request instanceof HttpServletRequest) { requestWrapper=new BodyReaderHttpServletRequestWrapper((HttpServletRequest)request); } if(requestWrapper==null) { chain.doFilter(request, response); }else { System.out.println("------------------------------请求报文----------------------------------"); System.out.println(getParamsFromrequestBody((HttpServletRequest) requestWrapper)); System.out.println("------------------------------请求报文----------------------------------"); chain.doFilter(requestWrapper, response); } } /* * * 获取请求体内容 * @return * @throws IOException */ private String getParamsFromrequestBody(HttpServletRequest request) throws IOException { BufferedReader br = null; String listString = ""; try { br = request.getReader(); String str = ""; while ((str = br.readLine()) != null) { listString += str; } } catch (IOException e) { e.printstacktrace(); } return listString; } @Override public void destroy() { System.out.println("destroy"); } }

3、web.xm配置过滤器

test2com.zhhy.hy2000interface.utils.filter.MyFiltertest2/*

（如果是Springboot，使用注解即可）

以上这篇解决spring 处理request.getInputStream()输入流只能读取一次问题就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持编程之家。