SpringBoot使用WebSocket实现前后端交互的操作方法
作者:heaven096 时间:2022-07-06 12:34:35
背景
我们都知道http协议只能在浏览器单方面向服务器发起请求时获得响应,然而服务器不能主动向浏览器推送消息,想要实现浏览器的主动推送目前有两种主流的实现方式:
轮询:缺点很多,但是实现简单
websocket: 在浏览器和服务器之间建立TCP连接,实现全双工通信
springboot使用websocket有两种方式,一种是实现简单的websocket,另外一种是实现STOMP协议。本篇讲述如何使用springboot实现简单的websocket。
实现
一、导入依赖
直接在pom.xml
中导入依赖。
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-websocket</artifactId>
</dependency>
二、新建WebSocket配置类,注入Bean
首先注入一个ServerEndpointExporterBean,该Bean会自动注册使用@ServerEndpoint注解申请的websocket endpoint,代码如下:
@Component
public class WebSocketConfig {
@Bean
public ServerEndpointExporter serverEndpointExporter(){
return new ServerEndpointExporter();
}
}
三、新建WebSocket服务端,在其中处理websocket逻辑
@Component //注册到容器中
@ServerEndpoint("/webSocket") //接收websocket请求路径
@Slf4j
public class WebSocket {
//当前连接(每个websocket连入都会创建一个WebSocket实例)
private Session session;
//定义一个websocket容器存储session,即存放所有在线的socket连接
private static CopyOnWriteArraySet<WebSocket> webSocketSet = new CopyOnWriteArraySet<>();
//处理连接建立
@OnOpen
public void opOpen(Session session){
this.session = session;
log.info("【有新的客户端连接了】:{}",session.getId());
webSocketSet.add(this); //将新用户加入在线组
log.info("【websocket消息】有新的连接,总数:{}",webSocketSet.size());
}
//处理连接关闭
@OnClose
public void Onclose(){
webSocketSet.remove(this);
log.info("【websocket消息】连接断开,总数:{}",webSocketSet.size());
//接受消息
@OnMessage
public void onMessage(String message){
log.info("【websocket消息】收到客户端发来的消息:{}",message);
// 群发消息
public void sendMessage(String message) {
for (WebSocket webSocket : webSocketSet) {
log.info("【websocket消息】广播群发消息,message={}",message);
try {
webSocket.session.getBasicRemote().sendText(message);
}catch (Exception e){
e.printStackTrace();
}
}
}
四、客户端实现,可以借助FreeMarker模板工具直接写在ftl文件里。
由于部分浏览器可能不支持,可以先测试,代码如下:
<script>
var websocket = null;
if('WebSocket' in window){
websocket = new WebSocket('ws://localhost:8080/webSocket');
}else{
alert('当前浏览器不支持websocket消息通知');
}
//连接成功建立的回调方法
websocket.onopen = function (event) {
console.log("ws建立连接成功");
//连接关闭的回调方法
websocket.onclose = function (event) {
console.log("ws连接关闭");
//接收到消息的回调方法
websocket.onmessage = function (event) {
/*setMessageInnerHTML(event.data);*/
// alert("ws接收返回消息:"+event.data);
console.log("服务器返回消息: " + event.data);
//弹窗提醒(要用到JQuary,所以要先引入JQuary) 播放音乐
$('#mymodal').modal('show')
//连接发生错误的回调方法
websocket.onerror = function(event){
alert('websocket通信发生错误!')
//监听窗口关闭事件,当窗口关闭时,主动去关闭websocket连接,防止连接还没断开就关闭窗口,server端会抛异常。
window.onbeforeunload = function() {
websocket.close();
</script>
五、测试
(项目实现客户创建新订单之后,前台发出提醒)
@Autowired
private WebSocket webSocket;
@Override
@Transactional
public OrderDTO create(OrderDTO orderDTO) {//创建订单
。。。。(具体代码省略)
//创建新订单 发送websocket消息
webSocket.sendMessage(orderDTO.getOrderId());
return orderDTO;
}
添加新订单:
接收到websocket消息
来源:https://www.cnblogs.com/xiaozhengtongxue/p/13448778.html
标签:SpringBoot,WebSocket,前后端交互
0
投稿
猜你喜欢
C#词法分析器之正则表达式的使用
2023-06-21 13:10:58
java生成图片验证码实例代码
2022-01-06 04:01:37
Java中如何避免sql注入实例详解
2022-08-24 14:42:06
一文带你了解SpringBoot的启动原理
2023-11-28 20:44:42
Java使用fill()数组填充的实现
2022-02-06 15:03:33
Java拦截器Interceptor实现原理及代码示例
2023-11-04 03:49:32
Flutter使用sqflite处理数据表变更的方法详解
2023-10-21 11:05:49
Java8方法引用及构造方法引用原理实例解析
2022-07-24 08:21:22
java实现动态 代理方法浅析
2023-11-28 23:33:59
Java 发送http请求(get、post)的示例
2022-02-15 12:20:56
Java 详解循环屏障CyclicBarrier如何实现多线程分段等待执行完成
2022-02-16 04:50:49
Spring Cloud Gateway网关XSS过滤方式
2021-08-07 13:16:53
Spring之spring-context-indexer依赖详解
2023-11-23 12:21:41
java实战之飞机大战小游戏(源码加注释)
2021-08-01 17:46:08
Java多个版本切换的几种方法
2022-04-22 14:10:15
Spring Boot如何通过CORS处理跨域问题
2021-09-10 02:44:15
Spring boot2X负载均衡和反向代理实现过程解析
2023-02-06 04:18:53
SpringCloud如何使用Eureka实现服务之间的传递数据
2022-02-17 18:47:37
c#实现爬虫程序
2023-04-19 18:59:14
SpringBoot AOP使用笔记
2023-12-09 13:25:50