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

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

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

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

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

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

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

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

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

下面看一個簡單的例子：

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

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

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

以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

最新評論