使用HttpServletquiestWrapper复制后，所需的请求主体丢失

Question

在我的项目中，我有一组api调用，这些调用应该通过特定的公共验证集进行过滤。在这种情况下，我必须在请求到达REST控制器之前拦截请求，读取请求正文，进行验证，如果请求通过了验证，则将其传递给控制器。

由于HttpServletRequest不能多次反序列化，因此我使用HttpServletRequestWrapper来复制实际请求。使用它制作的副本，我进行验证。

以下是用于拦截请求的配置类。

public class InterceptorConfig extends WebMvcConfigurerAdapter {

     @Autowired     
     CustomInterceptor customInterceptor;

     @Override  
     public void addInterceptors(InterceptorRegistry registry) { 
        registry.addInterceptor(customInterceptor).addPathPatterns("/signup/**");

     }   
}

这是我在CustomInterceptor类中的preHandle方法，它扩展了HandlerInterceptorAdaptor

@Override
public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {

    ServletRequest copiedRequest = new HttpRequestWrapper(request);

    Map<String, Object> jsonMap = mapper.readValue(copiedRequest.getInputStream(), Map.class);

    if(jsonMap.containsKey("userId")){
        long userId = jsonMap.get("userId");
        MyClass myObject= myAutowiredService.getMyObject(userId);
        if(myObject == null){
            response.setStatus(HttpStatus.SC_NOT_ACCEPTABLE);
            return false;
        } 
        // some more validations which end up returning false if they are met
    }
    return true;
}

这是我的HttpRequestWrapper

public class HttpRequestWrapper extends HttpServletRequestWrapper {

    private byte[] requestBody;

    public HttpRequestWrapper(HttpServletRequest request) throws IOException{
        super(request);

        try {
            requestBody = IOUtils.toByteArray(request.getInputStream());
        } catch (IOException ex) {
            requestBody = new byte[0];
        }
    }

    @Override
    public ServletInputStream getInputStream() throws IOException {

        final ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(requestBody);

        return new ServletInputStream() {

            @Override
            public boolean isFinished() {
                return byteArrayInputStream.available() == 0;
            }

            @Override
            public boolean isReady() {
                return true;
            }

            @Override
            public void setReadListener(ReadListener listener) {
                throw new RuntimeException("Not implemented");
            }

            public int read () throws IOException {
                return byteArrayInputStream.read();
            }
        };
    }

}

一切都准备好了。现在，当我以/signup/**的模式向任何url发送请求时，所有验证都正常进行。然而，一旦请求命中控制器方法，就会弹出错误，表明请求主体不可用。

缺少所需的请求体：公共com.mypackage.my响应对象com.mypackage.myController.my控制器方法（com.mypackage.myDTO）

我正在努力寻找原因，以及克服这个问题的方法。我在课堂上做错了什么吗？还是有什么遗漏？

帮我解决这件事。

谢谢

Answer 1

问题似乎是您正在使用Interceptor读取HttpServletRequest的InputStream并将其包装在HttpResestWrapper中，但包装器永远不会返回。

我认为你应该使用过滤器

public class CustomFilter extends OncePerRequestFilter {
    public void doFilterInternal(HttpServletRequest request, HttpServletResponse response, FilterChain filterChain) throws ServletException, IOException {
        ServletRequest copiedRequest = new HttpRequestWrapper(request);

        Map<String, Object> jsonMap = mapper.readValue(copiedRequest.getInputStream(), Map.class);

        if(jsonMap.containsKey("userId")){
            long userId = jsonMap.get("userId");
            MyClass myObject= myAutowiredService.getMyObject(userId);
            if(myObject == null){
                response.setStatus(HttpStatus.SC_NOT_ACCEPTABLE);
                //return false;
            } 
            // some more validations which end up returning false if they are met
         }

         filterChain.doFilter(copiedRequest, (ServletResponse) response);
    }
}

你需要使用这个过滤器在任一web.xml或WebApplication ation初始工具