性色视频在线观看,eeuss影院一区二区三区,国产精品免费小视频

Servlet 3.0筆記之Servlet的異步特性支持失效怎么辦？

滿心歡喜的為Servlet 添加上異步支持注解（asyncSupported = true），不曾想，其異步特性完全不起作用，仔細檢測項目，發現存在一個編碼攔截器（Filter），雖使用注解，但未標明支持異步，導致被攔截的標注為異步支持的Servlet，異步特性皆失效。怎么辦，在Filter中注解里面添加asyncSupported = true。問題解決。

但轉念一想，因歷史原因，遺留系統會存在很多的Servlet 2.*規范的Filter，無法支持異步，怎么辦？全部手動修改為注解版本，可能不太現實。還好，Doug Lea的JUC并發包，為我們提供了一種實現思路。

實際步驟:

準備一個線程池
把當前請求相關屬性包裝進一個任務線程中
獲取當前任務線程執行結果（不一定會有返回值）
阻塞，執行完畢或超時，或被中斷異常，可以輸出客戶端
整個請求結束

實際上，提交到一個線程池的任務線程，默認會返回一個Future對象，利用Future對象的get方法阻塞的特性，當前請求需要等待任務線程執行的結束，若指定時間內任務線程順利完成，則不必等到設定的時間的邊界即可自然往下執行。

實際代碼：

	package com.servlet3.demo;

	import java.io.IOException;
	import java.io.PrintWriter;
	import java.util.concurrent.ExecutionException;
	import java.util.concurrent.ExecutorService;
	import java.util.concurrent.Executors;
	import java.util.concurrent.Future;
	import java.util.concurrent.ThreadFactory;
	import java.util.concurrent.ThreadPoolExecutor;
	import java.util.concurrent.TimeUnit;
	import java.util.concurrent.TimeoutException;

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

	/**
	* Servlet中添加异步支持
	*
	* @author yongboy
	* @time 2012-1-17
	* @version 1.0
	*/
	@WebServlet(urlPatterns = "/async3")
	public class DemoAsync3Action extends HttpServlet {
	private static final long serialVersionUID = 1L;
	private final ExecutorService executor;

	{
	executor = Executors.newCachedThreadPool(new ThreadFactory() {
	public Thread newThread(Runnable r) {
	Thread thread = new Thread(r);
	thread.setName("DemoAsyncAction3 executor Thread "
	+ thread.getId());
	thread.setPriority(Thread.MAX_PRIORITY);

	return thread;
	}
	});

	if (executor instanceof ThreadPoolExecutor) {
	// 不超过服务器CPU数目个线程较佳
	((ThreadPoolExecutor) executor).setMaximumPoolSize(Runtime
	.getRuntime().availableProcessors());
	}
	}

	protected void doGet(HttpServletRequest request,
	HttpServletResponse response) throws ServletException, IOException {
	// 添加此属性，告诉浏览器，需要分段显示
	response.setHeader("Connection", "Keep-Alive");
	response.setContentType("text/html;charset=UTF-8");
	final PrintWriter out = response.getWriter();

	output(out, "the manual async start ...");

	Future<?> future = executor.submit(new Runnable() {
	@Override
	public void run() {
	try {
	// 假设实际业务耗时10秒
	Thread.sleep(10000L);
	} catch (InterruptedException e) {
	e.printStackTrace();
	}

	try {
	output(out, "the manual async goes here ...");
	} catch (IOException e) {
	e.printStackTrace();
	}
	}
	});

	boolean result = false;
	try {
	// 在此处，会阻塞当前线程，直到超时或线程执行完毕...
	future.get(10L, TimeUnit.SECONDS);
	result = true;
	} catch (InterruptedException e) {
	e.printStackTrace();
	} catch (ExecutionException e) {
	e.printStackTrace();
	} catch (TimeoutException e) {
	e.printStackTrace();
	} finally {
	future.cancel(true);
	}

	if (result) {
	output(out, "the manual async is ok ...");
	} else {
	output(out, "the manual async is failure ...");
	}

	// 按照顺序输出到此，结束请求
	output(out, "the end of manual async ...");
	out.close();
	}

	private static void output(PrintWriter out, String message)
	throws IOException {
	out.println(message);
	out.flush();
	}
	}

view raw DemoAsync3Action.java hosted with ❤ by GitHub

需要備注說明的是，若Future.get()無參數，則意味著需要等待計算完成，然后獲取其結果。這樣可不用設定等待時間了。更多信息，請參考JDK。

測試代碼下載

posted on 2012-01-18 10:32 nieyong 閱讀(685) 評論(0) 編輯收藏所屬分類: Servlet3 、Java

新用戶注冊刷新評論列表


只有注冊用戶登錄后才能發表評論。




網站導航: 博客園 IT新聞 Chat2DB C++博客博問管理
相關文章: Servlet 3.0筆記之文件下載的那點事情 Servlet 3.0筆記之Servlet的異步特性支持失效怎么辦？ Servlet 3.0筆記之Redis操作示范Retwis JAVA版 Servlet 3.0筆記之Servlet單實例以及線程安全小結 Servlet 3.0筆記之異步請求重新梳理Comet的幾種形式 Servlet 3.0筆記之異步請求Facebook BigPipe簡單模型實現 Servlet 3.0筆記之異步請求Comet推送長輪詢(long polling)篇補遺 Servlet 3.0筆記之異步請求Comet推送長輪詢(long polling)篇 Servlet 3.0筆記之Tomcat(7.0.6)穩定版發布 Servlet 3.0筆記之會話Cookie設置相關

聶永的博客

Servlet 3.0筆記之Servlet的異步特性支持失效怎么辦？

公告

導航

統計

常用鏈接

留言簿(58)

隨筆分類(130)

隨筆檔案(151)

個人收藏

最新隨筆

搜索

最新評論

閱讀排行榜

評論排行榜