记录下自己在用的websocket
介绍
现很多网站为了实现即时通讯，所用的技术都是轮询(polling)。轮询是在特定的的时间间隔（如每1秒），由浏览器对服务器发出HTTP request，然后由服务器返回最新的数据给客服端的浏览器。这种传统的HTTP request 的模式带来很明显的缺点 – 浏览器需要不断的向服务器发出请求，然而HTTP request 的header是非常长的，里面包含的数据可能只是一个很小的值，这样会占用很多的带宽。
而最比较新的技术去做轮询的效果是Comet – 用了AJAX。但这种技术虽然可达到全双工通信，但依然需要发出请求。
在 WebSocket API，浏览器和服务器只需要要做一个握手的动作，然后，浏览器和服务器之间就形成了一条快速通道。两者之间就直接可以数据互相传送。
运行环境：
实现了websocket的浏览器：
|
Chrome
|
Supported in version 4+
|
|
Firefox
|
Supported in version 4+
|
|
Internet Explorer
|
Supported in version 10+
|
|
Opera
|
Supported in version 10+
|
|
Safari
|
Supported in version 5+
|
依赖：
Tomcat 7 或者 J2EE7
<dependency>
<groupId>org.apache.tomcat</groupId>
<artifactId>tomcat-websocket-api</artifactId>
<version>7.0.47</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>javax</groupId>
<artifactId>javaee-api</artifactId>
<version>7.0</version>
<scope>provided</scope>
</dependency>
注意：早前业界没有统一的标准，各服务器都有各自的实现，现在J2EE7的JSR356已经定义了统一的标准，请尽量使用支持最新通用标准的服务器。
详见：http://www.oracle.com/technetwork/articles/java/jsr356-1937161.html
http://jinnianshilongnian.iteye.com/blog/1909962
我是用的Tomcat 7.0.57 + Java7
必须是Tomcat 7.0.47以上
详见：http://www.iteye.com/news/28414
ps：最早我们是用的Tomcat 7自带的实现，后来要升级Tomcat 8，结果原来的实现方式在Tomcat 8不支持了，就只好切换到支持Websocket 1.0版本的Tomcat了。
主流的java web服务器都有支持JSR365标准的版本了，请自行Google。
用nginx做反向代理的需要注意啦，socket请求需要做特殊配置的，切记！
Tomcat的处理方式建议修改为NIO的方式，同时修改连接数到合适的参数，请自行Google！
服务端
服务端不需要在web.xml中做额外的配置，Tomcat启动后就可以直接连接了。
import com.dooioo.websocket.utils.SessionUtils;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import javax.websocket.*;
import javax.websocket.server.PathParam;
import javax.websocket.server.ServerEndpoint;
/**
* 功能说明：websocket处理类, 使用J2EE7的标准
* 切忌直接在该连接处理类中加入业务处理代码
* 作者：liuxing(2014-11-14 04:20)
*/
//relationId和userCode是我的业务标识参数,websocket.ws是连接的路径，可以自行定义
@ServerEndpoint("/websocket.ws/{relationId}/{userCode}")
public class WebsocketEndPoint {
private static Log log = LogFactory.getLog(WebsocketEndPoint.class);
/**
* 打开连接时触发
* @param relationId
* @param userCode
* @param session
*/
@OnOpen
public void onOpen(@PathParam("relationId") String relationId,
@PathParam("userCode") int userCode,
Session session){
log.info("Websocket Start Connecting: " + SessionUtils.getKey(relationId, userCode));
SessionUtils.put(relationId, userCode, session);
}
/**
* 收到客户端消息时触发
* @param relationId
* @param userCode
* @param message
* @return
*/
@OnMessage
public String onMessage(@PathParam("relationId") String relationId,
@PathParam("userCode") int userCode,
String message) {
return "Got your message (" + message + ").Thanks !";
}
/**
* 异常时触发
* @param relationId
* @param userCode
* @param session
*/
@OnError
public void onError(@PathParam("relationId") String relationId,
@PathParam("userCode") int userCode,
Throwable throwable,
Session session) {
log.info("Websocket Connection Exception: " + SessionUtils.getKey(relationId, userCode));
log.info(throwable.getMessage(), throwable);
SessionUtils.remove(relationId, userCode);
}
/**
* 关闭连接时触发
* @param relationId
* @param userCode
* @param session
*/
@OnClose
public void onClose(@PathParam("relationId") String relationId,
@PathParam("userCode") int userCode,
Session session) {
log.info("Websocket Close Connection: " + SessionUtils.getKey(relationId, userCode));
SessionUtils.remove(relationId, userCode);
}
}
工具类用来存储唯一key和连接
这个是我业务的需要，我的业务是服务器有对应动作触发时，推送数据到客户端，没有接收客户端数据的操作。
import javax.websocket.Session;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
/**
* 功能说明：用来存储业务定义的sessionId和连接的对应关系
* 利用业务逻辑中组装的sessionId获取有效连接后进行后续操作
* 作者：liuxing(2014-12-26 02:32)
*/
public class SessionUtils {
public static Map<String, Session> clients = new ConcurrentHashMap<>();
public static void put(String relationId, int userCode, Session session){
clients.put(getKey(relationId, userCode), session);
}
public static Session get(String relationId, int userCode){
return clients.get(getKey(relationId, userCode));
}
public static void remove(String relationId, int userCode){
clients.remove(getKey(relationId, userCode));
}
/**
* 判断是否有连接
* @param relationId
* @param userCode
* @return
*/
public static boolean hasConnection(String relationId, int userCode) {
return clients.containsKey(getKey(relationId, userCode));
}
/**
* 组装唯一识别的key
* @param relationId
* @param userCode
* @return
*/
public static String getKey(String relationId, int userCode) {
return relationId + "_" + userCode;
}
}
推送数据到客户端
在其他业务方法中调用
/**
* 将数据传回客户端
* 异步的方式
* @param relationId
* @param userCode
* @param message
*/
public void broadcast(String relationId, int userCode, String message) {
if (TelSocketSessionUtils.hasConnection(relationId, userCode)) {
TelSocketSessionUtils.get(relationId, userCode).getAsyncRemote().sendText(message);
} else {
throw new NullPointerException(TelSocketSessionUtils.getKey(relationId, userCode) + " Connection does not exist");
}
}
我是使用异步的方法推送数据，还有同步的方法
详见：http://docs.oracle.com/javaee/7/api/javax/websocket/Session.html
客户端
var webSocket = null;
var tryTime = 0;
$(function () {
initSocket();
window.onbeforeunload = function () {
//离开页面时的其他操作
};
});
/**
* 初始化websocket，建立连接
*/
function initSocket() {
if (!window.WebSocket) {
alert("您的浏览器不支持websocket！");
return false;
}
webSocket = new WebSocket("ws://127.0.0.1:8080/websocket.ws/" + relationId + "/" + userCode);
// 收到服务端消息
webSocket.onmessage = function (msg) {
console.log(msg);
};
// 异常
webSocket.onerror = function (event) {
console.log(event);
};
// 建立连接
webSocket.onopen = function (event) {
console.log(event);
};
// 断线重连
webSocket.onclose = function () {
// 重试10次，每次之间间隔10秒
if (tryTime < 10) {
setTimeout(function () {
webSocket = null;
tryTime++;
initSocket();
}, 500);
} else {
tryTime = 0;
}
};
}
其他调试工具
Java实现一个websocket的客户端
<dependency>
<groupId>org.java-websocket</groupId>
<artifactId>Java-WebSocket</artifactId>
<version>1.3.0</version>
</dependency>
import java.io.IOException;
import javax.websocket.ClientEndpoint;
import javax.websocket.OnError;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
@ClientEndpoint
public class MyClient {
@OnOpen
public void onOpen(Session session) {
System.out.println("Connected to endpoint: " + session.getBasicRemote());
try {
session.getBasicRemote().sendText("Hello");
} catch (IOException ex) {
}
}
@OnMessage
public void onMessage(String message) {
System.out.println(message);
}
@OnError
public void onError(Throwable t) {
t.printStackTrace();
}
}
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.URI;
import javax.websocket.ContainerProvider;
import javax.websocket.DeploymentException;
import javax.websocket.Session;
import javax.websocket.WebSocketContainer;
public class MyClientApp {
public Session session;
protected void start()
{
WebSocketContainer container = ContainerProvider.getWebSocketContainer();
String uri = "ws://127.0.0.1:8080/websocket.ws/relationId/12345";
System.out.println("Connecting to " + uri);
try {
session = container.connectToServer(MyClient.class, URI.create(uri));
} catch (DeploymentException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
public static void main(String args[]){
MyClientApp client = new MyClientApp();
client.start();
BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
String input = "";
try {
do{
input = br.readLine();
if(!input.equals("exit"))
client.session.getBasicRemote().sendText(input);
}while(!input.equals("exit"));
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
Chrome安装一个websocket模拟客户端
最后
为了统一的操作体验，对于一些不支持websocket的浏览器，请使用socketjs技术做客户端开发。
欢迎交流、拍砖！
相关推荐
在本Java WebSocket实例中，我们将探讨以下几个关键知识点： 1. **WebSocket协议**：WebSocket协议是HTTP的升级版，通过一次握手（Upgrade头）从HTTP转换为WebSocket，然后保持持久连接，允许数据以较小的开销双向...
java版本websocket实例下载源码整理
一个基于Java的WebSocket爬虫示例，用于模拟客户端请求服务器，建立WebSocket连接，抓取对方数据，测试为某直播网站。运行时需要获取一个正在直播的网页地址，运行项目下的YizhiboView.java类。
在Java中，有两种常见的方式实现WebSocket：使用Tomcat内置的WebSocket API和使用Spring框架的WebSocket支持。下面我们将详细介绍这两种方法。 **一、Tomcat的WebSocket实现** Tomcat从7.x版本开始支持WebSocket，...
- 在Android应用中，你可以创建一个WebSocketClient实例，连接到WebSocket服务器，然后通过WebSocketListener监听服务器发送的数据，更新UI或执行其他业务逻辑。 - 如果需要在Android设备上运行WebSocket服务器，...
Java WebSocket 是一种在客户端和服务器之间建立长连接的协议，它允许双向通信，即服务器和客户端都可以主动发送数据。WebSocket API 设计用于提供低延迟、高效的数据传输，非常适合实时聊天应用。在这个“java ...
在使用`java-websocket`库时，开发者首先需要创建一个WebSocket客户端或服务器端的实例。客户端通常会连接到指定的WebSocket服务器，并监听连接状态。服务器端则需要设置监听特定端口，等待客户端的连接请求。一旦...
在WebSocket实例中，Maven负责下载并管理所有必要的库，如Java WebSocket API（JSR 356）和其他相关依赖。 要开始构建WebSocket应用，我们需要在Maven的`pom.xml`文件中添加适当的依赖。例如，对于Tomcat7和Java ...
WebSocket是Web应用中的一种实时通信协议，它允许服务器与...综上所述，这个WebSocket Java实例涵盖了从协议基础到实际应用的多个方面，通过学习和实践，你可以深入了解WebSocket在Java环境下的工作原理和开发流程。
websocket实例，内部含有详细使用说明以及代码注释。java写的websocket客户端，包含心跳监测。 此架包可解决问题：系统使用websocket 访问远程上的实时数据，但是有时候会停止更新实时数据，只要重启了自己的系统，...
在Java中，WebSocket的实现主要依赖于`javax.websocket` API，这个API是Java EE 7标准的一部分。下面我们将详细探讨WebSocket的工作原理、如何在Java中实现WebSocket以及同步问题。 1. **WebSocket工作原理**： ...
首先创建一个新的WebSocket实例，指定服务器的WebSocket URL，然后监听`open`、`message`、`close`和`error`事件。 5. **使用SockJS**：在客户端，引入SockJS库，创建一个`SockJS`实例，它会自动处理WebSocket的...
在这个WebSocket实例中，Lampsite的后端部分会集成WebSocket功能，使得用户可以通过浏览器实时获取服务器端的数据更新，例如聊天室、股票报价、在线游戏等实时交互场景。 为了实现WebSocket与Spring MVC和MyBatis的...
这个“Java WebSocket开发聊天室实例”将展示如何运用Java技术和WebSocket API创建一个实时的、互动的聊天环境。 首先，我们要理解WebSocket协议的基础。WebSocket协议是基于TCP的，为浏览器和服务器提供了一种高效...
在JavaScript中，你可以创建一个新的WebSocket实例，指定服务器的WebSocket端点，然后监听`open`、`message`、`close`事件。 6. **部署和测试**： 将Java项目打包成WAR文件，部署到支持WebSocket的服务器（如...
Java WebSocket是一种基于RFC 6455标准的通信协议，它允许在客户端和服务器之间建立持久的、全双工的连接。WebSocket协议弥补了HTTP协议的不足，为实时交互应用提供了高效的数据传输方式。在本项目中，"TooTallNate-...
springboot + websocket 实例： 实时读取日志升级版（追加消息广播，清空日志通知重新连接）