java - 在处理请求时使用异步Servlet以及dispatch()和complete()方法的行为

标签 java servlets asynchronous concurrency guava

我正在使用异步Servlet处理请求,

根据Docs :( complete()dispatch())

╔══════════════════╦═══════════════════════════════════════════════════════════╗
║ void complete()  ║ Completes the asynchronous operation and closes the       ║
║                  ║ response associated with this asynchronous context.       ║
║                  ║ You call this method after writing to the response object ║
║                  ║ inside the asynchronous context.                          ║ 
╠══════════════════╬═══════════════════════════════════════════════════════════╣
║ void dispatch()  ║ Dispatches the request and response objects               ║
║                  ║ of this AsyncContext to the servlet container.            ║
╚══════════════════╩═══════════════════════════════════════════════════════════╝

我无法理解async.dispatch()async.complete()以及它们如何工作。 我对此没有疑问:
  • async.dispatch()async.complete()之间到底有什么区别?
  • 我在run()内调用dispatch()()时,响应到达客户端,这意味着我们可以异步推送响应吗?
  • 如果我先调用asyncContext.dispatch(),然后再调用asyncContext.complete(),则线程的行为是什么?
  • 如果我在asyncContext.complete()之后调用任何方法,那么该方法调用将如何处理,如以下代码所示(在同一run()中)? [当我对此进行测试时,它工作正常并显示相同的线程ID]
  • 如果我在run()中调用异步方法,是否需要在callback()内完成asyncContext.complete()? (onSuccess()或onFailure())
  • 是否有与此相关的帮助(示例源/书籍/在线帮助)? (异步Servlet和 future 组合)
    final FutureCallback<Void> calculateTime= new CustomFuture<>(calculate);
     // start Async context.
     final AsyncContext asyncContext = request.startAsync();
    
      asyncContext.start(new Runnable() {
            @Override
            public void run() {
    
                MyObject object= null;
                try {   
                    object= myFactory.create();
                    //dispatch async context
                    asyncContext.dispatch("Object Successfully Created"); 
                } catch (final IOException e1) {
                    logger.error("logging error");      
                }
                asyncContext.complete(); //complete async context
    
                // call asynchronous method
                final ListenableFuture<Void> future = myService.doSomething();
    
                Futures.addCallback(future, calculateTime);
                // calling asyncContext.complete() here will work?
            }
        });
    

    提前致谢。
  • 最佳答案

    从马口中(Oracle Javadoc)
    完全的()
    完成在用于初始化此AsyncContext的请求上启动的异步操作,并关闭用于初始化此AsyncContext的响应。
    向其创建此AsyncContext的ServletRequest注册的所有AsyncListener类型的监听器都将在其onComplete方法中被调用。
    dispatch(字符串路径)
    将此AsyncContext的请求和响应对象分派(dispatch)到给定路径。
    ...
    对请求和响应的控制权委托(delegate)给分发目标,并且在完成分发目标后将关闭响应,除非调用了ServletRequest#startAsync()或ServletRequest#startAsync(ServletRequest,ServletResponse)。
    问/答

  • dispatchcomplete有什么区别?
    调用complete告诉容器触发onComplete监听器并停止异步模式,dispatch基本上告诉容器调用complete然后将请求(内部)转发到指定的路径。路径可以是JSP,同步Servlet或什至另一个异步Servlet,它们将触发新一轮的异步处理。
  • 当我在dispatch中调用run时,响应已到达客户端,这是否意味着我们可以像这样异步推送响应?
    相反,dispatch关闭异步模式,并将请求转发到另一个servlet或JSP。要将数据推送到客户端,您必须写入与Response关联的AsyncContext对象。
  • 如果我先调用dispatch,然后再调用complete,则线程的行为是什么?
    未定义,这是一个很好的说法,取决于容器的实现方式。可能会引发错误,也许onComplete处理程序将被触发两次,也许对complete的调用将无济于事,在调用处理程序和操作AsyncContext实现的内部结构等过程中,线程与容器之间将出现竞争状态。
  • 如果我在complete之后调用任何方法,该方法调用将如何处理
    取决于您要调用的方法。规范指出,如果在dispatch之后调用IllegalStateException,则会抛出complete,其他任何东西都是未定义的,因此是特定于实现的。
  • 如果我在run中调用异步方法,是否应该在callback()中调用complete
    是的,一旦完成,您必须调用complete来完成异步处理。 run方法用于安排由容器管理的线程池执行的任务,在异步请求的生存期内可以多次调用它。
  • 是否有使用异步Servlet和Futures Combination的示例?
    我什么都不知道,但是在“另请参阅”部分中有一些使用异步servlet的好例子。原则上,我认为使用 future 没有太大值(value)。请参阅:“异步servlet是否适合我的工作?”

  • 异步servlet非常适合我的工作吗?
    异步servlet的目的是减少服务于某些类型的“推送客户端”所需的线程数:HTTP请求保持打开状态,直到发生(通常是外部)事件,然后服务器将数据向下推送到 channel 。在标准Servlet环境中,每个客户端将分配并等待一个专用线程,从而消耗了宝贵的系统资源。在异步模式下,可以将客户端连接置于“挂起”状态,并将其与执行线程分离,直到出现事件为止,该事件使它可以执行某些操作。以一个在线聊天应用程序为例。所有连接的客户端都将处于空闲状态,直到有人向该房间发布消息为止。为每个连接的用户保留专用线程是浪费的。
    如果您的应用程序需要同时调用多个服务,并且您希望使用 future 和执行程序来并行化该操作,那么异步servlet可能不是一个合适的选择:您将一无所获,并且标准servlet将更易于实现。另一方面,如果可以以异步(非阻塞)方式进行服务调用,而不依赖于线程执行器,那么这就是另外一回事了。
    要问的“正确”问题是:我要比 Activity 连接拥有更少的线程吗?

    也可以看看:
  • AsyncStateMachine javadoc中的状态图(Tomcat实现)。
  • https://blogs.oracle.com/enterprisetechtips/entry/asynchronous_support_in_servlet_3
  • Servlet-3 Async Context, how to do asynchronous writes?
  • 关于java - 在处理请求时使用异步Servlet以及dispatch()和complete()方法的行为,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/22867311/

    相关文章:

    java |将项目添加到列表<?>

    java - 如何使用 MYSQL 在 JSwing 中创建并注册和登录表单

    java - 使用 jsp/servlet 清理 URL?

    javascript - Q - Javascript promise 等待数组被填充

    javascript - 如何将 async.waterfall 与现有回调一起使用

    java - JenaParser 代码中的错误

    java - Android VOICE_CALL,过时的音频源

    java - session 可以根据服务器负载定期回收吗?

    eclipse - Tomcat 没有在 Eclipse 中运行

    javascript - 等待一个循环结束 JavaScript