|
场景：在aop的日志中想获取 post请求的json数据时报错，因为在后台 控制器的接口中流已经读取了，导致日志这里获取就会报错，需要重写请求的 getInputStream? getReader，然后配置一个过滤器
1、requestWrapper
public class StreamWrapper extends HttpServletRequestWrapper{
public String _body;
public StreamWrapper(HttpServletRequest request) throws IOException {
super(request);
StringBuffer sBuffer = new StringBuffer();
BufferedReader bufferedReader = request.getReader();
String line;
while ((line = bufferedReader.readLine()) != null) {
sBuffer.append(line);
}
_body = sBuffer.toString();
}
@Override
public ServletInputStream getInputStream() {
final ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(_body.getBytes());
return new ServletInputStream() {
@Override
public int read() {
return byteArrayInputStream.read();
}
@Override
public boolean isFinished() {
return false;
}
@Override
public boolean isReady() {
return false;
}
@Override
public void setReadListener(ReadListener listener) {
}
};
}
@Override
public BufferedReader getReader() {
return new BufferedReader(new InputStreamReader(this.getInputStream()));
}
}
2、定义一个过滤器
public class StreamFilter implements Filter {
private final Set<String> ALLOWED_PATHS = Collections.unmodifiableSet(new HashSet<>(
Arrays.asList("/api/file/upload")));
@Override
public void init(FilterConfig filterConfig) throws ServletException {
}
@Override
public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException {
ServletRequest requestWrapper = null;
if(request instanceof HttpServletRequest) {
HttpServletRequest servletRequest = (HttpServletRequest) request;
String requestURI = servletRequest.getRequestURI();
if (ALLOWED_PATHS.contains(requestURI)){
chain.doFilter(servletRequest,response);
}else {
requestWrapper = new StreamWrapper(servletRequest);
//获取请求中的流如何，将取出来的字符串，再次转换成流，然后把它放入到新request对象中。
// 在chain.doFiler方法中传递新的request对象
chain.doFilter(requestWrapper, response);
}
}
}
@Override
public void destroy() {
}
}
3、springboot配置过滤器
@Configuration
public class StreamConfig {
@Value("${stream.enabled}")
private String enabled;
@Value("${stream.excludes}")
private String excludes;
@Value("${stream.urlPatterns}")
private String urlPatterns;
@Bean
public FilterRegistrationBean StreamRegistration() {
FilterRegistrationBean streamBean = new FilterRegistrationBean();
streamBean.setDispatcherTypes(DispatcherType.REQUEST);
streamBean.setFilter(new StreamFilter());
streamBean.addUrlPatterns(urlPatterns);
streamBean.setName("StreamFilter");
streamBean.setOrder(Integer.MAX_VALUE);
Map<String, String> initParameters = new HashMap<>(16);
initParameters.put("excludes", excludes);
initParameters.put("enabled", enabled);
streamBean.setInitParameters(initParameters);
return streamBean;
}
}
4、yml文件
stream:
# 过滤开关
enabled: true
# 排除链接（多个用逗号分隔）
excludes: /api/file/*,/api/file/upload
# 匹配链接
urlPatterns: /api/*
|