詳解Tomcat如何實現Comet

2024-09-01 13:49:39

字體：大中小

來源：轉載

供稿：網友

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

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

tomcat,comet,Tomcat實現Comet

一般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模式。

tomcat,comet,Tomcat實現Comet