servlet3.0規範異步請求

servlet3.0規範中添加了異步處理，即一部分操作處理完成之後，先行把資料傳回來，對于另一部分比較耗時的操作可以放置到另外一個線程中進行處理，該線程保留有連接配接的請求和響應對象，在處理完成之後可以把處理的結果通知到用戶端，執行個體代碼如下：

import java.io.IOException;
import java.io.PrintWriter;
import java.util.Date;

import javax.servlet.AsyncContext;
import javax.servlet.AsyncEvent;
import javax.servlet.AsyncListener;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

/**   
 * @Title: AsynServlet.java 
 * @Package  
 * @Description: TODO
 * @author ynb  
 * @date 2014-7-24 下午5:07:00 
 * @version V1.0   
 */

/**
 * @author admin
 *
 */
@WebServlet(urlPatterns="/demo", asyncSupported=true)
public class AsynServlet extends HttpServlet {
	private static final long serialVersionUID = -8016328059808092454L;
	
	/* (non-Javadoc)
	 * @see javax.servlet.http.HttpServlet#service(javax.servlet.http.HttpServletRequest, javax.servlet.http.HttpServletResponse)
	 */
	@Override
	protected void service(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
		  	resp.setContentType("text/html;charset=UTF-8");
	        PrintWriter out = resp.getWriter();
	        out.println("進入Servlet的時間：" + new Date() + ".");
	        out.flush();

	        //在子線程中執行業務調用，并由其負責輸出響應，主線程退出
	        final AsyncContext ctx = req.startAsync();
	        ctx.setTimeout(200000);
	        new Work(ctx).start();
	        out.println("結束Servlet的時間：" + new Date() + ".");
	        out.flush();
	}
}

class Work extends Thread{
	private AsyncContext context;
	
	public Work(AsyncContext context){
		this.context = context;
	}
	@Override
	public void run() {
		try {
			Thread.sleep(2000);//讓線程休眠2s鐘模拟逾時操作
			PrintWriter wirter = context.getResponse().getWriter();			
			wirter.write("延遲輸出");
			wirter.flush();
			context.complete();
		} catch (InterruptedException e) {
			
		} catch (IOException e) {
			
		}
	}
}
           

有些時候，我們可能需要用戶端和伺服器保持長連接配接的時候，我們可以使用這個特性，讓伺服器長時間保持用戶端的請求以及對用戶端的響應，做法如下：

對于異步執行，我們可以添加一個監聽器，監聽異步執行的狀态。

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
					
				}
			});
           

在Servlet傳回之前，我們可以把持有request和response對象的AsyncContext對象放置到一個全局可通路的靜态容器中

map.put("id",ctx);
           

如果連接配接出錯或者連接配接完的時候我們可以在onError以及onComplete方法中移除掉對應連接配接的AsyncContext

map.remove("id",ctx);
           

在逾時的回調方法onTimeout中，我們可以往浏覽器發送指定的資訊，讓用戶端重新發起請求，這樣就可以保持用戶端和伺服器的長久連接配接。

如下伺服器和用戶端之間資料互動的模型圖