Servlet3.0的新特性之异步请求 - 黑马程序员技术交流社区

Servlet是运行在服务器端的一段java程序，它的主要作用是接收客户端的请求，并针对这次请求做出响应。那么在一个请求过来时，Servlet的service方法就会执行，我们都知道，这个service方法的执行，是依赖于Servlet容器中的线程池中的子线程的，换句话讲，就是如果Servlet容器的线程池中没有可利用的线程池，那么这次请求要么被直接拒绝，要么处于等待状态中，这两种结果都不是用户喜欢看到的。

[Java] 纯文本查看 复制代码

@WebServlet("/SyncServlet")

public class SyncServlet extends HttpServlet {

        private static final long serialVersionUID = 1L;

       

        protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {

                try {

                        Thread.sleep(10000);

                } catch (InterruptedException e) {

                        e.printStackTrace();

                }

        }

        protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {

                doGet(request, response);

        }

}

上面的代码非常简单，我们模拟了一个耗时10秒的请求处理，也就是说，在这10秒之内，如果有10个请求过来，那么10个请求都能被处理，如果再来10个，那么这10个就会处于等待状态，直到有请求被处理完后，对应的执行doGet方法的线程才能回到Servlet容器的线程池中，等待的请求才能被处理。假如有第21个请求在这10秒之内同时发出，那么将有一个请求会被拒绝，相信这个道理大家都能明白，因为能处理请求的线程数是有限的，那么我们是不是可以增大Servlet容器线程池大小呢？当然可以，如果该服务器上所有请求都是非常耗时的，我们可以通过配置增大Servlet容器线程池大小，但是实际开发中，并不是所有请求都非常耗时，而是某个或者某几个请求非常耗时，比如文件上传或者下载，那么这种情况下，通过配置增大Servlet容器线程池大小，就有点得不偿失了。所以我们针对这种情况，会以新开工作线程的方式来提高服务器对请求的吞吐。此时Servlet3.0的异步Servlet就派上用场了。

[Java] 纯文本查看 复制代码

@WebServlet(urlPatterns="/SyncServlet",asyncSupported=true)

public class SyncServlet extends HttpServlet {

        private static final long serialVersionUID = 1L;

       

        protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {

                AsyncContext startAsync = request.startAsync();

                new MyThread(startAsync).start();

        }



        protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {

                doGet(request, response);

        }

        

        class MyThread extends Thread{

                private AsyncContext context;

                

                public MyThread(AsyncContext context) {

                        this.context = context;

                }



                @Override

                public void run() {

                        //通过AsyncContext可以获取request对象，对请求数据做处理

                        HttpServletRequest request = (HttpServletRequest) context.getRequest();

                        //通过AsyncContext可以获取response对象，对响应做处理

                        HttpServletResponse response = (HttpServletResponse) context.getResponse();

                        try {

                                Thread.sleep(10000);

                        } catch (InterruptedException e) {

                                e.printStackTrace();

                        }

                        

                        //处理完成后，一定就记得调用该方法通知Servlet容器，异步处理完成

                        context.complete();

                }

        }

}

在上述案例的代码中，我们在doGet方法中，调用了newMyThread(startAsync).start()新开一个线程，那么这个线程不依赖于Servlet容器线程池中的线程，doGet方法执行完这行代码后，doGet方法也就执行完了，那么处理doGet的线程就可以回到Servlet容器线程池中，继续处理其他请求，这样即使有耗时的任务，也不会阻塞Servlet容器线程池中的线程，从而提高服务器响应请求的吞吐。