From 665d60b679c8d0288b151adde4849b8e7355c4e8 Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@163.com>
Date: 星期三, 03 四月 2024 12:43:18 +0800
Subject: [PATCH] #
---
zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/common/config/WebSocketConfig.java | 5 -----
zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/map/websocket/MapWebsocket.java | 37 +++++++++++++++++++++++++++++++++++++
2 files changed, 37 insertions(+), 5 deletions(-)
diff --git a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/common/config/WebSocketConfig.java b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/common/config/WebSocketConfig.java
index 2df1e87..369166f 100644
--- a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/common/config/WebSocketConfig.java
+++ b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/common/config/WebSocketConfig.java
@@ -6,7 +6,6 @@
import org.springframework.web.socket.server.standard.ServerEndpointExporter;
@Configuration
-@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {
@Bean
@@ -14,9 +13,5 @@
return new ServerEndpointExporter();
}
- @Override
- public void registerStompEndpoints(StompEndpointRegistry registry) {
- registry.addEndpoint("/api/socket");
- }
}
diff --git a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/map/websocket/MapWebsocket.java b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/map/websocket/MapWebsocket.java
new file mode 100644
index 0000000..49dad31
--- /dev/null
+++ b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/map/websocket/MapWebsocket.java
@@ -0,0 +1,37 @@
+package com.zy.asrs.wcs.core.map.websocket;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import javax.websocket.OnClose;
+import javax.websocket.OnMessage;
+import javax.websocket.OnOpen;
+import javax.websocket.Session;
+import javax.websocket.server.ServerEndpoint;
+
+@Slf4j
+@Component
+@ServerEndpoint(value = "/map/websocket")
+public class MapWebsocket {
+
+ private Session session;
+ private String sessionId;
+
+ @OnOpen
+ public void onOpen(Session session) {
+ this.session = session;
+ this.sessionId = session.getId();
+ log.info("{} connected", this.sessionId);
+ }
+
+ @OnMessage
+ public void onMessage(String message, Session session) {
+ log.info("{} sendMsg:{}", this.sessionId, message);
+ }
+
+ @OnClose
+ public void onClose(Session session) {
+ log.info("{} closed", this.sessionId);
+ }
+
+}
--
Gitblit v1.9.1