使用spring boot 写一个 websocket代码
时间: 2023-11-20 14:03:15 浏览: 38
好的，下面是一个使用 Spring Boot 实现 WebSocket 的示例代码：
首先，需要在 pom.xml 中添加 WebSocket 和 Spring WebSocket 的依赖：
```xml
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-websocket</artifactId>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-messaging</artifactId>
</dependency>
</dependencies>
```
然后，创建一个 WebSocket 配置类，用于配置 WebSocket 相关的参数：
```java
@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {
@Override
public void configureMessageBroker(MessageBrokerRegistry config) {
config.enableSimpleBroker("/topic");
config.setApplicationDestinationPrefixes("/app");
}
@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
registry.addEndpoint("/websocket").withSockJS();
}
}
```
上面的代码中，`configureMessageBroker()` 方法用于配置消息代理（Message Broker），这里使用的是 SimpleBroker，它会将消息广播给所有订阅了特定主题（Topic）的客户端。`setApplicationDestinationPrefixes()` 方法用于设置应用程序前缀，这里设置的是 `/app`，表示客户端发送的消息会以 `/app` 开头。`registerStompEndpoints()` 方法用于注册一个 WebSocket 端点，客户端可以通过这个端点进行连接。
接下来，创建一个 WebSocket 控制器，用于处理客户端的连接和消息：
```java
@Controller
public class WebSocketController {
@MessageMapping("/hello")
@SendTo("/topic/greetings")
public String greeting(String message) throws Exception {
Thread.sleep(1000); // simulated delay
return "Hello, " + message + "!";
}
}
```
上面的代码中，`@MessageMapping("/hello")` 注解表示处理客户端发送到 `/app/hello` 的消息，`@SendTo("/topic/greetings")` 注解表示将处理结果发送到 `/topic/greetings` 主题。在这个示例中，服务器会将客户端发送的消息返回，并在消息前加上 "Hello, "，最终发送到 `/topic/greetings` 主题。
最后，创建一个 HTML 页面，用于与 WebSocket 进行交互：
```html
<!DOCTYPE html>
<html>
<head>
<title>WebSocket Example</title>
<script src="/webjars/jquery/jquery.min.js"></script>
<script src="/webjars/sockjs-client/sockjs.min.js"></script>
<script src="/webjars/stomp-websocket/stomp.min.js"></script>
<script>
$(function () {
var socket = new SockJS('/websocket');
var stompClient = Stomp.over(socket);
stompClient.connect({}, function (frame) {
console.log('Connected: ' + frame);
stompClient.subscribe('/topic/greetings', function (greeting) {
$('#greetings').append('<tr><td>' + JSON.parse(greeting.body) + '</td></tr>');
});
});
$('form').on('submit', function (e) {
e.preventDefault();
var message = $('#message').val();
stompClient.send('/app/hello', {}, message);
$('#message').val('');
});
});
</script>
</head>
<body>
<form>
<input type="text" id="message" />
<button>Send</button>
</form>
<table>
<thead>
<tr><th>Greetings</th></tr>
</thead>
<tbody id="greetings"></tbody>
</table>
</body>
</html>
```
上面的代码中，通过 SockJS 和 STOMP 连接到 WebSocket 端点，使用 `subscribe()` 方法订阅 `/topic/greetings` 主题，使用 `send()` 方法发送消息。当服务器向 `/topic/greetings` 主题发送消息时，会在页面上添加一条记录。
至此，一个简单的 Spring Boot WebSocket 示例就完成了。
相关推荐
最新推荐
SpringBoot webSocket实现发送广播、点对点消息和Android接收
主要介绍了SpringBoot webSocket实现发送广播、点对点消息和Android接收,具有一定的参考价值，感兴趣的小伙伴们可以参考一下。
Scrapy-1.8.2.tar.gz
文件操作、数据分析和网络编程等。Python社区提供了大量的第三方库，如NumPy、Pandas和Requests，极大地丰富了Python的应用领域，从数据科学到Web开发。Python库的丰富性是Python成为最受欢迎的编程语言之一的关键原因之一。这些库不仅为初学者提供了快速入门的途径，而且为经验丰富的开发者提供了强大的工具，以高效率、高质量地完成复杂任务。例如，Matplotlib和Seaborn库在数据可视化领域内非常受欢迎，它们提供了广泛的工具和技术，可以创建高度定制化的图表和图形，帮助数据科学家和分析师在数据探索和结果展示中更有效地传达信息。
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. 实时数据湖架构概述**
实时数据湖是一种现代数据管理架构，它允许企业以低延迟的方式收集、存储和处理大量数据。与传统数据仓库不同，实时数据湖不依赖于预先定义的模式，而是采用灵活的架构，可以处理各种数据类型和格式。这种架构为企业提供了以下优势：
- **实时洞察：**实时数据湖允许企业访问最新的数据，从而做出更明智的决策。
- **数据民主化：**实时数据湖使各种利益相关者都可
2． 通过python绘制y=e-xsin(2πx)图像
可以使用matplotlib库来绘制这个函数的图像。以下是一段示例代码：
```python
import numpy as np
import matplotlib.pyplot as plt
def func(x):
return np.exp(-x) * np.sin(2 * np.pi * x)
x = np.linspace(0, 5, 500)
y = func(x)
plt.plot(x, y)
plt.xlabel('x')
plt.ylabel('y')
plt.title('y = e^{-x} sin(2πx)')
plt.show()
```
运行这段
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。奥利维尔，"站在巨人的肩膀上"这句话对你来说完全有意义了。从科学上讲，你知道在这篇论文的（许多）错误中，你是我可以依
实现实时监控告警系统：Kafka与Grafana整合
# 1.1 Kafka集群架构
Kafka集群由多个称为代理的服务器组成，这
导入numpy库，创建两个包含9个随机数的3*3的矩阵，将两个矩阵分别打印出来，计算两个数组的点积并打印出来。（random.randn()、dot（）函数）
可以的，以下是代码实现：
```python
import numpy as np
# 创建两个包含9个随机数的3*3的矩阵
matrix1 = np.random.randn(3, 3)
matrix2 = np.random.randn(3, 3)
# 打印两个矩阵
print("Matrix 1:\n", matrix1)
print("Matrix 2:\n", matrix2)
# 计算两个数组的点积并打印出来
dot_product = np.dot(matrix1, matrix2)
print("Dot product:\n", dot_product)
```
希望