我正在使用异步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()
之间到底有什么区别? asyncContext.dispatch()
,然后再调用asyncContext.complete()
,则线程的行为是什么? asyncContext.complete()
之后调用任何方法,那么该方法调用将如何处理,如以下代码所示(在同一run()
中)? [当我对此进行测试时,它工作正常并显示相同的线程ID] run()
中调用异步方法,是否需要在callback()内完成asyncContext.complete()
? (onSuccess()或onFailure())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)。
问/答
dispatch
和complete
有什么区别?调用
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的好例子。原则上,我认为使用 future 没有太大值(value)。请参阅:“异步servlet是否适合我的工作?”
异步servlet非常适合我的工作吗?
异步servlet的目的是减少服务于某些类型的“推送客户端”所需的线程数:HTTP请求保持打开状态,直到发生(通常是外部)事件,然后服务器将数据向下推送到 channel 。在标准Servlet环境中,每个客户端将分配并等待一个专用线程,从而消耗了宝贵的系统资源。在异步模式下,可以将客户端连接置于“挂起”状态,并将其与执行线程分离,直到出现事件为止,该事件使它可以执行某些操作。以一个在线聊天应用程序为例。所有连接的客户端都将处于空闲状态,直到有人向该房间发布消息为止。为每个连接的用户保留专用线程是浪费的。
如果您的应用程序需要同时调用多个服务,并且您希望使用 future 和执行程序来并行化该操作,那么异步servlet可能不是一个合适的选择:您将一无所获,并且标准servlet将更易于实现。另一方面,如果可以以异步(非阻塞)方式进行服务调用,而不依赖于线程执行器,那么这就是另外一回事了。
要问的“正确”问题是:我要比 Activity 连接拥有更少的线程吗?
也可以看看:
AsyncStateMachine
javadoc中的状态图(Tomcat实现)。 关于java - 在处理请求时使用异步Servlet以及dispatch()和complete()方法的行为,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/22867311/