Servlet3.0的AsyncContext-分享时光

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

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

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

使用

手动开启异步处理支持

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

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

使用 request 获取异步 Context 对象

AsyncContext ctx = req.startAsync(req, resp);
ctx.setTimeout(5000);
new Thread(new Executor(ctx)).start();

在独立线程处理业务

一般可以通过线程的构造方法把 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();
			}
		}

	}

}

Servlet3.0的AsyncContext

使用

和线程的区别

Demo

效果图