从 spring 异常处理程序读取 httprequest 内容

我已经尝试了您的代码，并且我发现异常处理程序中存在一些错误，当您从中读取：InputStream

Writer writer = new StringWriter();
byte[] buffer = new byte[1024];

//Reader reader2 = new BufferedReader(new InputStreamReader(request.getInputStream()));
InputStream reader = request.getInputStream();
int n;
while ((n = reader.read(buffer)) != -1) {
    writer.toString();

}
String retval = writer.toString();
retval = "";

我用这个替换了你的代码：

BufferedReader reader = new BufferedReader(new   InputStreamReader(request.getInputStream()));
String line = "";
StringBuilder stringBuilder = new StringBuilder();
while ( (line=reader.readLine()) != null ) {
    stringBuilder.append(line).append("\n");
}

String retval = stringBuilder.toString();

然后我能够在异常处理程序中读取，它的工作原理！如果您仍然无法从 中读取，我建议您检查如何将 xml 数据发布到请求正文。您应该考虑每个请求只能使用一次，因此我建议您检查是否有任何其他调用 。如果您必须调用它两次或更多次，则应编写这样的自定义来制作请求正文的副本，以便您可以读取更多次。InputStreamInputStreamInputstreamgetInputStream()HttpServletRequestWrapper

更新
您的评论帮助我重现了问题。您使用注释@RequestBody，因此您确实不调用 ，但Spring调用它来检索请求的正文。看看类：如果你使用这个类调用方法，依此类推...最后，您无法再从您的.如果您仍然想在自己的方法中同时使用这两种功能，则必须将请求包装到自定义中以制作请求正文的副本，以便您可以手动读取更多次。这是我的包装器：getInputStream()org.springframework.web.bind.annotation.support.HandlerMethodInvoker@RequestBodyresolveRequestBodyInputStreamServletRequest@RequestBodygetInputStream()HttpServletRequestWrapper

public class CustomHttpServletRequestWrapper extends HttpServletRequestWrapper {

    private static final Logger logger = Logger.getLogger(CustomHttpServletRequestWrapper.class);
    private final String body;

    public CustomHttpServletRequestWrapper(HttpServletRequest request) {
        super(request);

        StringBuilder stringBuilder = new StringBuilder();
        BufferedReader bufferedReader = null;

        try {
            InputStream inputStream = request.getInputStream();
            if (inputStream != null) {
                bufferedReader = new BufferedReader(new InputStreamReader(inputStream));
                String line = "";
                while ((line = bufferedReader.readLine()) != null) {
                    stringBuilder.append(line).append("\n");
                }
            } else {
                stringBuilder.append("");
            }
        } catch (IOException ex) {
            logger.error("Error reading the request body...");
        } finally {
            if (bufferedReader != null) {
                try {
                    bufferedReader.close();
                } catch (IOException ex) {
                    logger.error("Error closing bufferedReader...");
                }
            }
        }

        body = stringBuilder.toString();
    }

    @Override
    public ServletInputStream getInputStream() throws IOException {
        final StringReader reader = new StringReader(body);
        ServletInputStream inputStream = new ServletInputStream() {
            public int read() throws IOException {
                return reader.read();
            }
        };
        return inputStream;
    }
}

然后，您应该编写一个简单的来包装请求：Filter

public class MyFilter implements Filter {

    public void init(FilterConfig fc) throws ServletException {

    }

    public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException {
        chain.doFilter(new CustomHttpServletRequestWrapper((HttpServletRequest)request), response);

    }

    public void destroy() {

    }

}

最后，您必须在 Web 中配置筛选器.xml：

<filter>     
    <filter-name>MyFilter</filter-name>   
    <filter-class>test.MyFilter</filter-class>  
</filter> 
<filter-mapping>   
    <filter-name>MyFilter</filter-name>   
    <url-pattern>/*</url-pattern>   
</filter-mapping>

您只能为真正需要过滤器的控制器触发过滤器，因此您应该根据需要更改 url 模式。

如果仅在一个控制器中需要此功能，则还可以在通过注释接收请求正文时在该控制器中创建请求正文的副本。@RequestBody

最近我遇到了这个问题，并以不同的方式解决了这个问题。与弹簧靴 1.3.5.发布

该筛选器是使用 Spring 类 ContentCachingRequestWrapper 实现的。这个包装器有一个可以多次调用的方法getContentAsByteArray（）。

import org.springframework.web.util.ContentCachingRequestWrapper;
public class RequestBodyCachingFilter implements Filter {

    public void init(FilterConfig fc) throws ServletException {
    }

    public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException {
        chain.doFilter(new ContentCachingRequestWrapper((HttpServletRequest)request), response);
    }

    public void destroy() {
    }
}

已将筛选器添加到链中

@Bean
public RequestBodyCachingFilter requestBodyCachingFilter() {
    log.debug("Registering Request Body Caching filter");
    return new RequestBodyCachingFilter();
}

在异常处理程序中。

@ControllerAdvice(annotations = RestController.class)
public class GlobalExceptionHandlingControllerAdvice {
    private ContentCachingRequestWrapper getUnderlyingCachingRequest(ServletRequest request) {
        if (ContentCachingRequestWrapper.class.isAssignableFrom(request.getClass())) {
            return (ContentCachingRequestWrapper) request;
        }
        if (request instanceof ServletRequestWrapper) {
            return getUnderlyingCachingRequest(((ServletRequestWrapper)request).getRequest());
        }
        return null;
    }

    @ResponseStatus(value = HttpStatus.INTERNAL_SERVER_ERROR)
    @ExceptionHandler(Throwable.class)
    public @ResponseBody Map<String, String> conflict(Throwable exception, HttpServletRequest request) {
        ContentCachingRequestWrapper underlyingCachingRequest = getUnderlyingCachingRequest(request);
        String body = new String(underlyingCachingRequest.getContentAsByteArray(),Charsets.UTF_8);
        ....
    }
}