1、先讲讲HTML5的WebSocket
HTML5规范中提供了WebSocket技术，替代了之前的ajax实现消息通信的方法。
WebSocket协议，简称WS（WSS-Secure），可以支持客户端-服务端任意消息推送，支持跨域（AJAX跨域会有问题），可降低系统开销及复杂性。网上已经有很多关于WebSocket的介绍，这里不再重复。
以下是WebSocketAPI的使用说明
a、 检测浏览器是否支持WebSocket
function checkWS() {
if (window.WebSocket) {
alert( "HTML5 WebSocket is supported in your browser.");
} else {
alert("HTML5 WebSocket is not supported in your browser.");
}
}
支持的浏览器有Firefox 4、Chrome 4、Opera 10.70以及Safari 5，不支持的浏览器可以是用Socket.IO技术
b、WebSocket API用法
// 创建一个Socket实例
var socket = new WebSocket(‘ws://localhost:8080′);
// 打开Socket
socket.onopen = function(event) {
// 发送一个初始化消息
socket.send(‘I am the client and I\’m listening!’);
// 监听消息
socket.onmessage = function(event) {
console.log(‘Client received a message’,event);
};
// 监听Socket的关闭
socket.onclose = function(event) {
console.log(‘Client notified socket has closed’,event);
};
// 关闭Socket….
//socket.close()
c、 Demo#
<!DOCTYPE html>
<head>
<title>WebSocket Test Page</title>
<script>
var log = function(s) {
if (document.readyState !== "complete") {
log.buffer.push(s);
} else {
document.getElementById("output").innerHTML += (s + "\n");
}
}
log.buffer = [];
url = "ws://localhost:8080/echo";
w = new WebSocket(url);
w.onopen = function() {
log("open");
w.send("thank you for accepting this WebSocket request");
}
w.onmessage = function(e) {
log(e.data);
}
w.onclose = function(e) {
log("closed");
}
window.onload = function() {
log(log.buffer.join("\n"));
document.getElementById("sendButton").onclick = function() {
w.send(document.getElementById("inputMessage").value);
}
}
</script>
</head>
<body>
<input type="text" id="inputMessage" value="Hello, WebSocket!">
<button id="sendButton">Send</button>
<pre id="output"></pre>
</body>
</html>
2. JWebSocket
http://jwebsocket.org/（最新版本v1.0 beta5）
jWebSocket是个纯Java/JavaScript高速的WEB双向通信解决方案，基于HTML5
包含：
jWebSocket Server：基于纯Java的WebSocket服务，可以实现Server-to-client，和server控制的client-to-client的通信
jWebSocket Client：基于纯JavaScript的WebSocket客户端，支持多种子协议，也可以支持Java和andriod，不需要插件
jWebSocket FlashBridge：基于Flash的WebSocket封装，需要flash插件
2.1. 下载安装
2.1.1 独立的server（略，很简单，执行bin/startup即可）
2.1.2.集成在tomcat中运行
1、 设置JWEBSOCKET_HOME 必须（最好重启）
2、 将jWebSocketServer-Bundle-1.0.jar、jWebSocketSamples-1.0.jar拷贝到tomcat6的lib下
3、 将jWebSocketAppSrvDemo-1.0.war拷贝到tomcat6的webapps下
4、 启动tomcat
5、 访问http://localhost:8080/jWebSocketAppSrvDemo-1.0/
6、 使用IP地址访问
（在JWEBSOCKET_HOME/conf/jWebSocket.xml里增加<domain>http://192.168.3.50</domain>,tomcat里的conf/jWebSocket.xml修改没有效果）
2.2. 开发指南
2.2.1. 要求
JDK1.6+
Apache Maven 2.2
Eclipse3.5
Apache tomcat6+
2.2.2. Eclipse开发
下载jWebSocket源码，使用maven导入可以将代码都导入到eclipse中
或者直接创建项目，把jWebSocketServer的libs导进来，自己做开发
2.2.3. JS工具包
2.2.3.1. jWebSocket.js（很庞大，涵盖了所有其他js）
jws对象：
JWS_SERVER_PORT: 8787
JWS_SERVER_SSL_PORT: 9797
JWS_SERVER_URL: "ws://" + ( self.location.hostname ? self.location.hostname : "127.0.0.1" ) + ":8787/jWebSocket/jWebSocket"
在我们的页面中引入jWebSocket.js便可以使浏览器支持WebSocket
<script type="text/javascript" language="JavaScript" src="jWebSocket.js"></script>
<script type="text/javascript" language="JavaScript">
function checkWS() {
if (window.WebSocket) {
alert( "HTML5 WebSocket is supported in your browser.");
} else {
alert("HTML5 WebSocket is not supported in your browser.");
}
}
checkWS();
</script>
Ie8也可以支持了（可以使用flashBridge来支持）
封装的函数：
获取dom对象：
jws.$( "schkDebug" );//getElementById();
事件监听
jws.events.addEventListener( eUsername[对象], "keydown"[事件], usrKeyDnLsnr[监听函数] );
定义js类
jws.oop = {};
// implement simple class declaration to support multi-level inheritance
// and easy 'inherited' calls (super-calls) in JavaScript
jws.oop.declareClass = function( aNamespace, aClassname, aAncestor, aFields ) {
…
}
如定义一个jWebSocketBaseClient（基类）：
jws.oop.declareClass( "jws", "jWebSocketBaseClient", null, {
create();
processOpened(event);
processPacket
processClosed
open( aURL, aOptions );
connect: ( aURL, aOptions );
processQueue
queuePacket: ( aPacket, aOptions )
sendStream(data);
abortReconnect();
setAutoReconnect;
setQueueItemLimit
setQueueSizeLimit
setReliabilityOptions
getReliabilityOptions
getOutQueue
resetSendQueue
isOpened
getURL
getSubProt
forceClose
isConnected
close
disconnect
addListener
removeListener
addPlugIn
setParam
getParam
clearParams
｝
如定义一个jWebSocketTokenClient继承jWebSocketBaseClient：
jws.oop.declareClass( "jws", "jWebSocketTokenClient", jws.jWebSocketBaseClient, {
…//继承的方法
getId();unique clientId
checkCallbacks(token);
checkConnected
isWriteable
checkWriteable
checkLoggedIn
resultToString
tokenToStream/streamToToken
notifyPlugInsOpened/notifyPlugInsClosed
sendToken( aToken, aOptions )
getLastTokenId
getNextTokenId
sendText: function( aTarget, aText ) {
var lRes = this.checkLoggedIn();
if( lRes.code == 0 ) {
this.sendToken({
ns: jws.NS_SYSTEM,
type: "send",
targetId: aTarget,
sourceId: this.fClientId,
sender: this.fUsername,
data: aText
});
}
return lRes;
}
broadcastText( aPool, aText, aOptions )
}
如定义一个jWebSocketJSONClient继承jWebSocketTokenClient
jws.oop.declareClass( "jws", "jWebSocketJSONClient", jws.jWebSocketTokenClient, {
tokenToStream: function( aToken ) {
aToken.utid = jws.CUR_TOKEN_ID;
var lJSON = JSON.stringify( aToken );
return( lJSON );
},
streamToToken: function( aStream ) {
// parsing a JSON object in JavaScript couldn't be simpler...
var lObj = JSON.parse( aStream );
return lObj;
}
});
使用：new jws.jWebSocketJSONClient();
2.2.3.2. <!--[endif]-->token
一个token对象包含1个或多个域（field）和值，使用HashMap<String(field),Object(value)>来存储。
客户端js可以任意增加token的属性（采用json的格式），如发送消息
this.sendToken({
ns: jws.NS_SYSTEM,
type: "send",
targetId: aTarget,
sourceId: this.fClientId,
sender: this.fUsername,
myKey1:"myVal1",//自己增加的属性
myKey2:"myVal2",//后台可以直接获取到
data: aText
});
2.2.3.3. 其他
略
2.2.4. Demo功能(下载的demo里都有附带，以下只是一些关键说明)
2.2.4.1. 聊天chat
A、创建客户端
lWSC = new jws.jWebSocketJSONClient();
B、与服务端连接
WebSocketServerUrl：
[ws://host:port/jWebSocket/jWebSocket]
var lURL = jws.getDefaultServerURL();
àws://localhost:8787/jWebSocket/jWebSocket
与WebSocketServer建立连接、接收消息、关闭连接
lWSC.isLoggedIn()//判断是否已经处于连接状态
lWSC.logon( lURL, eUsername.value, ePassword.value, {
OnOpen: function( aEvent ) {
//建立连接事件
checkKeepAlive({ immediate: false });//是否保持连接状态，调用 lWSC.startKeepAlive( aOptions );或lWSC.stopKeepAlive()
},
// 消息到达回调
Token:
token.type[“response”/”event”/”goodBye”/”broadcast”]
token.reqType[“login”/”getClients”]
token.code
token.count
token.clients
token.msg
token.sender
token.data
OnMessage: function( aEvent, aToken ) {
if( aToken ) {
// is it a response from a previous request of this client?
if( aToken.type == "response" ) {
// figure out of which request
if( aToken.reqType == "login" ) {
if( aToken.code == 0 ) {
// call getAuthClients method from
// jWebSocket System Client Plug-In
lWSC.getAuthClients({
pool: null
});//获取客户端
} else {
log( SYS, IN, "Error logging in '" + eUsername.value + "': " + aToken.msg );
}
} else if( aToken.reqType == "getClients" ) {
log( SYS, IN, "Clients (" + aToken.count + "): " + aToken.clients );
}
// is it an event w/o a previous request ?
} else if( aToken.type == "event" ) {
// interpret the event name
} else if( aToken.type == "goodBye" ) {
log( SYS, IN, lJWSID + " says good bye (reason: " + aToken.reason + ")!" );
// is it any token from another client
} else if( aToken.type == "broadcast" ) {
if( aToken.data ) {
log( aToken.sender, IN, aToken.data );
}
}
}
},
//关闭连接事件
OnClose: function( aEvent ) {
lWSC.stopKeepAlive();
...
})
//获取已经认证的客户端
var lRes = lWSC.getAuthClients({
pool: null
});
lRes.msg
C、给服务端发送消息：
使用客户端（lWSC）的broadcastText()、sendText()
function broadcast() {
var lMsg = eMessage.value;
var lTarget = eTarget.value;
if( lMsg.length > 0 ) {
log( USR, OUT, lMsg );
var lRes;
if( !lTarget || lTarget == "*") {
lRes = lWSC.broadcastText(
"", // broadcast to all clients (not limited to a certain pool)
lMsg // broadcast this message
);
} else {
lRes = lWSC.sendText(
lTarget, // broadcast to all clients (not limited to a certain pool)
lMsg // broadcast this message
);
}
// log error only, on success don't confuse the user
if( lRes.code != 0 ) {
log( SYS, OUT, "broadcast: " + lRes.msg );
}
}
…
}
D、服务端
自定义ServletContext监听器ServletContextListener:Servlet容器启动的时候加载监听
publicclass ContextListener implements ServletContextListener {
publicvoid contextInitialized(ServletContextEvent aSCE) {
// 启动WebSocket服务
JWebSocketFactory.start();
//获取一个tokenServer
TokenServer lTS0 = JWebSocketFactory.getTokenServer();
if (lTS0 != null) {
//给tokenServer增加自定义监听器（监听客户端与Server的一切交互）
System.out.println("----------tokenServer found");
lTS0.addListener(newMyJWebSocketTokenListenerSample());
}else{
System.out.println("----------tokenServer not found");
}
// assign web socket server to servlet bridge
//ServletBridge.setServer(JWebSocketFactory.getTokenServer());
}
publicvoid contextDestroyed(ServletContextEvent aSCE) {
// 关闭WebSocket服务
JWebSocketFactory.stop();
}
}
自定义WebSocketServerToken监听器
publicclass MyJWebSocketTokenListenerSample implements WebSocketServerTokenListener {
publicvoid processOpened(WebSocketServerEvent aEvent) {
System.out.println("login的时候会调用processOpened-------->Client '" + aEvent.getConnector() + "' connected.");
}
publicvoid processPacket(WebSocketServerEvent aEvent, WebSocketPacket aPacket) {
System.out.println("-------->processPacket@Processing data packet '" + aPacket.getUTF8() + "'...");
// Here you can answer an arbitrary text package...
// this is how to easily respond to a previous client's request
// aEvent.sendPacket(aPacket);
// this is how to send a packet to any connector
// aEvent.getServer().sendPacket(aEvent.getConnector(), aPacket);
}
publicvoid processToken(WebSocketServerTokenEvent aEvent, Token aToken) {
System.out.println("-------->Client '" + aEvent.getConnector() + "' sent Token: '" + aToken.toString() + "'.");
String lNS = aToken.getNS();
String lType = aToken.getType();
if("send".equals(lType)){
//{"ns":"org.jwebsocket.plugins.system","type":"send",
//"targetId":"01.32273.0","targetUserName":"tttt","sourceId":"01.32722.3",
//"sourceUserName":"qqqqqq","sender":"guest","data":"22222222","utid":4}
String receiver = aToken.getString("targetUserName");
String sender = aToken.getString("sourceUserName");
String data = aToken.getString("data");
System.out.println("-----------send......."+sender+"-->"+receiver+"["+data+"]");
//自己增加操作，如保存到DB等
}
}
}
/**
*
* @param aEvent
*/
publicvoid processClosed(WebSocketServerEvent aEvent) {
System.out.println("-------->Client '" + aEvent.getConnector() + "' disconnected.");
}
}
在web.xml中配置ServletContext监听即可
以下是我用jwebsocket在网页上实现的效果
支持用户上下线通知及更新，一个webSocket连接支持多用户同时在线聊天，消息提醒等功能
推荐阅读
代码之余轻松一下：当前热门-人民的名义
相关推荐
使用jWebSocket开发时，你需要了解以下几个核心概念： 1. **服务器端部署**：设置jWebSocket服务器，配置监听端口，以及处理WebSocket连接和消息的事件处理器。服务器端的代码可以通过实现`org.jwebsocket.server....
首先，jWebSocket框架提供了易于使用的API，使得开发者能够快速地集成WebSocket功能到他们的应用中。它支持多种类型的WebSocket服务器，包括基于Servlet容器的服务器（如Tomcat）和独立运行的服务器。通过这些服务器...
4. **文档**：可能包括API文档和用户指南，帮助开发者理解和使用jWebSocket的功能。 5. **配置文件**：如`config.properties`，用于配置服务器端的行为，如监听端口、日志级别等。 6. **构建脚本**：如`build.xml`，...
开发者可以使用jWebSocket创建基于WebSocket的应用，实现服务器与浏览器间，或者服务器与使用Java的客户端之间的快速数据交换。jWebSocket支持多种消息类型，包括文本、二进制数据、心电图等。此外，它还提供了多种...
包括使用WebSocket Secure (wss) 协议进行加密通信，以及提供了对用户认证、授权和加密消息的原生支持。 jWebSocket还提供了易用的API接口，简化了编程模型，使得开发者可以更专注于业务逻辑的实现，而不是底层通信...
jWebSocket Server - 基于Java的WebSocket服务器，用于server-to-client(S2C)客户端到服务器的流媒体解决方案，和服务器控制(C2C) client-to-client客户端到客户端的通信。 jWebSocket Clients – 纯JavaScript的...
1. **易于使用**：jWebSocket提供了一套直观的API，让开发者能够快速创建WebSocket服务器和客户端，减少了开发中的学习成本。 2. **跨平台**：由于基于Java，jWebSocket可以在任何支持Java的平台上运行，包括...
这个实例源码提供了完整的jWebSocket使用示例，包括服务器端和客户端的实现，非常适合初学者和开发者参考学习。通过实践，你可以更好地掌握WebSocket在Java中的应用，为开发实时通信应用打下坚实的基础。
在实际开发中，使用jWebSocket可以大大简化WebSocket应用的构建过程。首先，你需要在服务器端设置一个WebSocket监听器，监听特定的WebSocket端点。然后，客户端通过指定URL建立WebSocket连接，并发送或接收数据。...
1. **易于使用**：jWebSocket提供了一个简洁的API，使得开发者可以快速地集成WebSocket功能到他们的应用程序中。通过简单的接口调用，就能创建服务器端和客户端的WebSocket连接。 2. **跨平台**：由于jWebSocket是...
3. **实现客户端**: 可以使用jWebSocket提供的WebSocketClient类，或者自定义WebSocket连接逻辑。 4. **处理连接和消息**: 在服务器端监听连接建立和关闭事件，处理接收到的消息；在客户端建立连接后，可以发送和...
这个开源项目提供了一个灵活且易于使用的框架，使得开发者能够在Java应用中集成WebSocket功能。 jWebSocket的核心特性包括： 1. **双向通信**：WebSocket允许服务器主动向客户端推送数据，而不仅仅是响应客户端的...
免责声明：资料部分来源于合法的互联网渠道收集和整理，部分自己学习积累成果，供大家学习参考与交流。收取的费用仅用于收集和整理资料耗费时间的酬劳。 本人尊重原创作者或出版方，资料版权归原作者或出版方所有，...
在描述中提到，“jwebsocket的客户端源码及示例”，这意味着这个压缩包包含了该库的源代码和示例项目，可以帮助开发者深入理解其工作原理并进行定制化开发。"js什么的用的比较多"可能指的是在实现WebSocket协议时，...
6. **多线程处理**：由于WebSocket连接是长连接，jWebSocket库内部使用多线程机制来处理并发连接，确保在高并发环境下仍能保持高效运行。 7. **扩展性**：jWebSocket库设计时考虑了扩展性，开发者可以自定义消息...
本资料“android网络套接字.zip”可能包含了一个名为“JWebSocket-master”的项目，该项目可能是一个Java实现的WebSocket客户端库，用于在Android应用中实现实时双向通信。 WebSocket是一种在客户端和服务器之间...
第二部分讲解了jwebsocket、rgraph、webgl等3个重要框架和技术的详细使用方法。 《html 5开发精要与实例详解》一共12章：第1章分别用2个案例演示了如何利用html 5中的结构元素来构建一个博客网站和企业门户网站；第2...
除此之外，还可以选择其他语言实现，如Java的`jWebSocket`、Ruby的`web-socket-ruby`、Node.js的`SocketIO-node`等。 2. **安装与配置**：确保安装了相应的服务器环境（如XAMPP），并根据需要修改服务器的配置文件，...