java - 使用 DeferredResult 时输入流关闭

Question

我有一个旧的应用程序，客户端通过非常慢的连接(GPRS)上传大文件。目前我们使用Spring MVC和旧的servlet 2.0标准并直接获取请求inputStream，这显然会导致长时间运行的线程阻塞。我的任务是将应用程序升级到 servlet 3.1，以利用新的异步读取监听器(这被认为是直接的!!)，但是我已经陷入了死胡同。

将应用程序直接升级到 servlet 3.1 进展顺利，忽略了我立即返回响应的事实，因为我更关心测试文件本身是否正确上传以及 onDataAvailable() 是否被正确调用了多次这一事实。当我使用 DeferredResult 对象(看起来它或多或少是为此目的而发明的)将 View 名称返回到 Controller 时，就会出现问题，因为我需要明显地让客户端知道上传是否成功，并且在这个异步环境中我看不到其他方法可以做到这一点。

当我返回 DeferredResult 对象时，它被错误地直接返回给客户端，并且在第一次 onDataAvailable() 调用时，无法读取 inputStream，因为我收到 java.io.IOException: Stream closeed 异常。这里对 getDispatcherType() 的调用告诉我，类型现在已切换为 DispatcherType.ERROR，而当我在没有 DeferredResult 对象的情况下运行代码时(并且无论如何都会立即响应)，类型仍然是 DispatcherType.REQUEST。我原以为堆栈中的某个地方 inputStream 被提前读取(不是由我)并导致了这种情况，但似乎并非如此，奇怪的是 inputStream.isReady() 返回 true ，而 inputStream.isFinished() 返回 false ，我可以在第一个 onDataAvailable() 上看到缓冲区中文件的文本，但我无法直接从 inputStream 读取而不会出现 java.io.IOException: Stream close 异常。

无论对小文件还是大文件进行多少测试都不会改变这种行为。有人在 Spring MVC 和 servlet 3.1 中成功使用 DeferredResult 吗？我已经被难住了几天了，调试的代码比我想做的还要多!

这是我的代码(如果您认为它看起来有点贫血，则剪掉一些业务内容)

@Controller
public class ContentController {
    @RequestMapping(value = “/upload/“, method = POST)
    public DeferredResult<String> upload(ServletRequest request) throws IOException, InterruptedException {
       DeferredResult<String> deferredResult = new DeferredResult<String>();
       final AsyncContext asyncContext = httpServletRequest.startAsync();
       ServletInputStream servletInputStream =  httpServletRequest.getInputStream();
       NioReadListener readListener =  new NioReadListener(servletInputStream, asyncContext, deferredResult, size);
       servletInputStream.setReadListener(readListener);
       return deferredResult
}

public class NioReadListener implements ReadListener {
    private final ServletInputStream _input;
    private final AsyncContext _context;
    private final DeferredResult<String> deferredResult;

    public NioReadListener(ServletInputStream servletInputStream, AsyncContext asyncContext, DeferredResult<String> deferredResult, Long size) throws IOException {
        this._input = servletInputStream;
        this._context = asyncContext;
        this.deferredResult = deferredResult;
    }

    @Override
    public void onDataAvailable() throws IOException {
        try {
            int bytesRead;
            byte b[] = new byte[_size.intValue()];
            while (_input.isReady() && (bytesRead = _input.read(b)) != -1) {
                _totalBytesRead += bytesRead;
            }
        } catch (IOException e) {
            _log.error(e);
        }

    }

    @Override
    public void onAllDataRead() throws IOException {
        this._context.complete();
        deferredResult.setResult("VIEW_NAME");
    }
}

Answer 1

(这是我原来问题的答案，但不是整个应用程序问题的答案)。经过几个小时的调试和绞尽脑汁，我找到了 deferredResult 未正确设置的原因。我们为一些 REST 实用程序包含了一个第三方库，该库使应用程序使用 Spring 中已弃用的 AnnotationMethodHandlerAdapter，而不是它应该使用的 RequestMappingHandlerAdapter。一旦我覆盖了这个外部 bean，deferredResult 就会被正确处理。

唯一的事情是这个调用流程的异步性质仍然不起作用，这又回到了我最初的子问题之一，即是否有人让 Spring MVC/DeferredResults 和 Servlet 3.1 一起工作。我看到一些 stackoverflow 问题提出了同样的问题，但遗憾的是没有答案。