Servlet3.0的AsyncContext

Flchy 于 2016-10-25 发布

从 Servlet3.0 开始,Tomcat 的 Servlet 支持异步请求,或者说是 Tomcat 提供了异步 Servlet,从而可以将一些耗时的操作放到独立的线程中,在 操作完成后再返回数据,不阻塞请求的执行和返回

对于浏览器来说,他们是同步在等待输出的,但是对于服务器端来说,处理此请求的线程并没有卡在那里等待,则是把当前的处理转为线程池处理了

由此可以创建一个长链接,通过 Server-Sent Events 甚至可以实现推送的功能

使用

  1. 手动开启异步处理支持

    1.在web.xml配置
    <async-supported>true</async-supported>
    2.或者使用注解
    @WebServlet(asyncSupported = true)
    

    注意如果有过滤器,那么过滤器也要开启异步

  2. 使用 request 获取异步 Context 对象

    AsyncContext ctx = req.startAsync(req, resp);
    ctx.setTimeout(5000);
    new Thread(new Executor(ctx)).start();
    
  3. 在独立线程处理业务

    一般可以通过线程的构造方法把 Context 对象传递进来,调用 getRequest,和 getResponse 方法来获取请求对象,complete 来响应完成

    需要注意的是,异步 Servlet 有对应的超时时间,如果在指定的时间内没有执行完操作,response 依然会走原来 Servlet 的结束逻辑,后续的异步操作执行完再写回的时候,可能会遇到异常。

和线程的区别

对于一些比较耗时的操作,为了不阻塞输出会开一个线程,在线程里面处理耗时的操作

但是 AsyncContext 实际上不是让你异步,而是让你同步输出(所以浏览器一直是处于加载状态直到线程结束),但是解放服务器端的线程使用,使用 AsyncContext 的时候,对于浏览器来说,他们是同步在等待输出的,但是对于服务器端来说,处理此请求的线程并没有卡在那里等待,则是把当前的处理转为线程池处理了,关键就在于线程池,服务器端会起一个线程池去服务那些需要异步处理的请求,而如果你自己每次请求去起一个线程处理的话,这就有可能会耗大量的线程。

Demo

比如这个例子,在控制台的输入会同步到浏览器,所以把处理时间加长一点就可以模拟推送了

public class Service_1 extends HttpServlet{

	private static final long serialVersionUID = 1L;

	@Override
	protected void service(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {

		req.setCharacterEncoding("utf-8");
		resp.setCharacterEncoding("utf-8");
		resp.setContentType("text/html;charset=UTF-8");
		PrintWriter out = resp.getWriter();
		out.println("开始"+new Date().toString()+"<br>");
		out.flush();

		AsyncContext ctx = req.startAsync(req, resp);
		ctx.setTimeout(9999999);
		ctx.addListener(new AsyncListener() {

			@Override
			public void onTimeout(AsyncEvent arg0) throws IOException {
				// TODO Auto-generated method stub

			}

			@Override
			public void onStartAsync(AsyncEvent arg0) throws IOException {
				// TODO Auto-generated method stub

			}

			@Override
			public void onError(AsyncEvent arg0) throws IOException {
				// TODO Auto-generated method stub

			}

			@Override
			public void onComplete(AsyncEvent arg0) throws IOException {
				// TODO Auto-generated method stub
			}
		});
		new Thread(new Executor(ctx)).start();

		out.println("结束"+new Date().toString()+"<br>");
		out.flush();

	}


	public class Executor implements Runnable{

		private AsyncContext ctx = null;

		public Executor() {

		}

		public Executor(AsyncContext ctx) {

			this.ctx = ctx;
		}

		@Override
		public void run() {

			try {
				System.out.println("进入线程...");
				Scanner in = new Scanner(System.in);

				while(true){
					String  s = in.nextLine();
					if (s.equals("q")) {
						ctx.complete();
					}
					PrintWriter out = ctx.getResponse().getWriter();
					out.println("消息"+s+"<br>");
					out.flush();
				}

			} catch (IOException e) {
				e.printStackTrace();
			}
		}

	}

}

效果图

p1