这次给大家说一下自己对websocket + spring boot结合使用的一些经验
首先websocket是一个持久化的协议，实现了浏览器与服务器的全双工通信。不再像http那样，只有在浏览器发出request之后才有response，websocket能实现服务器主动向浏览器发出消息。
下面我们用spring boot来实现一下：
在spring boot的文档中，介绍了我们需要配置的文件
// pom.xml
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-websocket</artifactId>
</dependency>
之后我们需要添加一个单例bean，名为ServerEndpointExporter
@Configuration
public class WebSocketConfig {
@Bean
public ServerEndpointExporter serverEndpointExporter (){
return new ServerEndpointExporter();
}
}
接下来便能使用websocket了，下面是一个简单的例子：
@ServerEndpoint("/websocket")
@Component
public class MyWebSocket {
private static int onlineCount = 0;
private static CopyOnWriteArraySet<MyWebSocket> webSocketSet = new CopyOnWriteArraySet<>();
private Session session;
@OnOpen
public void onOpen (Session session){
this.session = session;
webSocketSet.add(this);
addOnlineCount();
System.out.println("有新链接加入!当前在线人数为" + getOnlineCount());
}
@OnClose
public void onClose (){
webSocketSet.remove(this);
subOnlineCount();
System.out.println("有一链接关闭!当前在线人数为" + getOnlineCount());
}
@OnMessage
public void onMessage (String message, Session session) throws IOException {
System.out.println("来自客户端的消息:" + message);
// 群发消息
for ( MyWebSocket item : webSocketSet ){
item.sendMessage(message);
}
}
public void sendMessage (String message) throws IOException {
this.session.getBasicRemote().sendText(message);
}
public static synchronized int getOnlineCount (){
return MyWebSocket.onlineCount;
}
public static synchronized void addOnlineCount (){
MyWebSocket.onlineCount++;
}
public static synchronized void subOnlineCount (){
MyWebSocket.onlineCount--;
}
}
代码很简单，相信大家都能看懂，接下来贴一下html代码：
<!DOCTYPE HTML>
<html>
<head>
<base href="localhost://localhost:8080/">
<title>My WebSocket</title>
</head>
<body>
Welcome<br/>
<input id="text" type="text"/>
<button onclick="send()">Send</button>
<button onclick="closeWebSocket()">Close</button>
<div id="message">
</div>
</body>
<script type="text/javascript">
var websocket = null;
//判断当前浏览器是否支持WebSocket
if ('WebSocket' in window) {
websocket = new WebSocket("ws://localhost:8080/websocket");
}
else {
alert('Not support websocket')
}
//连接发生错误的回调方法
websocket.onerror = function () {
setMessageInnerHTML("error");
};
//连接成功建立的回调方法
websocket.onopen = function (event) {
setMessageInnerHTML("open");
}
//接收到消息的回调方法
websocket.onmessage = function (event) {
setMessageInnerHTML(event.data);
}
//连接关闭的回调方法
websocket.onclose = function () {
setMessageInnerHTML("close");
}
//监听窗口关闭事件，当窗口关闭时，主动去关闭websocket连接，防止连接还没断开就关闭窗口，server端会抛异常。
window.onbeforeunload = function () {
websocket.close();
}
//将消息显示在网页上
function setMessageInnerHTML(innerHTML) {
document.getElementById('message').innerHTML += innerHTML + '<br/>';
}
//关闭连接
function closeWebSocket() {
websocket.close();
}
//发送消息
function send() {
var message = document.getElementById('text').value;
websocket.send(message);
}
</script>
</html>
接下来便能直接启动websocket进行访问了，具体的扩展可以根据你的业务需求进行增加。
其实websocket就是基于http协议的升级，在http的headers中有一个header名为Upgrade，用来对http协议进行升级，从而换用其他的协议，在本例中，为Upgrade:websocket
分享到：
相关推荐
一个基于Spring Boot + WebSocket + Redis，可快速开发的分布式即时通讯群聊系统。适用于直播间聊天、游戏内聊天、客服聊天等临时性群聊场景。 Java开发基于SpringBoot+WebSocket+Redis分布式即时通讯群聊系统。一...
vue前端后端分离spring boot 2.0集成websocket，带身份认证实现消息推送功能
如何使用Postman来发送数据到后端Spring Boot应用程序，并使用WebSocket建立实时通信通道，以便后端应用程序可以向Postman推送消息。 学会这个方法，就能缩短你的项目开发周期，以及提高你的开发效率。如果提出您的...
1、基于Spring Boot 实现的WebSocket实时数据通信Demo 2、结合Netty实现多客户端之间进行网络通信 3、在Web端建立多客户端之间的通信机制
spring boot 和 netty 构建长连接通信，通过spring boot 来处理前段请求
Spring Boot整合websocket实现群聊，音频发送，点对点聊天,图片发送。 Spring Boot整合websocket实现群聊，点对点聊天,图片发送，音频发送。 Spring Boot整合websocket实现群聊，点对点聊天,图片发送，音频发送 ...
基于Vue+SpringBoot+WebSocket实现Web端聊天系统+网络通信+心跳+客户端服务端+后端java+mysql 项目经过严格测试，确保可以运行！ 下载代码后，先配置好yml文件：数据库和微信号appid、secret（other包下面有数据库）...
Spring boot整合websocket实现即时通讯。传统的HTTP协议，一般通过向服务器发送请求，拉取数据实现半双工通信，缺点是服务器难以直接向浏览器下发消息，因此，websocket协议应运而生，可用于向建立连接的浏览器主动...
基于spring boot 实现的 websocket 通信。
如何使用Postman来发送数据到后端Spring Boot应用程序，并使用WebSocket建立实时通信通道，以便后端应用程序可以向Postman推送消息，并可动态开启、关闭和取消定时任务。 学会这个方法，就能缩短你的项目开发周期，...
如何使用Postman来执行连接后端Spring Boot应用程序内WebSocket的命令，并使用WebSocket建立实时通信通道，以实现电脑系统数据实时刷新。 学会这个方法，就能缩短你的项目开发周期，以及提高你的开发效率。如果提出...
后端采用Springboot框架，前端layui界面，前端和后端聊天基于websocket通信！ 注意，目前这个项目没实现注册功能，用户账号和密码都在user表，如果注册添加用户之间打开mysql数据库表操作即可 实现了用户的登录，...
本篇文章主要介绍了使用 Spring Boot 实现 WebSocket实时通信，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
如何使用Postman来发送数据到后端Spring Boot应用程序，并使用WebSocket建立实时通信通道，以便后端应用程序可以向Postman推送消息。 学会这个方法，就能缩短你的项目开发周期，以及提高你的开发效率。如果提出您的...
如何使用Postman来发送数据到后端Spring Boot应用程序，并使用WebSocket建立实时通信通道，以便后端应用程序可以向Postman推送消息，并可动态开启、关闭和取消定时任务。 学会这个方法，就能缩短你的项目开发周期，...
## 后端采用Springboot框架，前端layui界面，前端和后端聊天基于websocket通信！ 注意，目前这个项目没实现注册功能，用户账号和密码都在user表，如果注册添加用户之间打开mysql数据库表操作即可 ## 实现了用户的...
SpringBoot整合WebSocket+nacos注册中心实现多服务通信
Spring Boot Websocket示例 在我们当前的项目中，我们想要添加一个使用websocket将消息推送到我们的移动应用程序的服务。 虽然上的文档在实现由简单Web应用程序非常出色，但是的与简短的入门指南并不十分吻合。 由于...
WebSocket是一种在单个TCP连接上进行全双工通信的协议。这是一种比较官方的说法，简单点来说就是，在一次TCP连接中，通信的双方可以相互通信。这篇文章主要介绍了SpringBoot+WebSocket搭建简单的多人聊天系统,需要的...
spring boot 2.0 websocket stomp 实现广播通信和一对一通信聊天