浅析Comet技术在Java Web实时系统开发中的应用(1)(2)
2014-03-18 01:12
导读:传统的阻塞式IO,每个连接必须要开一个线程来处理,您始终从一个线程中读取流直到整个流完成,然后关闭连接。因此阻塞式IO对大量并发的短生命周期连接
传统的阻塞式IO,每个连接必须要开一个线程来处理,您始终从一个线程中读取流直到整个流完成,然后关闭连接。因此阻塞式IO对大量并发的短生命周期连接不会造成问题。而非阻塞IO处理连接是异步的。当某个连接发送请求到服务器,服务器把这个连接请求当作一个请求“事件”,并把这个“事件”分配给相应的函数处理。我们把这个处理函数放到线程中去执行,执行完就把线程归还。这样一个线程就可以异步地处理多个事件。
为了获得事件通知,我们需要一个机制,它只在需要读时才读,需要写时才写,但又保持连接打开以迅速响应发生的事件。为了方便这个过程,就要用到NIO,它已是1.4版本以后的Java语言的一部分。
2 使用Java开发Comet风格的Web应用
支持Comet的Java Web开源服务器有Tomcat 6.0.14和Jetty 6.1.14,它们的实现方法各不相同。下面我们以Tomcat为例来说明开发Comet风格的Web应用的步骤[2]。
本例以流方式实现了一个Comet应用。服务器每隔一定的时间间隔产生一个0~9之间的随机数,将数据推送到客户端。客户端接收并显示。
第一,要下载和安装Tomcat6.X(本文截稿时,Tomcat最新版本是6.0.24)。
第二,为了使用Comet,要求服务器支持NIO,所以要修改Tomcat配置文件conf/server.xml, 即启用异步版本的IO连接器,这个非常关键。如下所示:
第三,该项目需要Comet的API支持,Tomcat6自带的Comet API包为catalina.jar,在Tomcat安装目录下的lib目录中。
第四,编写Servlet。通过servlet实现CometProcessor接口。这个接口要求实现event()方法,在配置的Http11NioProtocol调用event()方法来处理请求,而不是doGet或doPost。最基本的支持Comet的servlet实现如程序清单1所示。
(科教论文网 lw.NsEac.com编辑整理)
在event()方法中,分别处理连接开始(BEGIN)、新数据可用(READ),连接结束(END),或出错等事件。Comet允许针对不同的事件指定不同的连接超时。这意味着可以给常规的请求设置很短的生命周期,但是对于响应长连接请求的机制,可以将这个生命周期延长至几分钟。
共2页: 1 [2] 下一页 论文出处(作者):
IDC中心的ARP攻击与防御解决方案
试验数据管理系统的应用