Java spring获取post请求的主体

Question

我有以下问题：我试图在Spring控制器处理POST请求之前获取它的主体。为此，我使用HandlerInterceptorAdapter的preHandle（）方法。

如本讨论中所述 SpringREST服务：从请求中检索JSON 我也使用使用此包装器，我设法打印了第一个POST请求的正文，但第二个POST抛出一个IOException：流关闭。

您对如何获取所有POST请求的正文有什么想法吗？

下面是拦截器的preHandle()方法:

@Override
public boolean preHandle(HttpServletRequest request,
        HttpServletResponse response, Object handler) throws Exception {
    System.out.println(request.getMethod());
    MyRequestWrapper w = new MyRequestWrapper(request);

    BufferedReader r = w.getReader();
    System.out.println(r.readLine());

    return super.preHandle(request, response, handler);
}

HttpServletRequestWrapper：

public class MyRequestWrapper extends HttpServletRequestWrapper {
private ByteArrayOutputStream cachedBytes;
private HttpServletRequest request;

public MyRequestWrapper(HttpServletRequest request) {
    super(request);
    this.request = request;
}

@Override
public ServletInputStream getInputStream() throws IOException {
    cachedBytes = new ByteArrayOutputStream();

    if (request.getMethod().equals("POST"))
        cacheInputStream();

    return new CachedServletInputStream();
}

@Override
public BufferedReader getReader() throws IOException {
    return new BufferedReader(new InputStreamReader(getInputStream()));
}

private void cacheInputStream() throws IOException {
    /*
     * Cache the inputstream in order to read it multiple times. For
     * convenience, I use apache.commons IOUtils
     */
    ServletInputStream inputStream = super.getInputStream();

    if (inputStream == null) {
        return;
    }

    IOUtils.copy(inputStream, cachedBytes);
}

/* An inputstream which reads the cached request body */
public class CachedServletInputStream extends ServletInputStream {
    private ByteArrayInputStream input;

    public CachedServletInputStream() {
        /* create a new input stream from the cached request body */
        input = new ByteArrayInputStream(cachedBytes.toByteArray());
    }

    @Override
    public int read() throws IOException {
        return input.read();
    }
}
}

控制台输出:

2014-10-15 12:13:00 INFO [http-nio-8080-exec-1] org.springframework.web.servlet.DispatcherServlet - FrameworkServlet 'dispatcherServlet': initialization completed in 9 ms
GET
null
GET
null
POST
{"long":null,"owner":{"__type":"Owner","id":20,"version":1,"md5Password":""},"string":"ws","tool":{"__type":"Tool","id":33,"version":1}}
POST
2014-10-15 12:13:00 ERROR [http-nio-8080-exec-3] org.apache.catalina.core.ContainerBase.[Tomcat].[localhost].[/].[dispatcherServlet] - Servlet.service() for servlet dispatcherServlet threw exception
java.io.IOException: Stream closed

Answer 1

我使用了实现过滤器的过滤器

过滤器。在这里，我包装了一个请求和一个响应，以便不仅从它们中读取一次。您可以为此使用ContentCachingRequest estWrapper和ContentCachingReportseWrapper。

    @Component
    public class RequestLogFilter implements Filter {

    private final Logger logger = LoggerFactory.getLogger(RequestLogFilter.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 {

        logger.info("======================> FILTER <======================");

        HttpServletRequest requestToCache = new ContentCachingRequestWrapper((HttpServletRequest) request);
        HttpServletResponse responseToCache = new ContentCachingResponseWrapper((HttpServletResponse) response);

        // before method
        chain.doFilter(requestToCache, responseToCache);
        // after method

        // your logic(save to DB, logging...)
        getRequestData(request);
        getResponseData(response);
    }

    @Override
    public void destroy() {

    }

}

-

@Component
public class RequestLogInterceptor extends HandlerInterceptorAdapter {

    private final Logger logger = LoggerFactory.getLogger(RequestLogInterceptor.class);

    @Autowired
    private InboundRequestLogStore inboundRequestLogStore;

    @Override
    public void postHandle(HttpServletRequest request, HttpServletResponse response, Object handler, ModelAndView modelAndView) {

        logger.info("====================> INTERCEPTOR <========================");

        try {
            if (request.getAttribute(InboundRequestAspect.INBOUND_LOG_MARKER) != null) {

                InboundRequestLogRecord logRecord = new InboundRequestLogRecord();

                logRecord.setIpAddress(request.getRemoteAddr());

                // getting request and response body
                logRecord.setRequestBody(getRequestData(request));
                logRecord.setResponseBody(getResponseData(response));

                logRecord.setResponseCode(((HttpServletResponse) response).getStatus());

                String uri = request.getScheme() + "://" + request.getServerName()
                        + ("http".equals(request.getScheme()) && request.getServerPort() == 80
                                || "https".equals(request.getScheme()) && request.getServerPort() == 443 ? ""
                                        : ":" + request.getServerPort())
                        + request.getRequestURI()
                        + (request.getQueryString() != null ? "?" + request.getQueryString() : "");
                logRecord.setUrl(uri);
                inboundRequestLogStore.add(logRecord);  // save to DB

              } else {

                        ((ContentCachingResponseWrapper) response).copyBodyToResponse(); // in other case you send null to the response

              }


        } catch (Exception e) {
            logger.error("error ", e);

            try {
                    ((ContentCachingResponseWrapper) response).copyBodyToResponse(); // in other case you send null to the response
                } catch (Exception e2) {
                    // TODO Auto-generated catch block
                    logger.error("error ", e2);
                }

        }



    }

    public static String getRequestData(final HttpServletRequest request) throws UnsupportedEncodingException {
        String payload = null;
        ContentCachingRequestWrapper wrapper = WebUtils.getNativeRequest(request, ContentCachingRequestWrapper.class);
        if (wrapper != null) {
            byte[] buf = wrapper.getContentAsByteArray();
            if (buf.length > 0) {
                payload = new String(buf, 0, buf.length, wrapper.getCharacterEncoding());
            }
        }
        return payload;
    }

        public static String getResponseData(final HttpServletResponse response) throws UnsupportedEncodingException, IOException {
            String payload = null;
            ContentCachingResponseWrapper wrapper = WebUtils.getNativeResponse(response, ContentCachingResponseWrapper.class);
            if (wrapper != null) {
                byte[] buf = wrapper.getContentAsByteArray();
                if (buf.length > 0) {
                    payload = new String(buf, 0, buf.length, wrapper.getCharacterEncoding());
                }
                wrapper.copyBodyToResponse();   // in other case you send null to the response
            }
            return payload;
        }

    }

添加到servlet-context.xml

<mvc:interceptors>
    <mvc:interceptor>
        <mvc:mapping path="/**" />
        <beans:bean class="path.to.RequestLogInterceptor"/>
    </mvc:interceptor>
</mvc:interceptors>

命名空间：

<beans:beans xmlns="http://www.springframework.org/schema/mvc"
    xmlns:mvc="http://www.springframework.org/schema/mvc"
    xsi:schemaLocation="http://www.springframework.org/schema/mvc 
    http://www.springframework.org/schema/mvc/spring-mvc.xsd">

内容缓存请求Wrapper - http://docs.spring.io/spring-framework/docs/current/javadoc-api/org/springframework/web/util/ContentCachingRequestWrapper.html

ContentCachingReportseWrapper-http://docs.spring.io/spring-framework/docs/current/javadoc-api/org/springframework/web/util/ContentCachingResponseWrapper.html

Answer 2

您试图从包装器中的原始请求中读取，但是在这之后，原始请求仍然被读取——因此请求输入流已经被消耗，不能再次被读取。

与其使用拦截器，不如考虑使用 javax.servlet.过滤器。在 doFilter 方法中，可以将包装的请求传递到链下游。