国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 網站 > 建站經驗 > 正文

詳解Tomcat如何實現Comet

2019-11-02 16:41:21
字體:
來源:轉載
供稿:網友

Comet模式是一種服務器端推技術,它的核心思想提供一種能讓當服務器端往客戶端發送數據的方式。Comet模式為什么會出現?剛開始人們在客戶端通過不斷自動刷新整個頁面來更新數據,后來覺得體驗不好又使用了AJAX不斷從客戶端輪詢服務器更新數據,然后是使用Comet模式由服務器端通過長連接推數據。Comet模式能大大減少發送到服務器端的請求從而避免了很多開銷,而且它還具備更好的實時性。

如圖所示,客戶端發送一個請求到服務器,服務器接收了連接后一直保持住連接不關閉;接著客戶端發送一個操作報文告訴服務器需要做什么操作,服務器處理完事件1后會給客戶端響應,然后處理完事件2后又會給客戶端響應;然后客戶端繼續發送操作報文給服務器,服務器再進行響應。

一般Comet模式需要NIO配合,而在BIO中無法使用Comet模式。在Tomcat內部集成Comet模式的思路也比較清晰,引入了一個CometProcessor接口,此接口只有一個event方法,具體接口代碼如下:

public interface CometProcessor extends Servlet{  public void event(CometEvent event)    throws IOException, ServletException;}

而CometEvent則表示Comet相關的事件,它包含四BEGIN, READ, END, ERROR四個事件,分別表示:

① BEGIN,表示請求開始,此時客戶端連接已被接收。

② READ,表示可以讀取客戶端連接,你可以開始讀取數據了,讀取的過程不會阻塞。

③ END,表示請求結束,此時客戶端連接將被斷開。

④ ERROR,表示發生了IO異常,一般將會結束此次請求并且連接會被斷開。

下面看一個簡單的例子:

public class CometServlet extends HttpServlet implements CometProcessor {  protected ArrayList connections = new ArrayList();  public void event(CometEvent event) throws IOException, ServletException {    HttpServletRequest request = event.getHttpServletRequest();    HttpServletResponse response = event.getHttpServletResponse();    if (event.getEventType() == CometEvent.EventType.BEGIN) {      synchronized (connections) {        connections.add(response);      }    } else if (event.getEventType() == CometEvent.EventType.ERROR) {      synchronized (connections) {        connections.remove(response);      }    }else if (event.getEventType() == CometEvent.EventType.END) {      synchronized (connections) {        connections.remove(response);      }    } else if (event.getEventType() == CometEvent.EventType.READ) {      InputStream is = request.getInputStream();      byte[] buf = new byte[512];      do {        int n = is.read(buf);        if (n > 0) {          System.out.println(new String(buf, 0, n));        } else if (n < 0) {          return;        }      } while (is.available() > 0);    }  }}

這個例子中只是簡單的客戶端連接都接收起來而不做任何處理,并將客戶端發送過來的數據輸出。很容易理解,在BEGIN事件中接收連接并把響應對象假如到列表中,發送ERROR或END事件時則將響應對象移除,當READ事件時則讀取數據并輸出。

有了CometProcessor接口后,Tomcat內部就可以識別Comet模式的Servlet了,我們知道Tomcat對請求的處理是管道模式的,所以在Wrapper容器的管道中判斷加載的Servlet是否繼承了CometProcessor,繼承則說明是Comet模式,則使用Comet方式處理。它的處理過程如圖,當一個客戶端連接到來,被接收器接收后注冊到NioChannel隊列中,Poller組件不斷輪詢是否有NioChannel需要處理,如果有則調用前面實例化的Comet模式Servlet,這里主要用到CometProcessor接口的event方法,Poller會將對應的請求對象、響應對象和事件封裝成都CometEvent對象并傳入event方法。此時即執行event方法的邏輯,完成對不同事件的處理,從而實現了Comet模式。

發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 济宁市| 安龙县| 女性| 威宁| 忻州市| 屏边| 松江区| 东阿县| 夏津县| 高邑县| 扎鲁特旗| 张家界市| 且末县| 绍兴市| 五大连池市| 丰宁| 方山县| 乳源| 大石桥市| 乐山市| 青浦区| 英德市| 临武县| 彰化县| 烟台市| 那坡县| 安西县| 友谊县| 诏安县| 平度市| 郸城县| 浏阳市| 鱼台县| 龙海市| 钟山县| 阿勒泰市| 大埔县| 阜城县| 禹城市| 敦煌市| 石台县|