0%

异步处理

异步处理

在Servlet3.0版本中引入了异步处理的功能,使线程可以返回到容器,从而执行更多的任务

使用AysncContext来进行异步操作

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
public interface ServletRequest {

// 使用原始请求和响应对象用于异步处理
public AsyncContext startAsync() throws IllegalStateException;

// 将请求转换为异步模式,并使用给定的请求和响应对象初始化,可以使用ServletRequestWrapper和ServletResponseWrapper
public AsyncContext startAsync(ServletRequest servletRequest,
ServletResponse servletResponse)
throws IllegalStateException;

// 检测请求是否为异步模式,使用原始请求和响应对象进行处理
public boolean isAsyncStarted();

// 是否支持异步处理
public boolean isAsyncSupported();

// 返回由startAsync调用创建的AsyncContext
public AsyncContext getAsyncContext();

}



public interface AsyncContext {
// AsyncContext中的请求响应进行分派
void dispatch();

// 分派到指定资源
void dispatch(String path);

// 分派到指定资源
void dispatch(ServletContext context, String path);
// 完成异步操作,并结束与这个异步上下文的关联的响应,在异步上下文中写入响应对象之后调用该方法
void complete();
// 容器提供了一个不同的线程,在该线程中处理阻塞操作
void start(Runnable run);
// 注册监听器用于接收 onTimeout、onError(用于通知监听器在Servlet上启动的异步操作未能完成)、onComplete(用于通知监听器在Servlet上启动的异步操作完成了)、onStartAsync(用于通知监听器正在通过调用一个ServletRequest.startAsync方法启动一个新的异步周期)通知
void addListener(AsyncListener listener);

void addListener(AsyncListener listener, ServletRequest request,
ServletResponse response);
}

要在servlet上启用异步处理,需要配置asyncSupported为true