java - AsyncContext.complete()后继续处理

Question

首先我想说英语不是我的母语，所以如果我犯了一些明显的错误或者有些地方不够清晰，请原谅。问题:

最近我被转移到一个新项目，我们正在开发一个 Java EE 应用程序，该应用程序通过 Jersey+Hibernate 提供一些 REST 服务。在此之前，我只有 Java SE 的经验，但有人已经奠定了基础，所以我有时间学习他的代码并经常使用 Google 和 SO。

问题是，在这些 REST 服务中，有一个可能需要很长时间才能完成，团队决定以非阻塞方式实现它。我们将定义两个服务:第一个服务是客户端发送数据进行处理，然后我们返回一个确认并开始处理，而客户端可以继续处理其他事情；第二个允许客户稍后检查他们的工作是否完成。

在研究如何以最佳方式实现这一点时，我前面提到的同事发现了 AsyncServlet Servlet 3.0 的功能，并在我到达之前实现了概念验证，后来他演变成该服务的本地工作(但非常脏)版本。他说他必须为此放弃 Jersey，因为 Servlet 3.0 与我们使用的 Jersey 版本不兼容，最后决定实现一个普通的 servlet。

最后，他得到了这样的东西(我现在没有代码，因为我在家并凭内存编写，但我会尝试尽可能清晰地编写它并尝试修复任何问题)明天早上会犯大错误):

处理doPost()中的新请求的servlet以及登记doGet() :

@WebServlet(asyncSupported = true)

//...

void doGet(HttpServletRequest req, HttpServletResponse res) {

    /* 
     * ...    
     * We query the previous "job request" here in the DB
     * ...
     */

}

void doPost(HttpServletRequest req, HttpServletResponse res) {

    /* 
     * ...
     * We convert the JSON request to an entity and then start the asynchronous 
     * "worker" thread
     * ...
     */

    AsyncContext ctx = req.startAsync(req, res);
    ctx.start(new WorkerThread(ctx, someOtherDataFromRequest);
}

还有一个实现 Runnable 的工作线程它做的第一件事就是调用 ctx.complete()关于AsyncContext这是在构造函数中发送给他的。我同事的推理是，如果工作人员立即通知父级他已完成，则父级可以将响应提交回客户端，然后使用构造函数中传递给他的其他数据开始自己的处理:

public class WorkerThread implements Runnable {

    public WorkerThread(AsyncContext ctx, SomeOtherData data){

        //...

    }

    public void run() {
        ctx.complete();

        // ... Now start doing the heavy processing with data

    }
}

嗯，正如我所说，这在他的本地测试服务器(Tomcat 7)上有效，但几天前，我被要求清理他的代码，当在我的装有 JBoss EAP 6.1 的机器上运行时，我发现它不起作用无法按预期工作，因为父 servlet 直到工作进程死亡才提交响应(我们有不同的服务器，因为生产机器是新的，上级还没有决定安装哪个服务器，并且改变了主意时代，官僚主义......)

我做了很多尝试，我很确定在清理时我没有删除异步处理的任何关键元素，因为我的版本编译并运行良好。最后我得到了一个测试用例，其中工作人员只 hibernate 10 秒，然后写入日志；在 Tomcat 中，响应几乎立即到达客户端，然后在 10 秒后写入日志；而在 JBoss 中，客户端必须等待整整 10 秒才能收到响应。

然后，我开始调查 AsyncServlet功能，我认为他的想法是错误的，这个功能似乎是针对异步内部处理而不是我们想要使用它，但我不明白为什么它在他的 Tomcat 上工作。来自complete()的javadoc我理解 JBoss 行为的方法是正确的:

If this method is called before the container-initiated dispatch that called startAsync has returned to the container, then the call will not take effect (and any invocations of AsyncListener#onComplete(AsyncEvent) will be delayed) until after the container-initiated dispatch has returned to the container.

所以，我的问题是 AsyncServlet 是否功能是针对我们的用例的，如果没有，是否有其他更干净的方法来获得我们想要的行为(如果它们与 Jersey 兼容，则加分)。我正在考虑只生成一个线程而不使用异步上下文，但听起来相当危险......

感谢并抱歉文字墙

Answer 1

这个回复可能有点太晚了，但是您是否考虑过使用 Jersey 2.0 附带的 AsyncResource

https://jersey.java.net/documentation/latest/async.html

此外，您还说过“父 servlet 在工作线程死亡之前不会提交响应”。你是如何证明这一点的？也许您的 Tomcat 服务器和 Jboss 服务器有不同的设置(不同的线程池大小/不同的连接数？)

此外，从您的描述来看，您在 SomeOtherData 中似乎拥有所需的一切。因此，您可以使用 ExecutorService，在其上添加一个可运行的对象，该对象仅在其构造函数中接受 SomeOtherData，并立即在 doPost 本身的上下文中调用完成，而不是在工作线程中执行。