快捷導(dǎo)航

SpringBoot攔截器執(zhí)行后,Controller層不執(zhí)行的問題及解決

更新時間：2025年07月18日 16:20:25 作者：努力的雅木茶

請求攔截器中若調(diào)用getInputStream()讀取流,會導(dǎo)致Controller層無法獲取請求體,引發(fā)400錯誤,解決方案：避免在攔截器中讀取流,或使用緩存（如將流轉(zhuǎn)為字符串）確保數(shù)據(jù)可重復(fù)使用

問題描述

請求在SpringBoot攔截器中執(zhí)行后，在Controller層不執(zhí)行，前端錯誤碼400

原因分析

ServletRequest 中通過流獲取參數(shù)（getInputStream()）只能讀取一次，

而@RequestBody注解也是根據(jù)流的形式獲取參數(shù)。

所以攔截器中 request 使用流獲取參數(shù)后，Controller中獲取不到參數(shù)

解決方案

// 攔截器中獲取請求
RequestWrapper myRequestWrapper = new RequestWrapper(request);
String JSONData = myRequestWrapper.getBody();

public class RequestWrapper extends HttpServletRequestWrapper {

    /**
     * 存儲請求數(shù)據(jù)
     */
    private String body;

    public RequestWrapper(HttpServletRequest request) {
        super(request);
        renewBody(request);
    }

    /**
     * 重寫getInputStream方法
     * @return
     */
    @Override
    public ServletInputStream getInputStream() {
        final ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(body.getBytes());
        ServletInputStream servletInputStream = new ServletInputStream() {
            @Override
            public boolean isFinished() {
                return false;
            }

            @Override
            public boolean isReady() {
                return false;
            }

            @Override
            public void setReadListener(ReadListener readListener) {
            }

            @Override
            public int read() {
                return byteArrayInputStream.read();
            }
        };
        return servletInputStream;

    }

    /**
     * 重寫getReader方法
     * @return
     */
    @Override
    public BufferedReader getReader() {
        return new BufferedReader(new InputStreamReader(this.getInputStream()));
    }

    /**
     * 讀取body的值
     * @param request
     */
    private void renewBody(HttpServletRequest request) {
        StringBuilder stringBuilder = new StringBuilder();
        BufferedReader bufferedReader = null;
        try {
            InputStream inputStream = request.getInputStream();
            if (inputStream != null) {
                bufferedReader = new BufferedReader(new InputStreamReader(inputStream));
                char[] charBuffer = new char[128];
                int bytesRead = -1;
                while ((bytesRead = bufferedReader.read(charBuffer)) > 0) {
                    stringBuilder.append(charBuffer, 0, bytesRead);
                }
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            if (bufferedReader != null) {
                try {
                    bufferedReader.close();
                } catch (IOException ex) {
                    ex.printStackTrace();
                }
            }
        }
        body = stringBuilder.toString();
    }

    public String getBody() {
        return body;
    }

}

@Component
public class HttpServletFilter implements Filter {


    @Override
    public void init(FilterConfig filterConfig) throws ServletException {

    }

    @Override
    public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {
        ServletRequest requestWrapper = null;
        if (servletRequest instanceof HttpServletRequest) {
            requestWrapper = new RequestWrapper((HttpServletRequest) servletRequest);
            System.out.println(((RequestWrapper) requestWrapper).getBody());
            // do something
        }
        if (requestWrapper == null) {
            filterChain.doFilter(servletRequest, servletResponse);
        } else {
            filterChain.doFilter(requestWrapper, servletResponse);
        }

    }

    @Override
    public void destroy() {

    }
}