Spring boot 结合websocket实现聊天功能
时间: 2024-03-15 17:36:23 浏览: 13
1. 添加依赖
首先，在 `pom.xml` 文件中添加 `spring-boot-starter-websocket` 依赖：
```
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-websocket</artifactId>
</dependency>
```
2. 配置WebSocket
在 `Application` 类中，添加 `@EnableWebSocket` 注解开启WebSocket支持，并实现 `WebSocketConfigurer` 接口：
```
@SpringBootApplication
@EnableWebSocket
public class Application implements WebSocketConfigurer {
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
@Override
public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
registry.addHandler(new WebSocketHandler(), "/chat").setAllowedOrigins("*");
}
}
```
这里创建了一个名为 `chat` 的WebSocket处理器，并指定允许所有来源的连接。
3. 编写WebSocketHandler
创建 `WebSocketHandler` 类，并实现 `WebSocketHandler` 接口：
```
public class WebSocketHandler implements org.springframework.web.socket.WebSocketHandler {
private static final Logger logger = LoggerFactory.getLogger(WebSocketHandler.class);
private final List<WebSocketSession> sessions = new CopyOnWriteArrayList<>();
@Override
public void afterConnectionEstablished(WebSocketSession session) throws Exception {
logger.info("New session connected: " + session.getId());
sessions.add(session);
}
@Override
public void handleMessage(WebSocketSession session, WebSocketMessage<?> message) throws Exception {
logger.info("Received message: " + message.getPayload());
for (WebSocketSession s : sessions) {
s.sendMessage(message);
}
}
@Override
public void handleTransportError(WebSocketSession session, Throwable exception) throws Exception {
logger.error("Error in transport", exception);
}
@Override
public void afterConnectionClosed(WebSocketSession session, CloseStatus closeStatus) throws Exception {
logger.info("Session closed: " + session.getId());
sessions.remove(session);
}
@Override
public boolean supportsPartialMessages() {
return false;
}
}
```
这里定义了一个静态的 `sessions` 列表，用于保存所有连接的WebSocket会话。在 `afterConnectionEstablished` 方法中，将新建立的会话添加到 `sessions` 列表中。在 `handleMessage` 方法中，遍历所有WebSocket会话，将接收到的消息发送给所有客户端。
4. 编写前端页面
在 `resources/static` 目录下创建一个 `index.html` 文件，用于展示聊天室页面，并实现WebSocket的连接和发送消息功能：
```
<!DOCTYPE html>
<html>
<head>
<meta charset="UTF-8">
<title>WebSocket Chat</title>
<script src="https://code.jquery.com/jquery-3.5.1.min.js"></script>
<script>
var ws;
function connect() {
var username = $("#username").val();
if (!username) {
alert("Please enter your username!");
return;
}
ws = new WebSocket("ws://" + location.host + "/chat");
ws.onopen = function(event) {
console.log("WebSocket opened: " + event);
ws.send(username + " joined the chat.");
};
ws.onmessage = function(event) {
console.log("WebSocket message received: " + event.data);
$("#messages").append($("<li>").text(event.data));
};
ws.onerror = function(event) {
console.error("WebSocket error: " + event);
};
ws.onclose = function(event) {
console.log("WebSocket closed: " + event);
$("#messages").append($("<li>").text("WebSocket connection closed."));
};
}
function send() {
var message = $("#message").val();
if (!message) {
alert("Please enter your message!");
return;
}
ws.send($("#username").val() + ": " + message);
$("#message").val("");
}
</script>
</head>
<body>
<h1>WebSocket Chat</h1>
<div>
<label>Username:</label>
<input type="text" id="username">
<button onclick="connect()">Connect</button>
</div>
<div>
<label>Message:</label>
<input type="text" id="message">
<button onclick="send()">Send</button>
</div>
<ul id="messages"></ul>
</body>
</html>
```
在页面加载时，通过 `WebSocket` 构造函数创建一个WebSocket对象，并指定连接的URL。在连接建立后，通过 `send` 方法向服务器发送消息。在接收到消息时，在页面上显示消息内容。
5. 启动应用
最后，运行 `Application` 类的 `main` 方法启动应用。访问 `http://localhost:8080`，即可进入聊天室页面。输入用户名后点击 `Connect` 按钮连接WebSocket服务器，即可开始聊天。
相关推荐
最新推荐
SpringBoot webSocket实现发送广播、点对点消息和Android接收
主要介绍了SpringBoot webSocket实现发送广播、点对点消息和Android接收,具有一定的参考价值，感兴趣的小伙伴们可以参考一下。
06_QLibrary.zip
06_QLibrary.zip
毕业设计: 基于Densenet + CTC技术的文字检测识别的技术研究
本毕设课题是属于计算机视觉下的目标检测与识别，对象为自然场景下的各种文本信息，通俗的说就是检测识别图片中的文本信息。由于文本的特殊性，本毕设将整个提取信息的过程可以分为检测、识别两个部分。
论文对用到的相关技术概念有一定的介绍分析，如机器学习，深度学习，以及各种的网络模型及其工作原理过程。
检测部分采用水平检测文本线方式进行文本检测，主要参考了乔宇老师团队的 CTPN 方法，并在正文部分从模型的制作到神经网络的设计实现对系统进行了较为详细的分析介绍。
识别部分则采用的是 Densenet + CTC，对于印刷体的文字有较好的识别。
毕业设计 基于javaweb的在线答题平台
毕业设计 基于javaweb的在线答题平台
zigbee-cluster-library-specification
最新的zigbee-cluster-library-specification说明文档。
管理建模和仿真的文件
管理Boualem Benatallah引用此版本：布阿利姆·贝纳塔拉。管理建模和仿真。约瑟夫-傅立叶大学-格勒诺布尔第一大学，1996年。法语。NNT：电话：00345357HAL ID：电话：00345357https://theses.hal.science/tel-003453572008年12月9日提交HAL是一个多学科的开放存取档案馆，用于存放和传播科学研究论文，无论它们是否被公开。论文可以来自法国或国外的教学和研究机构，也可以来自公共或私人研究中心。L’archive ouverte pluridisciplinaire
实现实时数据湖架构：Kafka与Hive集成
# 1. 实时数据湖架构概述**
实时数据湖是一种现代数据管理架构，它允许企业以低延迟的方式收集、存储和处理大量数据。与传统数据仓库不同，实时数据湖不依赖于预先定义的模式，而是采用灵活的架构，可以处理各种数据类型和格式。这种架构为企业提供了以下优势：
- **实时洞察：**实时数据湖允许企业访问最新的数据，从而做出更明智的决策。
- **数据民主化：**实时数据湖使各种利益相关者都可
解答下列问题：S—＞S；T｜T；T—＞a 构造任意项目集规范族，构造LR（0）分析表，并分析a;a
对于这个文法，我们可以构造以下项目集规范族:
I0:
S -> .S
S -> .T
T -> .a
I1:
S -> S. [$
T -> T. [$
I2:
S -> T.
I3:
S -> S.;S
S -> S.;T
T -> T.;a
其中，点(.)表示已经被扫描过的符号，;$表示输入串的结束符号。
根据项目集规范族，我们可以构造出LR(0)分析表:
状态 | a | $
---- | - | -
I0 | s3|
I1 | |acc
I2 | |
其中s3表示移进到状态3，acc表示接受。在分析字符串a;a时，我们可以按照以下步骤进行
JSBSim Reference Manual
JSBSim参考手册，其中包含JSBSim简介，JSBSim配置文件xml的编写语法，编程手册以及一些应用实例等。其中有部分内容还没有写完，估计有生之年很难看到完整版了，但是内容还是很有参考价值的。
"互动学习：行动中的多样性与论文攻读经历"
多样性她- 事实上SCI NCES你的时间表ECOLEDO C Tora SC和NCESPOUR l’Ingén学习互动，互动学习以行动为中心的强化学习学会互动，互动学习，以行动为中心的强化学习计算机科学博士论文于2021年9月28日在Villeneuve d'Asq公开支持马修·瑟林评审团主席法布里斯·勒菲弗尔阿维尼翁大学教授论文指导奥利维尔·皮耶昆谷歌研究教授：智囊团论文联合主任菲利普·普雷教授，大学。里尔/CRISTAL/因里亚报告员奥利维耶·西格德索邦大学报告员卢多维奇·德诺耶教授，Facebook /索邦大学审查员越南圣迈IMT Atlantic高级讲师邀请弗洛里安·斯特鲁布博士，Deepmind对于那些及时看到自己错误的人...3谢谢你首先，我要感谢我的两位博士生导师Olivier和Philippe。奥利维尔，"站在巨人的肩膀上"这句话对你来说完全有意义了。从科学上讲，你知道在这篇论文的（许多）错误中，你是我可以依