当前位置: 首页 > news >正文

Springboot 集成websocket

webSocket是基于TCP的一种新的网络协议。它实现了浏览器与服务器全双工通信--浏览器和服务器只需要完成一次握手,两者之间就可以创建持久性的连接,并进行双向数据传输。

http协议和websocket协议对比

http是短连接

websocket是长连接

http通信是单向的,基于请求响应模式

websocket支持双向通信

http和websocket底层都是tcp连接

介绍

英语场景

视频弹幕 页面并没有刷新,但是弹幕源源不断

网页聊天

体育实况更新

第一步:导入依赖

打开你的Spring Boot项目,你需要在 pom.xml  文件中引入WebSocket相关的依赖。

<dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-websocket</artifactId></dependency>
</dependencies>

第二步:配置WebSocket

Spring Boot 自带了对WebSocket的支持,你不需要太多手动配置,但如果需要自定义端点或者配置其他细节,可以创建一个配置类。

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {@Overridepublic void configureMessageBroker(MessageBrokerRegistry config) {// 配置消息代理,这里指定了"/app"前缀的频道将由控制器处理config.enableSimpleBroker("/topic");// "/app"前缀的消息将转发到带有@MessageMapping的方法config.setApplicationDestinationPrefixes("/app");}@Overridepublic void registerStompEndpoints(StompEndpointRegistry registry) {// 注册WebSocket的入口点,并启用SockJS以兼容更多浏览器registry.addEndpoint("/ws").withSockJS();}
}

第三步:编写WebSocket Server端

创建一个WebSocket的消息处理器类,该类里包含的方法会处理客户端发来的消息和广播消息。

@Controller
public class MyWebSocketController {@MessageMapping("/chat")@SendTo("/topic/messages")public ChatMessage sendMessage(ChatMessage message) throws Exception {// 这里可以处理消息,例如保存到数据库、转换格式等// 然后返回一个消息对象,它会被发送到所有订阅了/topic/messages频道的客户端return new ChatMessage(message.getFrom(), message.getText(), LocalDateTime.now());}
}

第四步:客户端连接与消息发送接收

在客户端(通常是HTML+JavaScript页面),使用WebSocket库如SockJS和StompJS来连接到WebSocket服务器并发送和接收消息。

<script src="https://cdn.jsdelivr.net/npm/sockjs-client@1/dist/sockjs.min.js"></script>
<script src="https://cdn.jsdelivr.net/npm/stompjs@2.3.3/dist/stomp.min.js"></script><script>var socket = new SockJS('/ws');var stompClient = Stomp.over(socket);stompClient.connect({}, function(frame) {console.log('Connected: ' + frame);stompClient.subscribe('/topic/messages', function(messageOutput) {// 接收服务器推过来的消息并显示在页面上var message = JSON.parse(messageOutput.body);displayChatMessage(message);});// 发送消息到服务器$('#sendMessage').click(function () {var from = $('#from').val();var text = $('#text').val();stompClient.send("/app/chat", {}, JSON.stringify({from: from, text: text}));});});
</script>

以上就是一个非常基础的Spring Boot集成WebSocket的教程,涵盖了从服务器端配置到客户端消息处理的基本流程。实际应用中,你可能还需要处理更多的细节,比如用户身份验证、断线重连等。

http://www.lryc.cn/news/336318.html

相关文章:

  • FPGA和ARM学习那个比较好
  • 你知道 Java 线程池的原理吗?
  • numpy学习笔记(1),不定期更新
  • 如何使用静态IP代理解决Facebook多账号注册并进行网络推广业务?
  • 局部适配器在产品和二次开发中的应用
  • C++之类和对象(上)
  • Linux 测试磁盘读写速度
  • 【YOLOv8】Yolov5和Yolov8网络结构的分析与对比
  • 无人机低空数字摄影测量系统
  • Disk Drill Enterprise for Mac v5.5.1515数据恢复软件中文版
  • day55 最长递增子序列 最长连续递增子序列 最长重复子数组
  • 使用Springboot配置生产者、消费者RabbitMQ?
  • 代码随想录算法训练营第46天|139.单词拆分、多重背包问题
  • 数组与伪数组的区别
  • Java集合List
  • elasticsearch基础命令
  • Capture One 23 Enterprise for Mac中文版 全面的图像处理工具
  • Qt案例 通过调用Setupapi.h库实现对设备管理器中设备默认驱动的备份
  • 如何理解JVM
  • 第十四讲:C语言字符函数和字符串函数
  • 华为海思2024春招数字芯片岗机试题(共9套)
  • 分类预测 | Matlab实现KPCA-IDBO-LSSVM基于核主成分分析和改进蜣螂优化算法优化最小二乘支持向量机分类预测
  • 与机器对话:ChatGPT 和 AI 语言模型的奇妙故事
  • 概率论基础——拉格朗日乘数法
  • [xboard]real6410-6.2 移植kernel网络驱动
  • Quarkus初探
  • 90天玩转Python-02-基础知识篇:初识Python与PyCharm
  • List操作的一些常见问题
  • 如何使用Java和RabbitMQ实现延迟队列?
  • AI论文速读 | TF-LLM:基于大语言模型可解释性的交通预测