在afterRequest()方法中添加判断,如果消息内容不完整则等待一段时间再重新读取。示例如下:
@Override
protected void doFilterInternal(HttpServletRequest request, HttpServletResponse response, FilterChain filterChain) throws ServletException, IOException {
// 在请求前先记录日志
if (shouldLog(request)) {
beforeRequest(request);
}
try {
filterChain.doFilter(request, response);
} finally {
// 在响应后再记录日志
if (shouldLog(request)) {
int status = response.getStatus();
ContentCachingResponseWrapper responseWrapper = new ContentCachingResponseWrapper(response);
afterRequest(request, responseWrapper, status);
responseWrapper.copyBodyToResponse();
}
}
}
@Override
protected void afterRequest(HttpServletRequest request, ContentCachingResponseWrapper response, int status) {
// 获取完整的消息内容
String requestMessage = getContentAsString(request);
String responseMessage = getContentAsString(response);
// 如果消息内容不完整则等待一段时间
if (StringUtils.isEmpty(requestMessage) || StringUtils.isEmpty(responseMessage)) {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
requestMessage = getContentAsString(request);
responseMessage = getContentAsString(response);
}
// 记录请求日志
StringBuilder logMessage = new StringBuilder();
logMessage.append(request.getMethod()).append(" ");
logMessage.append(request.getRequestURI()).append(" ");
logMessage.append(status).append("\n");
logMessage.append("RequestMessage: ").append(requestMessage).append("\n");
logMessage.append("ResponseMessage: ").append(responseMessage).append("\n");
logger.info(logMessage.toString());
}
private String getContentAsString(HttpServletRequest request) {
ContentCachingRequestWrapper wrapper = WebUtils.getNativeRequest(request, ContentCachingRequestWrapper.class);
if (wrapper != null) {
byte[] content = wrapper.getContentAsByteArray();
if (content.length > 0) {
return new String(content, 0, content.length, wrapper.getCharacterEncoding());
}
}
return "";
}
private String getContentAsString(ContentC