一、准备工作
pom.xml引入
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-websocket</artifactId>
</dependency>
二、代码编写
创建名为WebSocketConfig的类
/**
* 开启websocket的支持
* @author lichao
* @date 2018-08-28
*
*/
@Configuration
public class WebSocketConfig {
@Bean
public ServerEndpointExporter serverEndpointExporter(){
return new ServerEndpointExporter();
}
}
创建名为WebSocketServer的类
@ServerEndpoint(value = "/websocket")
@Component // 此注解千万千万不要忘记，它的主要作用就是将这个监听器纳入到Spring容器中进行管理
public class WebSocketServer {
// 统计在线人数
private static int onlineCount = 0;
// 用本地线程保存session
private static ThreadLocal<Session> sessions = new ThreadLocal<Session>();
// 保存所有连接上的session
private static Map<String, Session> sessionMap = new ConcurrentHashMap<String, Session>();
public static synchronized int getOnlineCount() {
return onlineCount;
}
public static synchronized void addOnlineCount() {
onlineCount++;
}
public static synchronized void subOnlineCount() {
onlineCount--;
}
// 连接
@OnOpen
public void onOpen(Session session) {
sessions.set(session);
addOnlineCount();
sessionMap.put(session.getId(), session);
System.out.println("【" + session.getId() + "】连接上服务器======当前在线人数【" + getOnlineCount() + "】");
// 连接上后给客户端一个消息
sendMsg(session, "连接服务器成功！");
}
// 关闭
@OnClose
public void onClose(Session session) {
subOnlineCount();
sessionMap.remove(session.getId());
System.out.println("【" + session.getId() + "】退出了连接======当前在线人数【" + getOnlineCount() + "】");
}
// 接收消息 客户端发送过来的消息
@OnMessage
public void onMessage(String message, Session session) {
//message的格式可以包含sessionid, 格式[SID,内容XXX]：1,内容
System.out.println("【" + session.getId() + "】客户端的发送消息======内容【" + message + "】");
String[] split = message.split(",");
String sessionId = split[0];
Session ss = sessionMap.get(sessionId);
if (ss != null) {
String msgTo = "【" + session.getId() + "】发送给【您】的消息:\n【" + split[1] + "】";
String msgMe = "【我】发送消息给【" + ss.getId() + "】:\n" + split[1];
sendMsg(ss, msgTo);
sendMsg(session, msgMe);
} else {
for (Session s : sessionMap.values()) {
if (!s.getId().equals(session.getId())) {
sendMsg(s, "【" + session.getId() + "】发送给【您】的广播消息:\n【" + message + "】");
} else {
sendMsg(session, "【我】发送广播消息给大家\n" + message);
}
}
}
/*String sid = session.getId();
Session ss = sessionMap.get(sid);*/
}
// 异常
@OnError
public void onError(Session session, Throwable throwable) {
System.out.println("发生异常!");
throwable.printStackTrace();
}
// 统一的发送消息方法
public synchronized void sendMsg(Session session, String msg) {
try {
session.getBasicRemote().sendText(msg);
} catch (IOException e) {
e.printStackTrace();
}
}
}
创建前端页面
<!DOCTYPE HTML>
<html>
<head>
<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://192.168.1.78:8080/eboata-admin/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>
相关推荐
如何使用Postman来发送数据到后端Spring Boot应用程序，并使用WebSocket建立实时通信通道，以便后端应用程序可以向Postman推送消息。 学会这个方法，就能缩短你的项目开发周期，以及提高你的开发效率。如果提出您的...
总结起来，Spring Boot 结合 WebSocket 可以有效地实现服务端到客户端的消息推送，降低了网络资源的消耗，提升了实时性。通过配置和编写相应的端点服务类，我们可以方便地构建起一个稳定的 WebSocket 通信系统。
当Spring Boot与Netty结合使用时，可以创建出高效、稳定的实时消息推送系统。 在"Spring Boot 整合 Netty + WebSocket 实时消息推送"项目中，我们主要关注以下几个核心知识点： 1. **Spring Boot集成WebSocket**：...
本项目提供的源代码展示了如何利用消息队列（Message Queue）、Spring Boot框架以及WebSocket技术来实现一个实时的消息推送模型。以下是关于这些关键技术的详细说明： 1. **消息队列**：消息队列是一种中间件，用于...
本知识点将介绍如何在Spring Boot与Vue前后端分离架构中集成WebSocket，并实现带有身份认证的消息推送功能。这是实现即时通讯、实时数据更新等应用场景的常用技术方案。 ### 1. WebSocket简介 WebSocket是一种在...
WebSocket是一种在单个TCP连接上进行全双工通信的协议，允许服务器主动向客户端推送数据，非常适合实时交互应用。 **1. 配置Spring Boot支持WebSocket** 在Spring Boot项目中，我们需要引入`spring-boot-starter-...
2.SpringBoot如何集成websocket 3.SpringBoot中的定时任务调度 4.前后端分离项目的Cros跨域问题解决 阅读建议： 此资源以案例代入知识点的方式，让你快速上手websocket的相关学习，可针对项目本身向外扩展。
WebSocket集成使用WebSocket实现实时消息推送，支持全双工通信。 点对点消息推送支持向指定用户发送消息。 广播消息推送支持向所有在线用户发送消息。 在线用户管理实时统计和管理在线用户，提供在线用户列表。 ...
概要：本文介绍如何使用 Spring Boot 3.X 和 WebSocket 实现消息推送，并动态开启、关闭和取消定时任务。通过WebSocket实现实时通信，结合定时任务管理，可实现灵活的消息推送和任务控制。 使用人群：适合有Spring ...
Spring Boot提供了一种方便的方式来集成WebSocket，但其底层实现可能不够高效，这时Netty就派上用场了。 Netty是一个高性能、异步事件驱动的网络应用框架，适用于开发服务器和客户端。Netty以其优秀的性能、低内存...
通过WebSocket实现实时消息推送，确保用户之间的消息能够即时传递。 ## 项目的主要特性和功能 1. 用户管理 用户注册与登录 用户名修改 用户状态管理（在线离线） 2. 聊天功能 实时消息发送与接收 群聊与私聊...
本项目是一个基于Spring Boot框架的WebSocket消息推送系统，旨在实现客户端与服务器之间的实时双向通信。通过WebSocket协议，服务器可以主动向客户端推送消息，避免了传统轮询方式的资源浪费，提高了通信效率。 ## ...
本项目基于Spring平台，整合websocket协议，实现一个简易web聊天室的功能。主要特性如下: 1.包含聊天室登录、退出的功能。登录时，浏览器自动向服务器发起websocket连接，退出时自动切断。登录页面为...
- 将WebSocket与Drools集成，例如，在接收到特定消息后，通过DroolsService执行规则判断，根据结果决定是否触发WebSocket推送。 - 如果Drools规则判断的结果需要更新前端数据，可以将结果封装为消息并发送给前端。...
通过WebSocket实现实时日志推送和状态更新，确保管理员能够及时获取系统运行状态和操作结果。 ## 项目的主要特性和功能 1. FTP服务管理 支持FTP服务的部署、启动、停止和重启操作。 提供服务参数配置，如服务ID...
通过以上步骤，我们可以利用“spring-boot-starter-websocket.zip”中的内容搭建起一个完整的站内信系统，实现实时的消息推送功能。这个压缩包提供的起步依赖简化了WebSocket在Spring Boot中的集成工作，让开发者...
本教程将详细介绍如何利用Spring Boot集成WebSocket，实现消息的主动推送，包括一对一的消息传递和广播给所有在线用户。 首先，我们需要在Spring Boot项目中添加WebSocket相关的依赖。在`pom.xml`文件中，引入`...
通过WebSocket技术，实现了消息的实时推送和接收，确保用户能够及时收到消息。 ## 项目的主要特性和功能 1. 用户管理 用户登录、注册功能。 用户个人信息查看和编辑。 根据用户ID查找其他用户信息。 2. 好友...
如何使用Postman来发送数据到后端Spring Boot应用程序，并使用WebSocket建立实时通信通道，以便后端应用程序可以向Postman推送消息，并可动态开启、关闭和取消定时任务。 学会这个方法，就能缩短你的项目开发周期，...
1. 实时消息推送通过WebSocket实现用户之间的实时消息推送，确保消息的即时性和可靠性。 2. 文件传输支持用户之间的文件传输，包括图片、文档等多种格式。 3. 数据同步提供数据同步功能，确保多设备之间的数据一致性...