onopen 打开之后为什么发送一次消息后会触发onclose

时间: 2024-02-06 16:03:17 浏览: 205

SpringMVC整合websocket实现消息推送及触发功能

SpringMVC整合websocket实现消息推送及触发功能 SpringMVC是一种流行的基于Java的Web应用程序框架，而websocket是一种实时通信协议，用于实现实时的双向通信。本文将详细介绍如何使用SpringMVC与websocket实现消息推送及触发功能。 HandShake的实现在实现websocket握手协议时，我们需要创建一个HandShake类，继承自HandshakeInterceptor接口。HandShake类的主要作用是拦截websocket握手请求，并将必要的信息传递给websocket handler。在beforeHandshake方法中，我们可以获取到客户端传递的参数，并将其存储在attributes中。在本例中，我们获取了jspCode参数，并将其存储在attributes中。 ```java public class HandShake implements HandshakeInterceptor{ @Override public boolean beforeHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler wsHandler, Map<String, Object> attributes) throws Exception { String jspCode = ((ServletServerHttpRequest) request).getServletRequest().getParameter("jspCode"); if(jspCode!=null){ attributes.put("jspCode", jspCode); }else{ return false; } return true; } @Override public void afterHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler wsHandler, Exception exception) { // TODO Auto-generated method stub } } ``` MyWebSocketConfig的实现在实现websocket配置时，我们需要创建一个MyWebSocketConfig类，用于配置websocket的相关参数。在本例中，我们使用了Spring的注解式配置，使用@Resource注解将websocket handler注入到配置类中。 ```java package com.yun.websocket; import javax.annotation.Resource; import org.springframework.context.annotation.Configuration; import org.springframework.web.socket.config.annotation.EnableWebSocket; import org.springframework.web.socket.config.annotation.WebSocketConfigurer; import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry; @Configuration @EnableWebSocket public class MyWebSocketConfig implements WebSocketConfigurer { @Resource private MyWebSocketHandler myWebSocketHandler; @Override public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) { registry.addHandler(myWebSocketHandler, "/websocket").setAllowedOrigins("*"); } } ``` 消息推送及触发功能在实现消息推送及触发功能时，我们需要使用websocket handler来处理客户端的连接请求。我们可以在MyWebSocketHandler类中实现onOpen、onMessage、onClose等方法，以处理客户端的连接、消息推送和连接关闭事件。 ```java package com.yun.websocket; import org.springframework.web.socket.CloseStatus; import org.springframework.web.socket.TextMessage; import org.springframework.web.socket.WebSocketHandler; import org.springframework.web.socket.WebSocketSession; import org.springframework.web.socket.handler.TextWebSocketHandler; public class MyWebSocketHandler extends TextWebSocketHandler { @Override protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception { // 处理客户端推送的消息 } @Override public void afterConnectionEstablished(WebSocketSession session) throws Exception { // 客户端连接成功后处理逻辑 } @Override public void afterConnectionClosed(WebSocketSession session, CloseStatus status) throws Exception { // 客户端连接关闭后处理逻辑 } } ``` 小结本文详细介绍了如何使用SpringMVC与websocket实现消息推送及触发功能。我们创建了HandShake类，用于拦截websocket握手请求，并将必要的信息传递给websocket handler。然后，我们创建了MyWebSocketConfig类，用于配置websocket的相关参数。我们实现了MyWebSocketHandler类，用于处理客户端的连接请求和消息推送事件。

通常情况下，当WebSocket连接成功建立并发送一条消息后，onclose事件不应该被触发。可能有以下几种情况导致onclose事件被触发： 1. 服务器端关闭了WebSocket连接，这时候onclose事件会被触发。 2. 在发送消息时，发生了错误，导致WebSocket连接自动关闭，这时候同样会触发onclose事件。 3. 在发送消息后，客户端主动关闭了WebSocket连接，这时候onclose事件也会被触发。需要进一步分析你的代码和网络环境才能确定具体原因。

阅读全文

onopen 打开之后为什么发送一次消息后会触发onclose

相关推荐

vue项目消息链接全局创建监听

使用webSocket简单实现群发消息和指定用户发送消息

spring集成webSocket发送及时消息

AndroidContext:Appcelerator Titanium js 库在 Android 上触发 pausedresumed 事件

android SlidingMenuDemo 侧边栏 滑动打开

socketTask.onOpen(res => {})、socketTask.onMessage(res => {})、socketTask.onClose(res => {}) 有什么区别 都怎么用

socket.onclose 后重连

websocket怎么发送消息

webScoket.js发送消息

java 实现 websocket 定时发送消息

java实现websocket客户端发送消息

java如何触发OBS软件的动作？

使用Undertow实现WebSocket前后端消息推送

libhv WebSocketService连接的时候添加open

如果我用纯js写一个websocket接受和发送如何写

js的完整的websocket例子，包含各种事件和状态判断，以及断线后自动重连，自动接收和发送心跳数据

最新推荐

SpringMVC整合websocket实现消息推送及触发功能

C#实现WebSocket协议客户端和服务器websocket sharp组件实例解析

在 Blender 2.6 中导入,导出 .x 文件.zip

MATLAB新功能：Multi-frame ViewRGB制作彩色图阴影

管理建模和仿真的文件

【实战篇：自定义损失函数】：构建独特损失函数解决特定问题，优化模型性能

在Flow-3D中如何根据水利工程的特定需求设定边界条件和进行网格划分，以便准确模拟水流问题？

XKCD Substitutions 3-crx插件：创新的网页文字替换工具

"互动学习：行动中的多样性与论文攻读经历"

【强化学习损失函数探索】：奖励函数与损失函数的深入联系及优化策略

android SlidingMenuDemo 侧边栏滑动打开

socketTask.onOpen(res => {})、socketTask.onMessage(res => {})、socketTask.onClose(res => {}) 有什么区别都怎么用