Web容器会为每一个请求分配一个线程,默认情况下,响应完成前,该线程占用的资源都不会释放。如果有些请求需要长时间处理(例如长时间运算,等待某个资源),就会长时间占用线程所需资源,对系统的性能造成负担
Servlet3.0新增了异步处理,可以先释放容器分配给请求的线程和相关资源,原先释放了容器所分配线程的请求,响应将会被延后
为了支持异步处理,ServletRequest中提供了startAsync()方法,方法的处理都是返回AsyncContext对象
public interface AsyncContext {
String ASYNC_REQUEST_URI = "javax.servlet.async.request_uri";
String ASYNC_CONTEXT_PATH = "javax.servlet.async.context_path";
String ASYNC_PATH_INFO = "javax.servlet.async.path_info";
String ASYNC_SERVLET_PATH = "javax.servlet.async.servlet_path";
String ASYNC_QUERY_STRING = "javax.servlet.async.query_string";
ServletRequest getRequest();
ServletResponse getResponse();
boolean hasOriginalRequestAndResponse();
void dispatch();
void dispatch(String var1);
void dispatch(ServletContext var1, String var2);
void complete();
void start(Runnable var1);
void addListener(AsyncListener var1);
void addListener(AsyncListener var1, ServletRequest var2, ServletResponse var3);
<T extends AsyncListener> T createListener(Class<T> var1) throws ServletException;
void setTimeout(long var1);
long getTimeout();
}
如果要调用ServletRequest的startAsync()以取得AsyncContext,必须告知容器当前Servlet支持异步处理,可以在@WebServlet注解中设置asyncSupported为ture
@WebServlet(name = "AsyncServlet",urlPatterns = "async",asyncSupported = true)
当然可以在web.xml中设置,如下:
<servlet>
<servlet-name>AsyncServlet</servlet-name>
<servlet-class>AsyncServlet</servlet-class>
<!-- 设置当前Servlet支持异步处理 -->
<async-supported>true</async-supported>
</servlet>
<servlet-mapping>
<servlet-name>AsyncServlet</servlet-name>
<url-pattern>/async</url-pattern>
</servlet-mapping>
如果当前支持异步处理的Servlet之前有过滤器,则过滤器也需要设置asyncSupported为true,同样可以在注解或web.xml中设置,否则会抛出如下错误:
A filter or servlet of the current chain does not support asynchronous operations.
@WebServlet(name = "AsyncServlet", urlPatterns = "/async", asyncSupported = true)
public class AsyncServlet extends HttpServlet {
protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
}
protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
// 1、开启异步处理,响应延后
AsyncContext async = request.startAsync();
// 2、做一些长时间运算或等待某个资源的操作
// 3、结束异步处理,开始对客户端响应
async.complete();
}
}
模拟服务器推送消息
Http是基于请求和响应规范,Http服务器无法直接对客户端传输消息,因为没有请求就没有响应;在这种请求、响应模型下,如果客户端想要获取服务器端的最新状态,必须以定期方式发送请求,查询服务器端的最新状态,但这种方式会浪费网络流量。
一种解决方案就是,服务器将每次请求都延后处理,直到服务器端数据发送变化之后在进行响应,当然这样的话客户端会一直处于等待响应状态,不过可以搭配Ajax发送异步请求,对请求在延后响应,就OK了。这就是所谓的服务器推送机制
在web容器中,我们可以监听所有的异步请求,然后统一做响应延后处理,实现服务器推送,代码如下:
/**
* 监听所有的异步请求,实现服务器推送的目的
*/
@WebListener()
public class AsyncsListener implements ServletContextListener {
// 所有的异步请求都放在该集合中
private List<AsyncContext> asyncs = new ArrayList<>();
@Override
public void contextInitialized(ServletContextEvent event) {
event.getServletContext().setAttribute("asyncs", asyncs);
new Thread(new Runnable() {
@Override
public void run() {
int num = (int) (Math.random() * 1000);
try {
Thread.sleep(num);
synchronized (asyncs) {
for (AsyncContext async : asyncs) {
async.getResponse().getWriter().print(num);
async.complete();
}
asyncs.clear();
}
} catch (InterruptedException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
}).start();
}
@Override
public void contextDestroyed(ServletContextEvent servletContextEvent) {
}
}
更多的AsyncContext细节
1. 如果没有声明 asyncSupported为true, 调用startAsync()将会抛出IllegalStateException
2. 当在支持异步处理的Servlet中调用startAsync()方法时,该次请求会离开容器所分配的线程