详解Tomcat如何实现Comet

2024-04-26 08:53: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模式。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持我们。

基于JQuery框架的AJAX实例代码

index.html 复制代码代码如下: <html> <head> <title>jQuery Ajax 实例演示</title> </head> <script src="./js/jquery.js" type="text/javascript"></script> <script type="text/javascript"> $(docum
JavaScript数据推送Comet技术详解

JavaScript数据推送主要致力于webapp的在线推送服务,不用我们每次都像服务器去发送Ajax请求而主动从Server端推送数据到本地. 数据推送进化史: 1. HTTP协议简易轮询,保持着一个链接不放,或者通过前端不停的向后端发送请求 2. H5更新后有了WebSocket大大改善了双向和单向推送数据的便利性 3. SSE(Server-Send Event):服务器推送数据的新方式 Comet:基于 HTTP 长连接的服务器推送技术本课时介绍Comet:基于 HTTP 长连接的服务
Ajax和Comet技术总结

Ajax是一种技术,一种能够向服务器请求额外的数据而无需卸载页面的技术,能够使网页具备更优的用户体验.Ajax技术的核心是XMLHttpRequest对象(XHR).本文从XHR开始谈起,理解Ajax技术的特点,再对跨域以及Comet等技术进行简要理解和总结. XMLHttpRequest基本用法 XHR对象有两个常用的方法open和send.open方法用户启动一个HTTP请求,不过它不会真的发送HTTP请求.open方法接收3个参数,分别表示请求的HTTP方法.请求的URL.是否异步.XHR
完美解决AJAX跨域问题

从AJAX诞生那天起,XMLHttprequest对象不能跨域请求的问题就一直存在.这似乎是一个很经典的问题了.是由于javascript的同源策略(这里不作深入探讨)所导致. 解决的办法,大概有如下几种: 1. 使用中间层过渡的方式(可以理解为"代理"): 中间过渡,很明显,就是在AJAX与不同域的服务器进行通讯的中间加一层过渡,这一层过渡可以是PHP.JSP.c++等任何具备网络通讯功能的语言,由中间层向不同域的服务器进行读取数据的操作.拿asp.net做一个例子,如果需要对不同域
jQuery Ajax全解析

什么是Ajax Ajax基本概念 Ajax(Asynchronous JavaScript and XML):翻译成中文就是异步的JavaScript和XML. 从功能上来看是一种在无需重新加载整个网页的情况下能够更新部分网页的技术. 传统的网页想要更新内容或者提交表单就要重新加载或刷新页面. 使用ajax技术的网页通过后台服务器进行少量的数据交换,网页就可以实现异步局部跟新. Ajax出现前 Ajax技术出现之前,是一个同步交互的世界. 同步:客户端发出请求,服务端去处理,然后响应,这一段
页面间隔半秒钟更新时间 Asp.net使用Comet开发http长连接示例分享

好处:1.和AJAX轮询比起来节省资源,并且延迟小, 2.和webSocket比起来,适用的场景比较广泛. 1.先建立一个Asp.net MVC的空项目添加一个控制器 (同样的代码在Asp.net WebForm中也是可以使用的) 复制代码代码如下: public class CometController : Controller { public ActionResult Test() { Response.Buffer = f
jquery ajax例子返回值详解

在JQuery中,AJAX有三种实现方式:$.ajax() , $.post , $.get(). 首先我们看$.get(): 复制代码代码如下: $.get("test.jsp", { name: "cssrain", time: "2008/01/21" }, //要传递的数据 function(data){ alert("返回的数据: " + data); } ) 然后看$.post(): 跟$.get()格式一样.
jquery实现ajax提交form表单的方法总结

方法一: 复制代码代码如下: function AddHandlingFeeToRefund() { var AjaxURL= "../OrderManagement/AjaxModifyOrderService.aspx"; alert($('#formAddHandlingFee').serialize()); $.ajax({ type: "P
使用Java实现类似Comet风格的web app

开始在本文中,我将展示如何使用各种不同的 Java 技术构建一些简单的 Comet 风格的 Web 应用程序.读者对 Java Servlet.Ajax 和 JavaScript 应该有一定的了解.我们将考察 Tomcat 和 Jetty 中一些支持 Comet 的特性,因此需要使用这两个产品的最新版本.本文使用 Tomcat 6.0.14 和 Jetty 6.1.14.另外还需要一个支持 Java 5 或更高版本的 JDK.本文使用 JDK 1.5.0-16.此外还需要看看 Jett
详解Tomcat如何实现Comet

Comet模式是一种服务器端推技术,它的核心思想提供一种能让当服务器端往客户端发送数据的方式.Comet模式为什么会出现?刚开始人们在客户端通过不断自动刷新整个页面来更新数据,后来觉得体验不好又使用了AJAX不断从客户端轮询服务器更新数据,然后是使用Comet模式由服务器端通过长连接推数据.Comet模式能大大减少发送到服务器端的请求从而避免了很多开销,而且它还具备更好的实时性. 如图所示,客户端发送一个请求到服务器,服务器接收了连接后一直保持住连接不关闭:接着客户端发送一个操作报文告诉服务器需
详解tomcat热部署和热加载的方法

详解tomcat热部署和热加载的方法我在项目开发过程中,经常要改动Java/JSP 文件,但是又不想从新启动服务器(服务器从新启动花时间),想直接获得(debug)结果.有两种方式热部署和热加载: 1.热加载:在server.xml -> context 属性中设置 reloadable="true" <Context docBase="xxx" path="/xxx" reloadable="true"/&
详解Tomcat出现404的解决方法

Tomcat测试出现404问题出现的问题如下: HTTP状态 404 - 未找到类型状态报告消息请求的资源[/chapter06/IndexServlet]不可用描述源服务器未能找到目标资源的表示或者是不愿公开一个已经存在的资源表示. Apache Tomcat/9.0.37 问题原因,浏览器不能直接访问Java文件问题的解决方法 1.提交表单时遇到此问题 <form name = "reg" action="/login" method=&qu
详解tomcat各个端口的作用

从tomcat配置文件中,我们可以看出,在启动tomcat的时候默认启动了3个端口,分别是8080(8443).8009.8005. 8080(8443)端口 <Connector port="80" protocol="HTTP/1.1" connectionTimeout="20000" redirectPort="8443" /> 这个应该是我们最熟悉的一个,平常开发测试也经常用,该Connector用于监听
详解Tomcat双击startup.bat闪退的解决方法

作为一个刚学习Tomcat的程序猿来说,这是会经常出现的错误. 1.环境变量问题 1.1 首先需要确认java环境是否配置正确,jdk是否安装正确 win+R打开cmd,输入java 或者 javac 出现下图所示就说明jdk配置正确: 如果没有,则参考jdk的安装及配置如果以上都没有问题,则向下看. 1.2确认Tomcat的环境变量配置对于免安装版的Tomcat来说,在启动Tomcat时,需要读取环境变量和配置信息,缺少了这些信息,就不能登记环境变量,导致闪退. 解决方法: 1:在已解压的
详解Tomcat常用的过滤器

一.跨域过滤器CorsFilter org.apcache.catalina.filters.CorsFilter是跨域资源共享规范的一个实现,常常用于前后端分离,静态资源与后端分离等情况.它主要在HttpServletResponse中增加Access-Control-*头,同时保护HTTP响应避免拆分,如果请求无效或者禁止访问,则返回403响应码. 1.1.配置示例 <filter> <filter-name>CorsFilter</filter-name> <
详解Tomcat多域名的配置

有时候我们有好几个项目需要发布在同一个tomcat服务器上,每个项目有不同的域名.这就需要在tomcat里配置多域名,添加多个虚拟主机. 主要在server.xml里面设置: 在<Engine></Engine>里面添加两个<Host></Host>标签,内容如下: <Host name="www.123.com" appBase="/usr/local/tomcat/webapps/123" unpackWAR
详解Tomcat服务器绑定多域名和虚拟目录的方法

tomcat采用默认安装,要想tamcat直接绑定多个域名,这里我们需要修改配置文件:C:\Program Files\Apache Software Foundation\Tomcat 5.5\conf\server.xml server.xml 的修改方式如下: (一)多域名绑定 1.如果你要绑定网站,首先是要把tomcat的默认访问端口8080,修改成80 原始: <Connector port="8080" maxHttpHeaderSize="8192&quo
详解Tomcat集群如何同步会话

Tocmat集群中最重要的交换信息就是会话消息,对某个tomcat实例某会话做的更改要同步到集群其他tomcat实例的该会话对象,这样才能保证集群所有实例的会话数据一致.在tribes组件的基础上完成这些工作就相当容易些,tribes是tomcat实现的一个通信框架. 如下图,tomcat实现会话同步的过程中大致会使用如下组件,现在假设中间的tomcat实例的会话改变了,它会通过会话管理器Manager将改变的动作消息封装成消息然后调用集群对象Cluster,通过Cluster将消息发送出去,同
详解Tomcat多域名配置(多个项目共用80端口)

今天在做项目时,需要用已申请好的三个二级域名(公司不可能每个项目都申请一个顶级域名,所以这里解析的三个二级域名),分别配置到三个项目,网上搜了一堆,感觉看的不明不白,故在此记录下. 总体步骤是:申请域名>>配置tomcat>>域名绑定IP. 这里主要说明配置Tomcat(我的服务器是windows,lilux下同理修改): 首先保证三个项目正常部署在同一个tomcat里,默认端口号是都是80,这时候访问的url均为http://IP地址/各自项目名/XXX,如下图然后修改tomc

详解Tomcat如何实现Comet

相关推荐

随机推荐