發(fā)表于 2011-12-21 08:44
易用性是 Jetty 設(shè)計(jì)的基本原則，易用性主要體現(xiàn)在以下幾個(gè)方面：
- 通過(guò) XML 或者 API 來(lái)對(duì) Jetty 進(jìn)行配置；
- 默認(rèn)配置可以滿足大部分的需求；
- 將 Jetty 嵌入到應(yīng)用程序當(dāng)中只需要非常少的代碼；
在使用了 Ajax 的 Web 2.0 的應(yīng)用程序中，每個(gè)連接需要保持更長(zhǎng)的時(shí)間，這樣線程和內(nèi)存的消耗量會(huì)急劇的增加。這就使得我們擔(dān)心整個(gè)程序會(huì)因?yàn)閱蝹�(gè)組件陷入瓶頸而影響整個(gè)程序的性能。但是有了 Jetty：
- 即使在有大量服務(wù)請(qǐng)求的情況下，系統(tǒng)的性能也能保持在一個(gè)可以接受的狀態(tài)。
- 利用 Continuation 機(jī)制來(lái)處理大量的用戶請(qǐng)求以及時(shí)間比較長(zhǎng)的連接。
另外 Jetty 設(shè)計(jì)了非常良好的接口，因此在 Jetty 的某種實(shí)現(xiàn)無(wú)法滿足用戶的需要時(shí)，用戶可以非常方便地對(duì) Jetty 的某些實(shí)現(xiàn)進(jìn)行修改，使得 Jetty 適用于特殊的應(yīng)用程序的需求。
Jetty 設(shè)計(jì)之初就是作為一個(gè)優(yōu)秀的組件來(lái)設(shè)計(jì)的，這也就意味著 Jetty 可以非常容易的嵌入到應(yīng)用程序當(dāng)中而不需要程序?yàn)榱耸褂?Jetty 做修改。從某種程度上，你也可以把 Jetty 理解為一個(gè)嵌入式的Web服務(wù)器。
將自己的應(yīng)用程序部署到 Jetty 上面是非常簡(jiǎn)單的，首先將開發(fā)好的應(yīng)用程序打成 WAR 包放到 Jetty 的 Webapps 目錄下面。然后用如下的命令來(lái)啟動(dòng) Jetty 服務(wù)器：Java –jar start.jar， 在啟動(dòng)服務(wù)器后。我們就可以訪問(wèn)我們的應(yīng)用程序了，Jetty 的默認(rèn)端口是 8080，WAR 的名字也就是我們的應(yīng)用程序的 Root Context。例如一個(gè)典型的 URL 就是：http://127.0.0.1:8080/sample/index.jsp 。
將 Jetty 嵌入到程序當(dāng)中是非常簡(jiǎn)單的， 如 代碼 1 所示：首先我們創(chuàng)建一個(gè) Server 對(duì)象， 并設(shè)置端口為 8080，然后為這個(gè) Server 對(duì)象添加一個(gè)默認(rèn)的 Handler。接著我們用配置文件 jetty.xml 對(duì)這個(gè) server 進(jìn)行設(shè)置，最后我們使用方法 server.start()將 Server 啟動(dòng)起來(lái)就可以了。從這段代碼可以看出，Jetty 是非常適合用于作為一個(gè)組件來(lái)嵌入到我們的應(yīng)用程序當(dāng)中的，這也是 Jetty 的一個(gè)非常重要的特點(diǎn)。
清單 1. 代碼片斷
| public class JettyServer { public static void main(String[] args) { Server server = new Server(8080); server.setHandler(new DefaultHandler()); XmlConfiguration configuration = null; try { configuration = new XmlConfiguration( new FileInputStream("C:/development/Jetty/jetty-6.1.6rc0/etc/jetty.xml")); } catch (FileNotFoundException e1) { e1.printStackTrace(); } catch (SAXException e1) { e1.printStackTrace(); } catch (IOException e1) { e1.printStackTrace(); } try { configuration.configure(server); server.start(); } catch (Exception e) { e.printStackTrace(); } } } |
接下來(lái)我們分析一下 Jetty Server 是如何啟動(dòng)的。首先我們注意到 Server 類，這個(gè)類實(shí)際上繼承了 HttpServer, 當(dāng)啟動(dòng) Jetty 服務(wù)器的時(shí)候，就是說(shuō)，在 Jetty 根目錄下的命令行下如果輸入 java -jar start.jar etc/jetty.xml，注意這里有一個(gè)配置文件 jetty.xml 做為運(yùn)行參數(shù)，這個(gè)參數(shù)也可以是其它的配置文件，可以是多個(gè) XML 配置文件，其實(shí)這個(gè)配置文件好比我們使用 Struts 時(shí)的 struts-config.xml 文件，將運(yùn)行 Server 需要用到的組件寫在里面，比如上一節(jié)中 HttpServer 的配置需要的組件類都可以寫在這個(gè)配置文件中。按上述方法啟動(dòng) Jetty Server 時(shí)，就會(huì)調(diào)用 Server 類里面的 main 方法，這個(gè)入口方法首先會(huì)構(gòu)造一個(gè) Server 類實(shí)例（其實(shí)也就構(gòu)造了一個(gè) HttpServer），創(chuàng)建實(shí)例的過(guò)程中就會(huì)構(gòu)造 XmlConfiguration 類的對(duì)象來(lái)讀取參數(shù)配置文件，之后再由這個(gè)配置文件產(chǎn)生的 XmlConfiguration 對(duì)象來(lái)配置這個(gè) Server，配置過(guò)程其實(shí)是運(yùn)用了 Java 的反射機(jī)制，調(diào)用 Server 的方法并傳入配置文件中所寫的參數(shù)來(lái)向這個(gè) Server 添加 HttpListener，HttpContext，HttpHandler，以及 Web Application（對(duì)應(yīng)于我們的 Web 應(yīng)用）。
討論 Jetty 的 Continuation 機(jī)制，首先需要提到 Ajax 技術(shù)，Ajax 技術(shù)是當(dāng)前開發(fā) Web 應(yīng)用的非常熱門的技術(shù)，也是 Web 2.0 的一個(gè)重要的組成部分。Ajax 技術(shù)中的一個(gè)核心對(duì)象是 XMLHttpRequest 對(duì)象，這個(gè)對(duì)象支持異步請(qǐng)求，所謂異步請(qǐng)求即是指當(dāng)客戶端發(fā)送一個(gè)請(qǐng)求到服務(wù)器的時(shí)候，客戶端不必一直等待服務(wù)器的響應(yīng)。這樣就不會(huì)造成整個(gè)頁(yè)面的刷新，給用戶帶來(lái)更好的體驗(yàn)。而當(dāng)服務(wù)器端響應(yīng)返回時(shí)，客戶端利用一個(gè) Javascript 函數(shù)對(duì)返回值進(jìn)行處理，以更新頁(yè)面上的部分元素的值。但很多時(shí)候這種異步事件只是在很小一部分的情況下才會(huì)發(fā)生，那么怎么保證一旦服務(wù)器端有了響應(yīng)之后客戶端馬上就知道呢，我們有兩種方法來(lái)解決這個(gè)問(wèn)題，一是讓瀏覽器每隔幾秒請(qǐng)求服務(wù)器來(lái)獲得更改，我們稱之為輪詢。二是服務(wù)器維持與瀏覽器的長(zhǎng)時(shí)間的連接來(lái)傳遞數(shù)據(jù)，長(zhǎng)連接的技術(shù)稱之為 Comet。
大家很容易就能發(fā)現(xiàn)輪詢方式的主要缺點(diǎn)是產(chǎn)生了大量的傳輸浪費(fèi)。因?yàn)榭赡艽蟛糠窒蚍⻊?wù)器的請(qǐng)求是無(wú)效的，也就是說(shuō)客戶端等待發(fā)生的事件沒(méi)有發(fā)生，如果有大量的客戶端的話，那么這種網(wǎng)絡(luò)傳輸?shù)睦速M(fèi)是非常厲害的。特別是對(duì)于服務(wù)器端很久才更新的應(yīng)用程序來(lái)講，比如郵件程序，這種浪費(fèi)就更是巨大了。并且對(duì) Server 端處理請(qǐng)求的能力也相應(yīng)提高了要求。如果很長(zhǎng)時(shí)間才向 Server 端發(fā)送一次請(qǐng)求的話，那么客戶端就不能的得到及時(shí)的響應(yīng)。
如果使用 Comet 技術(shù)的話，客戶端和服務(wù)器端必須保持一個(gè)長(zhǎng)連接，一般情況下，服務(wù)器端每一個(gè) Servlet 都會(huì)獨(dú)占一個(gè)線程，這樣就會(huì)使得服務(wù)器端有很多線程同時(shí)存在，這在客戶端非常多的情況下也會(huì)對(duì)服務(wù)器端的處理能力帶來(lái)很大的挑戰(zhàn)。
Jetty 利用 Java 語(yǔ)言的非堵塞 I/O 技術(shù)來(lái)處理并發(fā)的大量連接。 Jetty 有一個(gè)處理長(zhǎng)連接的機(jī)制：一個(gè)被稱為 Continuations 的特性。利用 Continuation 機(jī)制，Jetty 可以使得一個(gè)線程能夠用來(lái)同時(shí)處理多個(gè)從客戶端發(fā)送過(guò)來(lái)的異步請(qǐng)求，下面我們通過(guò)一個(gè)簡(jiǎn)化的聊天程序的服務(wù)器端的代碼來(lái)演示不使用 Continuation 機(jī)制和使用 Continuation 的差別。
清單 2. Continuation 機(jī)制
| public class ChatContinuation extends HttpServlet{ public void doPost(HttpServletRequest request, HttpServletResponse response){ postMessage(request, response); } private void postMessage(HttpServletRequest request, HttpServletResponse response) { HttpSession session = request.getSession(true); People people = (People)session.getAttribute(session.getId()); if (!people.hasEvent()) { Continuation continuation = ContinuationSupport.getContinuation(request, this); people.setContinuation(continuation); continuation.suspend(1000); } people.setContinuation(null); people.sendEvent(response); } } |
大家注意到，首先獲取一個(gè) Continuation 對(duì)象，然后把它掛起 1 秒鐘，直到超時(shí)或者中間被 resume 函數(shù)喚醒位置，這里需要解釋的是，在調(diào)用完 suspend 函數(shù)之后，這個(gè)線程就可處理其他的請(qǐng)求了，這也就大大提高了程序的并發(fā)性，使得長(zhǎng)連接能夠獲得非常好的擴(kuò)展性。
如果我們不使用 Continuation 機(jī)制，那么程序就如 清單 3 所示：
清單 3. 不使用 Continuation 機(jī)制
| public class Chat extends HttpServlet{ public void doPost(HttpServletRequest request, HttpServletResponse response){ postMessage(request, response); } private void postMessage(HttpServletRequest request, HttpServletResponse response) { HttpSession session = request.getSession(true); People people = (People)session.getAttribute(session.getId()); while (!people.hasEvent()) { try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } } people.setContinuation(null); people.sendEvent(response); } } |
大家注意到在等待事件發(fā)生的時(shí)間里，線程被掛起，直到所等待的事件發(fā)生為止，但在等待過(guò)程中，這個(gè)線程不能處理其他請(qǐng)求，這也就造成了在客戶端非常多的情況下服務(wù)器的處理能力跟不上的情況。下面我們解釋一下 Jetty 的 Continuation 的機(jī)制是如何工作的。
為了使用 Continuatins，Jetty 必須配置為使用它的 SelectChannelConnector 處理請(qǐng)求。這個(gè) connector 構(gòu)建在 java.nio API 之上，允許它維持每個(gè)連接開放而不用消耗一個(gè)線程。當(dāng)使用 SelectChannelConnector時(shí)，ContinuationSupport.getContinuation() 提供一個(gè) SelectChannelConnector.RetryContinuation 實(shí)例（但是，您必須針對(duì) Continuation 接口編程）。當(dāng)在 RetryContinuation 上調(diào)用 suspend() 時(shí)，它拋出一個(gè)特殊的運(yùn)行時(shí)異常 --RetryRequest，該異常傳播到 servlet 外并且回溯到 filter 鏈，最后被 SelectChannelConnector 捕獲。但是不會(huì)發(fā)送一個(gè)異常響應(yīng)給客戶端，而是將請(qǐng)求維持在未決 Continuations 隊(duì)列里，則 HTTP 連接保持開放。這樣，用來(lái)服務(wù)請(qǐng)求的線程返回給 ThreadPool，然后又可以用來(lái)服務(wù)其他請(qǐng)求。暫停的請(qǐng)求停留在未決 Continuations 隊(duì)列里直到指定的過(guò)期時(shí)間，或者在它的 Continuation 上調(diào)用 resume() 方法。當(dāng)任何一個(gè)條件觸發(fā)時(shí)，請(qǐng)求會(huì)重新提交給 servlet（通過(guò) filter 鏈）。這樣，整個(gè)請(qǐng)求被"重播"直到 RetryRequest 異常不再拋出，然后繼續(xù)按正常情況執(zhí)行。
為了防止任何人都有權(quán)限去關(guān)閉一個(gè)已經(jīng)開啟的 Jetty 服務(wù)器， 我們可以通過(guò)在啟動(dòng) Jetty 服務(wù)器的時(shí)候指定參數(shù)來(lái)進(jìn)行控制，使得用戶必須提供密碼才能關(guān)閉 Jetty 服務(wù)器，啟動(dòng) Jetty 服務(wù)器的命令如下所示：
| java -DSTOP.PORT=8079 -DSTOP.KEY=mypassword -jar start.jar |
這樣，用戶在停止 Jetty 服務(wù)器的時(shí)候，就必須提供密碼“mypassword”。
Jetty 是一個(gè)非常方便使用的 Web 服務(wù)器，它的特點(diǎn)在于非常小，很容易嵌入到我們的應(yīng)用程序當(dāng)中，而且針對(duì) Web 2.0 的 Ajax 技術(shù)進(jìn)行了特別的優(yōu)化，這也使得我們的使用 Ajax 的應(yīng)用程序可以擁有更好的性能。
學(xué)習(xí)
- developerWorks 文章“ 面向 Java 開發(fā)人員的 Ajax: 使用 Jetty 和 Direct Web Remoting 編寫可擴(kuò)展的 Comet 應(yīng)用程序”：受異步服務(wù)器端事件驅(qū)動(dòng)的 Ajax 應(yīng)用程序?qū)崿F(xiàn)較為困難，本文介紹了一種結(jié)合使用 Comet 模式和 Jetty 6 Continuations API 的解決方法。
- developerWorks 文章“ Comet：基于 HTTP 長(zhǎng)連接的“服務(wù)器推”技術(shù) ”：介紹、比較了常用的“服務(wù)器推”方案。
- “Comet: Low Latency Data for the Browser”：Alex Russell 是 Dojo Toolkit 的項(xiàng)目主管和 Dojo Foundation 的主席，他在這篇博客文章中提出了 Comet 這個(gè)術(shù)語(yǔ)。
- Comet wiki：提供了很多開源 Comet 框架的鏈接。
- Jetty：Jetty 是一種開源的基于標(biāo)準(zhǔn)的 Web 服務(wù)器，完全使用 Java 語(yǔ)言實(shí)現(xiàn)。
- “Ajax, Comet and Jetty”（Greg Wilkins，Webtide，2006 年 1 月）：Wilkins 的這份白皮書討論了擴(kuò)展 Ajax 連接的 Jetty 架構(gòu)方法。
- Continuations：了解更多關(guān)于 Jetty 的 Continuations 特性的信息。
- “pushlet”：開源 comet 框架，使用了觀察者模型。瀏覽器端提供了基于 AJAX 和 iframe 的 JavaScript 庫(kù)，服務(wù)器端使用 Java Servlet。
- developerWorks Ajax 技術(shù)資源中心：能找到更多關(guān)于 Ajax 技術(shù)的文章和教程。
- developerWorks Web 開發(fā)技術(shù)專區(qū)：提供了關(guān)于 Web 開發(fā)和架構(gòu)方面的大量文章。
- developerWorks Java 技術(shù)專區(qū)：提供了關(guān)于 Java 編程各個(gè)方面的數(shù)百篇文章。
- 瀏覽 技術(shù)書店，查閱有關(guān)本文所述主題以及其他技術(shù)主題的書籍。
獲得產(chǎn)品和技術(shù)
- Jetty：下載 Jetty。
討論
周登朋，上海交通大學(xué)研究生，目前在IBM上海國(guó)際化實(shí)驗(yàn)室（SGL）實(shí)習(xí)。對(duì)Java技術(shù)，數(shù)據(jù)挖掘，信息檢索技術(shù)非常感興趣，并已在IBM Developerworks上發(fā)表過(guò)多篇文章，你可以通過(guò)zhoudengpeng@yahoo.com.cn來(lái)聯(lián)系他。