Java 类org.springframework.web.util.ContentCachingRequestWrapper 实例源码

项目：amv-access-api-poc 文件：PayloadLoggingFilter.java

@Override
protected void doFilterInternal(HttpServletRequest request, HttpServletResponse response, FilterChain filterChain)
        throws ServletException, IOException {
    ContentCachingRequestWrapper requestWrapper = new ContentCachingRequestWrapper(request);
    ContentCachingResponseWrapper responseWrapper = new ContentCachingResponseWrapper(response);

    try {
        filterChain.doFilter(requestWrapper, responseWrapper);
    } finally {
        String requestBody = new String(requestWrapper.getContentAsByteArray());
        log.info("Request body: {}", requestBody);

        String responseBody = new String(responseWrapper.getContentAsByteArray());
        log.info("Response body: {}", responseBody);

        // Do not forget this line after reading response content or actual response will be empty!
        responseWrapper.copyBodyToResponse();
    }
}

项目：role-api 文件：BaseLoggingFilter.java

private String extractRequestPayload(HttpServletRequest request) {
    ContentCachingRequestWrapper wrapper = WebUtils.getNativeRequest(request, ContentCachingRequestWrapper.class);

    if (wrapper == null) {
        return UNKNOWN_PAYLOAD;
    }

    if (wrapper.getContentLength() > 0) {
        try {
            return request.getReader().lines().collect(Collectors.joining(StringUtils.LF));
        } catch (IOException e) {
            return UNKNOWN_PAYLOAD;
        }
    }
    return EMPTY_PAYLOAD;
}

项目：xm-commons 文件：TimelineEventProducer.java

private static String getRequestContent(HttpServletRequest request) {
    if (request instanceof ContentCachingRequestWrapper) {
        return new String(((ContentCachingRequestWrapper) request).getContentAsByteArray());
    }
    if (request instanceof HttpServletRequestWrapper
        && ((HttpServletRequestWrapper) request).getRequest() instanceof ContentCachingRequestWrapper) {
        return new String(((ContentCachingRequestWrapper) ((HttpServletRequestWrapper) request)
            .getRequest()).getContentAsByteArray());
    }
    log.warn("Empty request content because of unsupported request class {}", request.getClass());
    return "";
}

项目：xproject 文件：AbstractHttpAccessLoggingInterceptor.java

/**
 * 从HttpServletRequest中提取请求参数(包括请求体中的参数)
 * @param request
 * @param loggingContext
 * @return
 * @throws Exception
 */
protected HttpRequestParameter extractRequestParameter(HttpServletRequest request, LoggingContext loggingContext) throws Exception {
    HttpRequestParameter parameter = new HttpRequestParameter();
    Map<String,String[]> originalParamMap = request.getParameterMap();
    Map<String,String> paramMap = new HashMap<String,String>();
    if(originalParamMap != null && !originalParamMap.isEmpty()){
        for(Map.Entry<String, String[]> entry : originalParamMap.entrySet()){
            paramMap.put(entry.getKey(), getStringParameterValue(entry.getValue()));
        }
    }
    parameter.setParameter(paramMap);
    MediaType contentType = loggingContext.getHttpAccessLog().getRequestContentType();
    if(contentType != null){
        if(isContentCachingRequest(request)){
            String charset = request.getCharacterEncoding();
            if(StringUtils.isEmpty(charset)){
                charset = StringUtils.defaultIfEmpty(contentType.getCharset().name(), GlobalConstants.SYSTEM_DEFAULT_CHARSET);
            }
            ContentCachingRequestWrapper requestToUse = (ContentCachingRequestWrapper) request;
            byte[] bytes = requestToUse.getContentAsByteArray();
            if(bytes != null){
                String body = IOUtils.toString(bytes, charset);
                Object bodyObj = body;
                if(MediaType.APPLICATION_JSON.getType().equals(contentType.getType())){ //目前只处理JSON类型的数据
                    if(body.startsWith("[") && body.endsWith("]")){ //JSON Array String -> List<Map<String,Object>>
                        bodyObj = JsonUtils.json2Object(body, new TypeReference<List<Map<String,Object>>>(){});
                    }else if(body.startsWith("{") && body.endsWith("}")){ //JSON Object String -> Map<String,Object>
                        bodyObj = JsonUtils.json2Object(body, new TypeReference<Map<String,Object>>(){});
                    }
                }
                parameter.setBody(bodyObj);
            }

        }
    }
    return excludeRequestParameter(parameter, loggingContext);
}

项目：xproject 文件：AbstractHttpAccessLoggingInterceptor.java

protected boolean isContentCachingRequest(ServletRequest request) {
    if(request instanceof ContentCachingRequestWrapper){
        return true;
    }else if(request instanceof HttpServletRequestWrapper) {
        HttpServletRequestWrapper requestToUse = (HttpServletRequestWrapper) request;
        return isContentCachingRequest(requestToUse.getRequest());
    }
    return false;
}

项目：xm-ms-dashboard 文件：ContentCachingWrappingFilter.java

@Override
protected void doFilterInternal(HttpServletRequest request,
                                HttpServletResponse response,
                                FilterChain filterChain) throws ServletException, IOException {
    ContentCachingRequestWrapper requestWrapper = new ContentCachingRequestWrapper(request);
    ContentCachingResponseWrapper responseWrapper = new ContentCachingResponseWrapper(response);
    try {
        filterChain.doFilter(requestWrapper, responseWrapper);
    } finally {
        responseWrapper.copyBodyToResponse();
    }
}

项目：xm-ms-entity 文件：ContentCachingWrappingFilter.java

@Override
protected void doFilterInternal(HttpServletRequest request,
                                HttpServletResponse response,
                                FilterChain filterChain) throws ServletException, IOException {
    ContentCachingRequestWrapper requestWrapper = new ContentCachingRequestWrapper(request);
    ContentCachingResponseWrapper responseWrapper = new ContentCachingResponseWrapper(response);
    try {
        filterChain.doFilter(requestWrapper, responseWrapper);
    } finally {
        responseWrapper.copyBodyToResponse();
    }
}