需要jdk1.5以上，tomcat5.0以上，具体的安装不再说明。
下载jetty源码，将里面demo的软件包导入到所建的工程，将demo中web路径下org文件夹放在所建工程的webroot下。
将Dojo里面的三个文件夹dijit，dojo，dojox放在webroot路径下。
客户端有两个文件chattest.html，chattest.js。服务端有一个java类ChatTestService.java。
chattest.html
<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN"
"http://www.w3.org/TR/html4/loose.dtd">
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
<title>test chat</title>
<script type="text/javascript" src="../dojo/dojo.js"
djConfig="parseOnLoad:true"></script>
<script type="text/javascript" src="t.js"></script>
</head>
<body>
<div id="root">
<div>
<label>一个简单的聊天程序</label>
</div>
<div id="chat"></div>
<div>
Chat:
<input id="message" type="text" />
<button id="sendChat">Send</button>
</div>
</div>
</body>
</html>
chattest.js
dojo.require("dojox.cometd");
dojo.require("dojox.cometd.timestamp");
dojo.require("dojox.cometd.ack");
dojo.require("dojox.cometd.reload");
var root = {
_chatSubscription: null,
//初始化
_init: function(){
//简历链接，握手
dojox.cometd.init("http://localhost:8080/dojocometd/cometd");
root._subscribe();
//点击按钮时调用_chat方法
dojo.query("#sendChat").onclick(function(e)
{
root._chat();
});
},
//订阅通道，将信息写到界面
_subscribe: function(){
root._chatSubscription = dojox.cometd.subscribe
('/test/testchat',root._receive);
},
//取消订阅
_unsubscribe: function(){
if (room._chatSubscription)
{
dojox.cometd.unsubscribe(root._chatSubscription);
}
root._chatSubscription = null;
},
//将客户端信息发送到服务器端
_chat:function(){
var text=dojo.byId('message').value;
dojox.cometd.publish('/test/testchat', {
clientuser: 'test',
chatmessageclient: text
});
dojo.byId('message').value="";
},
//接受服务器端的信息，显示到界面
_receive: function(message)
{
var chat = dojo.byId('chat');
var text=message.data.chatmessageservice;
chat.innerHTML += "" + "testchat:" + " " + text + "<br/>";
}
};
//页面初始渲染时，调用_init方法
dojo.addOnLoad(root, "_init");
//关闭页面时断开链接
dojo.addOnUnload(function()
{ root._unsubscribe();
dojox.cometd.disconnect();
});
ChatTestService.java
package com.my.service;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import javax.inject.Inject;
import org.cometd.bayeux.server.BayeuxServer;
import org.cometd.bayeux.server.ConfigurableServerChannel;
import org.cometd.bayeux.server.ServerMessage;
import org.cometd.bayeux.server.ServerSession;
import org.cometd.java.annotation.Configure;
import org.cometd.java.annotation.Listener;
import org.cometd.java.annotation.Service;
import org.cometd.java.annotation.Session;
import org.cometd.server.authorizer.GrantAuthorizer;
import org.cometd.server.filter.DataFilter;
import org.cometd.server.filter.DataFilterMessageListener;
import org.cometd.server.filter.JSONDataFilter;
import org.cometd.server.filter.NoMarkupFilter;
@Service
public class ChatTestService {
//用来存储订阅了该服务的客户端ID
private final List<String> clientId = new ArrayList<String>();
@Inject
private BayeuxServer _bayeux;
@Session
private ServerSession _session;
@SuppressWarnings("unused")
//配置通道
@Configure("/test/testchat")
private void configureTestChat(ConfigurableServerChannel channel) {
DataFilterMessageListener noMarkup = new DataFilterMessageListener(
_bayeux, new NoMarkupFilter(), new BadWordFilter());
channel.setPersistent(true);
channel.addListener(noMarkup);
channel.addAuthorizer(GrantAuthorizer.GRANT_PUBLISH);
}
//通道监听
@Listener("/test/testchat")
public void privateTestChat(ServerSession client, ServerMessage message) {
//判断list中是否保存了客户端id
if (!clientId.contains(client.getId()))
clientId.add(client.getId());
//获取客户端数据
Map<String, Object> data = message.getDataAsMap();
//获取所有的client对应的ServerSession
ArrayList<ServerSession> ssvs= new ArrayList<ServerSession>(
clientId.size());
for (String ssvid: clientId) {
if ssvid!= null) {
ServerSession ssv = _bayeux.getSession(peerId);
if (ssv != null)
ssvs.add(ssv);
}
}
if (ssvs.size() > 0) {
Map<String, Object> chat = new HashMap<String, Object>();
chat.put("userserivce", data.get("clientuser"));
chat.put("chatmessageservice", data.get("chatmessageclient"));
ServerMessage.Mutable forward = _bayeux.newMessage();
forward.setChannel("/test/testchat");
forward.setId(message.getId());
forward.setData(chat);
//将数据发布到每个订阅的客户端
for (ServerSession ssv: ssvs)
if (ssv != client)
ssv.deliver(_session, forward);
client.deliver(_session, forward);
}
}
class BadWordFilter extends JSONDataFilter {
@Override
protected Object filterString(String string) {
if (string.indexOf("dang") >= 0)
throw new DataFilter.Abort();
return string;
}
}
}
配置一下web.xml文件
<?xml version="1.0" encoding="UTF-8"?>
<web-app version="2.4"
xmlns="http://java.sun.com/xml/ns/j2ee"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://java.sun.com/xml/ns/j2ee
http://java.sun.com/xml/ns/j2ee/web-app_2_4.xsd">
<welcome-file-list>
<welcome-file>index.jsp</welcome-file>
</welcome-file-list>
<display-name>Cometd Test WebApp</display-name>
<!-- Request that Jetty create an MBean to manage the Bayeux instance -->
<context-param>
<param-name>org.eclipse.jetty.server.context.ManagedAttributes</param-name>
<param-value>org.cometd.bayeux,org.cometd.oort.Oort</param-value>
</context-param>
<!-- Filter to support cross domain requests -->
<filter>
<filter-name>cross-origin</filter-name>
<filter-class>org.eclipse.jetty.servlets.CrossOriginFilter</filter-class>
<!--async-supported>true</async-supported-->
</filter>
<filter-mapping>
<filter-name>cross-origin</filter-name>
<url-pattern>/cometd/*</url-pattern>
</filter-mapping>
<!-- Cometd Servlet -->
<servlet>
<servlet-name>cometd</servlet-name>
<servlet-class>org.cometd.java.annotation.AnnotationCometdServlet</servlet-class>
<!--async-supported>true</async-supported-->
<init-param>
<param-name>timeout</param-name>
<param-value>20000</param-value>
</init-param>
<init-param>
<param-name>interval</param-name>
<param-value>0</param-value>
</init-param>
<init-param>
<param-name>maxInterval</param-name>
<param-value>10000</param-value>
</init-param>
<init-param>
<param-name>maxLazyTimeout</param-name>
<param-value>5000</param-value>
</init-param>
<init-param>
<param-name>long-polling.multiSessionInterval</param-name>
<param-value>2000</param-value>
</init-param>
<init-param>
<param-name>logLevel</param-name>
<param-value>0</param-value>
</init-param>
<init-param>
<param-name>services</param-name>
<param-value>com.my.service.ChatTestService</param-value>
</init-param>
<load-on-startup>1</load-on-startup>
</servlet>
<servlet-mapping>
<servlet-name>cometd</servlet-name>
<url-pattern>/cometd/*</url-pattern>
</servlet-mapping>
</web-app>
将代码发布到tomcat下，访问cometdtest.html文件即可，最好用火狐浏览器
分享到：
相关推荐
jetty-6.1.9 jetty-util-6.1.9 servlet-api-2.5-6.1.9 全网搜索dojox.cometd实现WEBQQ，没有可以运行的源码包项目，搞了五天，分享给大家，真实可用，jar包就找了好久，花了5分，搞了5天5分。共10分。 付原作者地址...
一个comet的实例，使用了dojoJavaScript等
这是我做的一个comet应用的小例子，使用tomcat 6实现的，例子只能在FireFox上运行，运行时打开两个浏览器就能达到你要的效果了，还要记住把conf/server中的连接类型改为NIO protocol="org.apache.coyote....
tomcat实现comet例子，实现后台产生每隔几秒产生随机数，前台不刷新显示。tomcat实现comet例子，实现后台产生每隔几秒产生随机数，前台不刷新显示。tomcat实现comet例子，实现后台产生每隔几秒产生随机数，前台不...
通过tomcat服务器，向网页发送即时消息。comet的小例子，可以直接运行，用tomcat6.0。
comet框架例子项目,自己写的一个参考例子供大家学习
comet4j 简单例子 + 文档 + jar + tomcat7 + 解压导入eclipse即可用。
comet 很好的一个实例 var ajax = new Ajax.Request(WebApp._url_, { method: 'get', parameters: { 'timestamp' : WebApp._timestamp_ }, onSuccess: function(transport) { var response = ...
ssh框架整合comet实现即时通信的简单实例，ssh框架整合comet实现即时通信的简单实例
asp.net comet例子,基于ajax的长联技术, 注:此版本只有ff下正常 ie下可以用iframe实现 http://www.dotnetdev.cn
如何安装一个Jetty包 如何配置Jetty – 主要文档 如何运行Jetty 用JConsole监控Jetty 如何使用Jetty开发 Jetty HelloWorld教程 Jetty和Maven HelloWorld教程 Jetty(6)入门 (www.itjungle.com) Jetty Start.jar 配置...
dwr与spring整合的相关资料收集dwr与spring整合的相关资料收集dwr与spring整合的相关资料收集dwr与spring整合的相关资料收集
http长连接comet pushlet 例子 导入eclipse 直接能用
NULL 博文链接：https://ttling.iteye.com/blog/1910095
java comet服务器推送使用步骤及例子
网络上Spring整合DWR comet 实现无刷新、多人聊天室 的代码整理，包含jar包，eclipse工程，直接导入即可运行。
comet4j，comet4j实例，实例代码，可直接运行
comet两种实现之一的ajax实现，内部有源代码，这是一个聊天室的例子
comet4j-tomcat6,comet4j-tomcat7,comet4j.js,comet4j.js,以及一个样例
一个简单的comet实现的例子程序，就是comet实现长链接，反向ajax实现