java - 使用 DeferredResult 时输入流关闭

标签 java spring servlets asynchronous deferred

我有一个旧的应用程序,客户端通过非常慢的连接(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");
    }
}

最佳答案

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

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

关于java - 使用 DeferredResult 时输入流关闭,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/32700617/

相关文章:

java - Spring 条件属性验证

java - Servlet请求处理

Spring Web 应用程序 : Post-DispatcherServlet initialization

java - 是否有将 Java POJO 转换为 JSON 和 XML 的库?

java - 运行tomcat时eclipse没有检测到错误但是找不到bean

java - Spring Boot 不会从 application.yml 中选取值

linux - 什么触发tomcat自动部署

java - 我需要帮助从目录中的所有文件读取数据

java - Spring 和 AOP : @After works but not @AfterReturning

hibernate - 在带有 jpa/hibernate 的 Spring 中,如何保持 session 打开以避免延迟初始化异常?