快捷導(dǎo)航

詳解Tomcat如何實(shí)現(xiàn)Comet

更新時(shí)間：2016年12月16日 10:26:31 作者：seaboat 汪洋之舟

Comet模式是一種服務(wù)器端推技術(shù)，它的核心思想提供一種能讓當(dāng)服務(wù)器端往客戶端發(fā)送數(shù)據(jù)的方式。本篇文章主要介紹了Tomcat如何實(shí)現(xiàn)Comet，有興趣的可以了解一下。

Comet模式是一種服務(wù)器端推技術(shù)，它的核心思想提供一種能讓當(dāng)服務(wù)器端往客戶端發(fā)送數(shù)據(jù)的方式。Comet模式為什么會(huì)出現(xiàn)？剛開始人們?cè)诳蛻舳送ㄟ^不斷自動(dòng)刷新整個(gè)頁面來更新數(shù)據(jù)，后來覺得體驗(yàn)不好又使用了AJAX不斷從客戶端輪詢服務(wù)器更新數(shù)據(jù)，然后是使用Comet模式由服務(wù)器端通過長連接推數(shù)據(jù)。Comet模式能大大減少發(fā)送到服務(wù)器端的請(qǐng)求從而避免了很多開銷，而且它還具備更好的實(shí)時(shí)性。

如圖所示，客戶端發(fā)送一個(gè)請(qǐng)求到服務(wù)器，服務(wù)器接收了連接后一直保持住連接不關(guān)閉；接著客戶端發(fā)送一個(gè)操作報(bào)文告訴服務(wù)器需要做什么操作，服務(wù)器處理完事件1后會(huì)給客戶端響應(yīng)，然后處理完事件2后又會(huì)給客戶端響應(yīng)；然后客戶端繼續(xù)發(fā)送操作報(bào)文給服務(wù)器，服務(wù)器再進(jìn)行響應(yīng)。

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

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

而CometEvent則表示Comet相關(guān)的事件，它包含四BEGIN, READ, END, ERROR四個(gè)事件，分別表示：

①　BEGIN，表示請(qǐng)求開始，此時(shí)客戶端連接已被接收。

②　READ，表示可以讀取客戶端連接，你可以開始讀取數(shù)據(jù)了，讀取的過程不會(huì)阻塞。

③　END，表示請(qǐng)求結(jié)束，此時(shí)客戶端連接將被斷開。

④　ERROR，表示發(fā)生了IO異常，一般將會(huì)結(jié)束此次請(qǐng)求并且連接會(huì)被斷開。

下面看一個(gè)簡單的例子：

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

這個(gè)例子中只是簡單的客戶端連接都接收起來而不做任何處理，并將客戶端發(fā)送過來的數(shù)據(jù)輸出。很容易理解，在BEGIN事件中接收連接并把響應(yīng)對(duì)象假如到列表中，發(fā)送ERROR或END事件時(shí)則將響應(yīng)對(duì)象移除，當(dāng)READ事件時(shí)則讀取數(shù)據(jù)并輸出。

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