异步处理

异步处理

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

使用AysncContext来进行异步操作

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

以tomcat为例，看一下异步是怎么处理的

@Override
public AsyncContext startAsync() {
    return startAsync(getRequest(),response.getResponse());
}

@Override
public AsyncContext startAsync(ServletRequest request,
        ServletResponse response) {
  // 先判断asyncSupported是否为ture
    if (!isAsyncSupported()) {
        IllegalStateException ise =
                new IllegalStateException(sm.getString("request.asyncNotSupported"));
        log.warn(sm.getString("coyoteRequest.noAsync",
                StringUtils.join(getNonAsyncClassNames())), ise);
        throw ise;
    }

    if (asyncContext == null) {
        asyncContext = new AsyncContextImpl(this);
    }

    asyncContext.setStarted(getContext(), request, response,
            request==getRequest() && response==getResponse().getResponse());
    asyncContext.setTimeout(getConnector().getAsyncTimeout());

    return asyncContext;
}