模拟12306网上抢票的业务场景。春节等高峰时期，车票资源非常紧张，因此在约定时间放票，会存在大量抢票行为。服务器为了缓解并发高峰时的压力，抢票请求会用消息中间件进行排队处理。出票行为在服务器的独立线程中进行，这样主线程主要用于接收购票请求，异步线程用于出票，会大大缓解服务器的压力。
# 01、案例：12306抢票
操作步骤如下所述。
(1) 新建控制器支持异步模式。
js @WebServlet(asyncSupported = true,urlPatterns ="/AuctionSvl") public class AuctionSvl extends HttpServlet
(2) 控制器的service（）方法是一个高并发环境。
每个HTTP请求都使用独立的request对象。调用request.startAsync()，为每个HTTP请求创建一个异步回应的环境。
js public void service(HttpServletRequest request HttpServletResponse response)throws ServletException，IOException (System.out.println("servlet 主线程:”+ Thread.currentThread().getId()) //lineNum 为行号String linenum = request.getParameter("lineNum”); AsyncContext act = request.startAsync(); act.getRequest().setAttribute("linenum”linenum); AuctionListener.add(act);
(3) 所有异步回应在独立线程中统一处理。
AuctionListener实现了ServletContextListener监听器，因此在Tomcat启动时被加载。BlockingQueue为阻塞队列，装载所有与请求对应的AsyncContext对象。
js public class AuctionListener implements ServletContextListener( private static final BlockingOueue < AsyncContext > queue= new LinkedBlockingOueue < AsyncContext >(); private volatile Thread thread; public static void add(AsvncContext c)queue.add(c); contextInitialized(); //参见下面的代码实现
ServletContextListener的contextInitialized()方法代码如下，独立的后台线程从队列queue中顺序提取AsyncContext对象，然后分别调用每个AsyncContext的response对象，给不同的客户端回应数据。
js public void contextInitialized(ServletContextEvent servletContextEvent) (thread = new Thread(new Runnable() public void run(){ while (true) AsyncContext acontext = null; while ( queue.peek() != null) try{ acontext = (AsyncContext)queue.poll(); ServletResponse response = acontext.getResponse();response.setContentType("text/html;charset = utf - 8");PrintWriter out = response.getWriter();Thread.sleep(200);String name ="异步线程:” +Thread.currentThread().getId();long duration = System.currentTimeMillis(); //提取前面输入的行号，并输出 out.println(acontext.getRequest().getAttribute("linenum"） } "+ name +”"duration) out.close(); catch (Exception e) throw new RuntimeException(e.getMessage()，e);finally(if(acontext != null)acontext.complete(); thread.start(); } }
(4) 客户端模拟多用户并发抢票，循环发出20个异步请求。
js S.ajax( url:"AuctionSvl" type: "post" dataType:"html" data: data, timeout:50000 cache:false dataFilter:function (data,type) (return data; success:function(data,testStatus)var dataArray = Array();dataArray = data.split("")* 填充表格 *$("# tablel").append("< tr id='tr"+ i+ "class = 'mytr'></tr>") ;for(var j=0;j< dataArray.length; j++)[ $ ("#tr"+ i).append("< td>" + dataArray[j] + "</td>") error:function(msg) );
(5) 对比服务器异步回应和同步回应，异步抢票结果见图1。
在这个示例中，所有用户的并发购票请求，都会先存在一个阻塞队列中，然后由一个后台异步线程，顺序从阻塞队列中提取请求，当出票结束后再回应客户端。这样做的好处是服务器的压力很小，虽然用户的等待时间较长，但是这样保证了用户购票请求的正确处理。
■ 图1 12306抢票
