Servlet3 异步处理

简介

Servlet 3.0 之前， Servlet 的主要工作流程大致如下：

• 首先，Servlet 接收到请求之后，可能需要对请求携带的数据进行一些预处理；
• 接着，调用业务接口的某些方法，以完成业务处理；
• 最后，根据处理的结果提交响应，Servlet 线程结束。

其中第二步的业务处理通常是最耗时的，这主要体现在数据库操作，以及其它的跨网络调用等，在此过程中，Servlet 线程一直处于阻塞状态，直到业务方法执行完毕。在处理业务的过程中，Servlet 资源一直被占用而得不到释放，对于并发较大的应用，这有可能造成性能的瓶颈。对此，在以前通常是采用私有解决方案来提前结束 Servlet 线程，并及时释放资源。

使用 Servlet 3.0 的异步处理支持，之前的 Servlet 处理流程可以调整为如下的过程：

• 首先，Servlet 接收到请求之后，可能首先需要对请求携带的数据进行一些预处理；
• 接着，Servlet 线程将请求转交给一个异步线程来执行业务处理，线程本身返回至容器。此时 Servlet 还没有生成响应数据，异步线程处理完业务以后，可以直接生成响应数据（异步线程拥有 ServletRequest 和 ServletResponse 对象的引用），或者将请求继续转发给其它 Servlet。如此一来， Servlet 线程不再是一直处于阻塞状态以等待业务逻辑的处理，而是启动异步线程之后可以立即返回。

异步处理特性可以应用于 Servlet 和过滤器两种组件，由于异步处理的工作模式和普通工作模式在实现上有着本质的区别，因此默认情况下，Servlet 和过滤器并没有开启异步处理特性。 对于使用 Servlet 3.0 提供的 @WebServlet 和 @WebFilter 进行 Servlet 或Filter配置的情况，这两个注解都提供了 asyncSupported 属性，默认该属性的取值为 false，要启用异步处理支持，只需将该属性设置为 true 即可。以 @WebFilter 为例，其配置方式如下所示：

@WebFilter(urlPatterns = "/asyncFilterDemo",asyncSupported = true)

示例

@WebServlet(urlPatterns = "/as",asyncSupported = true)
public class AsyncServlet extends HttpServlet {
    @Override
    protected void doGet(HttpServletRequest req, HttpServletResponse resp) {
        System.out.println(Thread.currentThread()+"......");
        final AsyncContext asyncContext = req.startAsync();//返回异步类
        //开启异步操作，有一个新线程去处理
        asyncContext.start(() -> {
            ServletResponse response = asyncContext.getResponse();//异步的response
            try {
                Thread.sleep(3000);
                asyncContext.complete();//异步调用完成
                response.getWriter().write("success");
            } catch (Exception e) {
                e.printStackTrace();
            }
        });
        System.out.println(Thread.currentThread()+".......");
    }
}

部署项目运行并在浏览器中请求，发现控制台中先输出内容，一小段时间之后才会页面中才会有文字显示出来。