[Optimization-4314][admin] Optimize WebSocket for asynchronous sending (#4315)

aiwenmo · web-flow · commit 92077a51c076 · 2025-03-23T22:57:29.000+08:00
diff --git a/dinky-admin/src/main/java/org/dinky/ws/GlobalWebSocket.java b/dinky-admin/src/main/java/org/dinky/ws/GlobalWebSocket.java
@@ -109,7 +109,7 @@ public void onMessage(String message, Session session) throws IOException {
 
             if (requestDTO.getType() == RequestDTO.EventType.PING) {
                 WsDataVo data = new WsDataVo(session.getId(), RequestDTO.EventType.PONG);
-                session.getBasicRemote().sendText(JsonUtils.toJsonString(data));
+                session.getAsyncRemote().sendText(JsonUtils.toJsonString(data));
                 return;
             }
 
@@ -153,12 +153,7 @@ private void firstSend() {
     }
 
     private void send(Session session, WsDataVo data) {
-        try {
-            session.getBasicRemote().sendText(JsonUtils.toJsonString(data));
-        } catch (IOException e) {
-            log.error("send ws data error", e);
-            throw new RuntimeException(e);
-        }
+        session.getAsyncRemote().sendText(JsonUtils.toJsonString(data));
     }
 
     public void sendTopic(GlobalWebSocketTopic topic, Set<String> params, Map<String, Object> result) {

Original file line number	Diff line number	Diff line change
`@@ -109,7 +109,7 @@ public void onMessage(String message, Session session) throws IOException {`
`109`	`109`
`110`	`110`	`if (requestDTO.getType() == RequestDTO.EventType.PING) {`
`111`	`111`	`WsDataVo data = new WsDataVo(session.getId(), RequestDTO.EventType.PONG);`
`112`		`- session.getBasicRemote().sendText(JsonUtils.toJsonString(data));`
	`112`	`+ session.getAsyncRemote().sendText(JsonUtils.toJsonString(data));`
`113`	`113`	`return;`
`114`	`114`	`}`
`115`	`115`
`@@ -153,12 +153,7 @@ private void firstSend() {`
`153`	`153`	`}`
`154`	`154`
`155`	`155`	`private void send(Session session, WsDataVo data) {`
`156`		`- try {`
`157`		`- session.getBasicRemote().sendText(JsonUtils.toJsonString(data));`
`158`		`- } catch (IOException e) {`
`159`		`- log.error("send ws data error", e);`
`160`		`- throw new RuntimeException(e);`
`161`		`- }`
	`156`	`+ session.getAsyncRemote().sendText(JsonUtils.toJsonString(data));`
`162`	`157`	`}`
`163`	`158`
`164`	`159`	`public void sendTopic(GlobalWebSocketTopic topic, Set<String> params, Map<String, Object> result) {`