基于Comet技术的WEB实时性应用的研究

    刘媚++王旭阳

    

    摘要：Comet技术也称反向AJAX技术，它主要是通过服务器端主动推送，解决AJAX需定期轮询发送消息请求连接所要消耗服务器资源的问题，给用户实时交互使用带来了全新的体验。文章主要介绍Comet技术、实现方式、实现框架等，使用Comet技术完成实时系统的开发方法和步骤。主要是通过开源的Pushlet框架技术相结合完成网页主动推送的功能，实现网页数据实时主动呈现给用户的最终效果。

    关键词：Comet；AJAX；服务器推送；Web实时系统

    随着互联网技术的快速发展，浏览器作为Web应用前台的方式越来越多。人们对网页的使用要求不仅仅是主动获取的方式，更多的是希望由服务器端主动推送呈现用户所需的内容。如现在应用比较多的淘宝、京东的一些主动推送服务。

    AJAX技术的出现使得Comet技术成为可能。AJAX技术的工作原理主要是通过异步方式在客户端和服务器端增加了个中间层，客户端发送请求不是所有的都直接提交给服务器端，某些请求是可以通过中间层间接完成的，这样在一定程度上缓解了服务器的负荷。但是，AJAX最终还是需要服务器响应，实时性还是有延迟。因此，应用AJAX技术的话，实时性还是得不到保障。所以又引入了新的技术Comet（也叫反向AJAX），Comet通过维护一条HTTP长链接，从而不再需要客户端侧发送请求消息，服务器端主动发送消息到浏览器端。

    1 Comet技术实现方式

    传统的Ajax技术无法实现真正的高并发、高实时性，同时频繁的轮询机制服务器的开销比较大，只能应用在小型应用中。所以AJAX适用并发用户不大于200个，并且用户不同操作的请求的实时性Web应用中，如：用户通过网页注册账号，当输入用户名时，提示此用户名已经存在AJAX的典型应用。

    Comet技术也被称作反AJAX （Reverse AJAX）技术，它主要是通过服务器端推的方式来解决AJAX中存在不确定的延迟以及需要维护大量开销的服务器负荷问题。而通过Comet技术，客户端侧则不需要主动向服务器发起消息，服务器端却能主动将消息推送到客户端侧。

    因此，Comet被称为“基于HTTP长连接的服务器推”。Comet技术主要是通过在服务器端和客户端侧的浏览器之间建立并维持一个TCP长连接保持监听的。当服务器侧处理完客户端发送过来的请求时，服务器端并不是马上关闭这条连接，而是将这条连接一直保留着，当下一次有数据更新或者变动时，它能快速使服务器实时地将更新的信息通过这条连接传送到客户端，而无须客户端侧再次发出请求，这种方式节省了服务器端与客户端建立与关闭连接的时间，真正实现了“push”模式。

    2 使用Comet技术的设计框架

    2.1

    Pushlet框架

    设计采用Pushlet框架实现。Pushlet框架是Comet技术应用的开源框架。它主要是通过客户端侧发送请求，订阅感兴趣的事件。服务器端为每个客户端分配一个可以用作会话的ID作为标记，事件源会把新产生的事件以多播的方式发送到订阅者的事件队列里。Pushlet采用基于Comet的JavaScript库文件用于实现长轮询方式的“服务器推”。

    2.2 数据层

    服务器数据推送采用开源的Pushlet框架，利用JSP技术，服务器在不关闭http流的情况下推送数据到客户端浏览器，基于Comet的长轮询方式。首先每个Client会跟Server建立一个长连接，服务器会保存客户端Session即入队，Server会每隔一段时间例如每5秒对数据库进行查询，然后根据队列中的对象进行广播，把数据Push到每个Client。性能说明：Server每5秒只对数据库进行1次查询，然后把数据广播给所有连接的客户端，这区别于AJAX每个客户端都去对数据库进行查询，Push的性能要远远高于AJAX拉取的方式。在Push的过程中程序会频繁开关数据库，为了减少连接创建时间，提高性能，连接采用开源连接池组件Proxool。

    2.3 业务逻辑层

    主要使用struts2框架来处理用户请求，实现具体逻辑关系和页面跳转。

    2.4 表现层

    图形化报表呈现用JfreeChart和FusionCharts作比较，FLASH格式的报表在色彩表现要比JfreeChart效果好，并且具有动态效果，推荐报表的呈现方式采用FusionCharts图表控件。前端页面展示采用Jpolite框架，JPolite将内容展示和事件相分离。

    3 使用Pushlet开发Comet风格的Web应用

    （l）首先当然要获取pushlet开发包。http：//sourceforge.net/projects/pushlets/files/pushlets/2.0.4/pus hlet-2.0.4.zip/download下载后解压，获取lib下的pushlet.Jar，pushletclient.Jar及web apps＼pu shlet ＼WEB-INF＼classes下的log4j. properties，pushlet. properties、sources. propertieS。

    （2）在src目录中添加log4j.properties，pushlet.properties，sources.properties，后续对sources.properties进行修改和配置。

    （3）配置Web. xml。

    （4）创建自己的事件源。

    创建事件（pullEvent）中，业务部分就写在pullEvent（）方法中即可，这个方法会被定时调用。protected EventpullEvent（）{

    Event

    event

    =Event. creat eDat aEvent（"/fornew/push"）：∥事件与jsp页面“绑定” StringBufferstr - new StringBuffer（“工单总量[”）.append（i++）.append（]）：str. append （this.getRandomStr（））：

    try{//转码，否则中文在页面出现乱码，且会使页面“掉线”event. setField（"hw"， new

    String （str.toString（）. getBytes （"UTF8"），

    "IS08859-1"》：

    ）

    catch （UnsupportedEncodingException e） {

    e.printStackTrace（）：

    ）

    return event；

    ）∥产生随机数，便于页面观察

    public String getRandomStr（）{

    Random random = new Random（）；

    return Math. abs （random. nextlnt（））+""： ）

    （5）在上面加入的sources. properties中配置事件源。

    配置如下：

    sourcel-com. fornew. PushLet $PushEvent

    （6）编写index.jsp页面如下。

    pushlet源码中DEMO测试成功的参考页面如图1所示。

    4 结语

    本文通过采用Comet技术开源的Pushlet框架实现Web的实时系统，给用户带来了全新的交互性和良好的界面感知。为了将Comet技术与现有技术架构相结合，采用开源的plush框架设计结构，从而保证节点快速地加入、退出、跳转等，提高交互的性能。为了解决资源链接数的优化设置，本文采用了Tomcat中间件的应用，以达到最佳资源数的应用，最终更大化地提升系统性能。由于Comet技术链接数资源有限，只能应用于并发数较少的链接使用，当并发数较多的情况出现，实时性就得不到保障。下一步可以考虑将Comet技术与多并发分布式技术相结合，应用于多终端、多用户的多连接实时呈现。