comet4j开发指南
原文链接:http://blog.csdn.net/majian_1987/article/details/8489738
准备工作
下载服务端jar文件
Comet4J目前仅支持Tomcat6、7版本,根据您所使用的Tomcat版本下载【comet4jtomcat6.jar】或【comet4j-tomcat7.jar】文件放置到WEB项目的WEB-INF\lib目录下。
下载客户端js文件
修改服务器配置文件
- <Connector executor="tomcatThreadPool" port="8080" protocol="HTTP/1.1" connectionTimeout="20000" redirectPort="8443" />
替换为:
- <Connector URIEncoding="UTF-8" connectionTimeout="20000" port="8080" protocol="org.apache.coyote.http11.Http11NioProtocol" redirectPort="8443"/>
客户端
- <!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
- <html xmlns="http://www.w3.org/1999/xhtml">
- <head>
- <meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
- <title>Comet4J Hello World</title>
- <script type="text/javascript" src="js/comet4j-0.0.2.js"></script>
- <script type="text/javascript">
- function init(){
- var kbDom = document.getElementById('kb');
- JS.Engine.on({
- hello : function(kb){//侦听一个channel
- kbDom.innerHTML = kb;
- }
- });
- JS.Engine.start('conn');
- }
- </script>
- </head>
- <body οnlοad="init()">
- 剩余内存:<span id="kb">...</span>KB
- </body>
- </html>
服务端
helloworld.java
- package org.comet4j.demo.helloworld;
- import javax.servlet.ServletContextEvent;
- import javax.servlet.ServletContextListener;
- import org.comet4j.core.CometContext;
- import org.comet4j.core.CometEngine;
- public class HelloWorld implements ServletContextListener {
- private static final String CHANNEL = "hello";
- public void contextInitialized(ServletContextEvent arg0) {
- CometContext cc = CometContext.getInstance();
- cc.registChannel(CHANNEL);//注册应用的channel
- Thread helloAppModule = new Thread(new HelloAppModule(), "Sender App Module");
- helloAppModule.setDaemon(true);
- helloAppModule.start();
- }
- class HelloAppModule implements Runnable {
- public void run() {
- while (true) {
- try {
- Thread.sleep(1000);
- } catch (Exception ex) {
- ex.printStackTrace();
- }
- CometEngine engine = CometContext.getInstance().getEngine();
- engine.sendToAll(CHANNEL, Runtime.getRuntime().freeMemory()/1024);
- }
- }
- }
- public void contextDestroyed(ServletContextEvent arg0) {
- }
- }
配置
- <listener>
- <description>Comet4J容器侦听</description>
- <listener-class>org.comet4j.core.CometAppListener</listener-class>
- </listener>
- <servlet>
- <description>Comet连接[默认:org.comet4j.core.CometServlet]</description>
- <display-name>CometServlet</display-name>
- <servlet-name>CometServlet</servlet-name>
- <servlet-class>org.comet4j.core.CometServlet</servlet-class>
- </servlet>
- <servlet-mapping>
- <servlet-name>CometServlet</servlet-name>
- <url-pattern>/conn</url-pattern>
- </servlet-mapping>
- <listener>
- <description>HelloWorld</description>
- <listener-class>org.comet4j.demo.helloworld.HelloWorld</listener-class>
- </listener>
客户端使用简介
客户端是一个JavaScript文件(comet4j-0.0.2.js),其中最重要的是JS.Connector和JS.Engine两个类。JS.Connector负责与服务器建立并保持连接,而JS.Engine类负责将服务器推送过来的消息转化为开发人员可以处理的消息事件,并分发出去,大多数情况下,我们仅需要使用JS.Engine类就可以完成多数的开发工作。
JS.Engine类是一个静态类,在一个页面中只有一个JS.Engine类的实例。它除了负责把服务器推过来的消息转化为事件分发以外,与服务器的连接与断开也由此类负责。
JS.Engine.start方法
JS.Engine.start(String str)和JS.Engine.stop(String str)分别控制连接和断开动作,start方法需要传入一个字符串参数,用来指定您配置的Comet4J连接地址。比如按前面准备工作的配置了CometServlet的地址为/conn,那么可以这样写:
- JS.Engine.start('/conn');
上段代码我们让浏览器与服务器进行连接,当连接成功以后JS.Engine类会发出"start"事件,如何进行事件的处理我们稍后介绍。
JS.Engine.stop方法
我们也能够让连接断开:
- JS.Engine.stop('主动断开');
上面代码我们让连接断开,并传入了一个“主动断开”这样一个断开的原因。如果您并不需要对断开的原因进行说明,也可以不传递参数:
- JS.Engine.stop();
JS.Engine类的事件处理
- JS.Engine.on('start',function(cId, channelList, engine){
- alert('连接已建立,连接ID为:' + cId);
- });
- JS.Engine.on('stop',function(cause, cId, url, engine){
- alert('连接已断开,连接ID为:' + cId + ',断开原因:' + cause + ',断开的连接地址:'+ url);
- });
也可以将上段代码写成,下面代码与上段代码完全等效:
- JS.Engine.on({
- start : function(cId, channelList, engine){
- alert('连接已建立,连接ID为:' + cId);
- },
- stop : function(cause, cId, url, engine){
- alert('连接已断开,连接ID为:' + cId + ',断开原因:' + cause + ',断开的连接地址:'+ url);
- }
- });
接下来,介绍一下如何对服务器推送过来的消息进行处理。在介绍之前,我们假设后台已经注册了一个"hello"的应用通道标识,并且只向客户端推送简单的字符串信息。先看如下代码:
- JS.Engine.on('hello',function(text){
- alert(text);
- });
这样当服务器端使用"hello"通道标识推送过来的消息就可以由上段代码进行处理,将推送过来的信息弹出。
服务器端使用简介
服务端由一个Jar包组成,其中最重的是CometContext和CometEngine两个类。
Comet Context 类
- CometContext.getInstance().registChannel("hello");
这样便注册了一个标识为“hello”的应用通道,而客户也可以通过JS.Engine.on('hello',function(msg){...})的形式来接收并处理来自此通道的消息。
Comet Engine 类
- ring channel = "hello";
- String someConnectionId = "1125-6634-888";
- engine.sendToAll(channel , "我来了!");
- engine.sendTo(channel , engine.getConnection(someConnectionId),“Hi,我是XXX”);
上面代码使用sendToAll方法向所有客户端在"hello"通道上发送了“我来了!”这样一条消息,然后又使用sendTo在同样的通道上向某一个连接发送了“Hi,我是XXX”消息。 CometEngine另外一个很重要的地方在于,它是框架工作的事件引擎的集散地,它提供了BeforeConnectEvent、BeforeDropEvent、ConnectEvent、DropEvent、MessageEvent等事件。通过对这些事件的处理来实现具体的功能:
- class JoinListener extends ConnectListener {
- @Override
- public boolean handleEvent(ConnectEvent anEvent) {
- CometConnection conn = anEvent.getConn();
- CometContext.getInstance().getEngine().sendTo("hello", conn.getId(),"欢迎上线");
- }
- }
- CometEngine engine = CometContext.getInstance().getEngine();
- engine.addConnectListener(new JoinListener()
上面先定义了一个JoinListener并实现了父类ConnectListener的handleEvent抽像方法,然后使用engine.addConnectListener来注册这个事件侦听。这样,在有客户与服务器成功建立连接已后,就可以向此客户端推送一条欢迎信息。
Comet4J配置参数表
- <!--Comet4J配置 -->
- <listener>
- <description>Comet4J容器侦听</description>
- <listener-class>org.comet4j.core.CometAppListener</listener-class>
- </listener>
- <servlet>
- <description>Comet连接[默认:org.comet4j.core.CometServlet]</description>
- <display-name>CometServlet</display-name>
- <servlet-name>CometServlet</servlet-name>
- <servlet-class>org.comet4j.core.CometServlet</servlet-class>
- </servlet>
- <servlet-mapping>
- <servlet-name>CometServlet</servlet-name>
- <url-pattern>/conn</url-pattern>
- </servlet-mapping>
- <!-- Comet4J可选参数配置-->
- <context-param>
- <description>语言[支持:zh,en,默认:zh,详细http://www.loc.gov/standards/iso639-2/php/English_list.php]</description>
- <param-name>Comet.Language</param-name>
- <param-value>zh</param-value>
- </context-param>
- <context-param>
- <description>请求超时时间/微妙[默认:60000,1分钟,建议至少设置3秒以上]</description>
- <param-name>Comet.Timeout</param-name>
- <param-value>60000</param-value>
- </context-param>
- <context-param>
- <description>连接空闲过期时间/微妙[默认:5000,5秒]</description>
- <param-name>Comet.ConnExpires</param-name>
- <param-value>5000</param-value>
- </context-param>
- <context-param>
- <description>连接检查频率/微妙[默认:5000,5秒]</description>
- <param-name>Comet.ConnFrequency</param-name>
- <param-value>5000</param-value>
- </context-param>
- <context-param>
- <description>缓存信息过期时间/微妙[默认:60000,1分种]</description>
- <param-name>Comet.CacheExpires</param-name>
- <param-value>60000</param-value>
- </context-param>
- <context-param>
- <description>缓存信息过期检查频率/微妙[默认:60000,1分种]</description>
- <param-name>Comet.CacheFrequency</param-name>
- <param-value>60000</param-value>
- </context-param>
- <context-param>
- <description>连接模式[auto(默认)/stream/lpool]</description>
- <param-name>Comet.WorkStyle</param-name>
- <param-value>auto</param-value>
- </context-param>
- <context-param>
- <description>开启调试[false(默认)/true]</description>
- <param-name>Comet.Debug</param-name>
- <param-value>false</param-value>
- </context-param>
转载于:https://www.cnblogs.com/zhongshiqiang/p/6679887.html
comet4j开发指南相关推荐
- 最全面的Unity游戏开发指南视频教程 第2卷
最全面的Unity游戏开发指南视频教程 第2卷 流派:电子学习| MP4 |视频:h264,1280×720 |音频:AAC,44.1 KHz 语言:英语+中英文字幕(根据原英文字幕机译更准确)|大小 ...
- Linux 汇编语言开发指南
Linux 汇编语言开发指南 肖文鹏 (xiaowp@263.net), 北京理工大学计算机系硕士研究生 本文作者 肖文鹏是北京理工大学计算机系的一名硕士研究生,主要从事操作系统和分布式计算环境的研究 ...
- 《Python和Pygame游戏开发指南》——2.16 pygame.display.update()函数
本节书摘来自异步社区<Python和Pygame游戏开发指南>一书中的第2章,第2.16节,作者[美]Al Sweigart(斯维加特), 李强 译,更多章节内容可以访问云栖社区" ...
- 400 多行代码!超详细 Rasa 中文聊天机器人开发指南 | 原力计划
作者 | 无名之辈FTER 责编 | 夕颜 出品 | 程序人生(ID:coder_life) 本文翻译自Rasa官方文档,并融合了自己的理解和项目实战,同时对文档中涉及到的技术点进行了一定程度的扩展, ...
- Knockout应用开发指南 第六章:加载或保存JSON数据
原文:Knockout应用开发指南 第六章:加载或保存JSON数据 加载或保存JSON数据 Knockout可以实现很复杂的客户端交互,但是几乎所有的web应用程序都要和服务器端交换数据(至少为了本地 ...
- iOS开发指南 从Hello World到App Store上架 第5版
iOS开发指南 从Hello World到App Store上架 第5版 关东升 著 ISBN:9787115450630 包装:平装 开本:16开 正文语种:中文 出版社: 人民邮电出版社 出版时间 ...
- 《jQuery EasyUI开发指南》——10.4 迭代开发
本节书摘来自异步社区<jQuery EasyUI开发指南>一书中的第10章,第10.4节,作者:王波著,更多章节内容可以访问云栖社区"异步社区"公众号查看 10.4 迭 ...
- 《Node.js开发指南》书评汇总
刚查了下库存,发现订阅<Node.js开发指南>的读者大增,这是为什么呢?看了下近期本书在豆瓣的评论,口碑很好,现将豆瓣的书评汇总如下: ------------------------- ...
- JNI/NDK开发指南(八)——调用构造方法和父类实例方法
转载请注明出处:http://blog.csdn.net/xyang81/article/details/44002089 在第6章我们学习到了在Native层如何调用Java静态方法和实例方法,其中 ...
最新文章
- IOI2011 BZOJ2600 ricehub
- linux cron指定用户,Centos下crontab指定执行用户
- Apex Integration Overview
- 机器学习(一)线性回归
- vite打包编译后类名混淆冲突问题处理
- 二叉树节点数目计算的两种思路
- 电池供电的电容麦_电容麦一定需要幻象电源吗 幻象电源的作用是什么
- 14寸笔记本电脑_苹果 华为 联想 笔记本电脑报价 11月3日
- step-by-step: 夕小瑶版神经网络调参指南
- 《圈圈教你玩USB》 第三章 USB鼠标的实现——看书笔记( 2 )
- Cadence系列之SIPI仿真笔记:Cadence多种版本的安装、卸载重装(一)
- 借助Bodymovin播放svg动画
- 如何将CAD图纸转换成彩色jpg
- Golang获取时间戳并增加一天
- 你知道JavaScript的继承有几种写法吗?
- Mysql 分数排名查询
- gromacs ngmx_GROMACS教程
- 桌面虚拟化中VDI和IDV的五大区别
- 下单后,订单拆单能怎拆?
- 沉淀近900万+营销资产,天攻智投户外营销助力网易有道实现“品效双赢”
热门文章
- 矿泉水功能突破口-丰收节交易会·李喜贵:遵义谋定水产业
- C#学习知识库2.0版
- 可覆写的函数与创建节点
- [CF917D]Stranger Trees[矩阵树定理+解线性方程组]
- 深入理解Spring AOP思想
- python开发【第四篇】:python基础之函数
- centos上安装supervisor来管理dotnetcore等应用程序
- Vulkan Tutorial 14 Integration pipeline
- Spring学习总结(一)——Spring实现IoC的多种方式
- 结对开发4----最大子数组(大数溢出)