From c40fc0cc01b12f6fab6db90af395eb241e0e2aaf Mon Sep 17 00:00:00 2001
From: 13693261870 <252740454@qq.com>
Date: 星期四, 26 十月 2023 15:55:32 +0800
Subject: [PATCH] 解决WS消息推送报错
---
src/main/java/com/moon/server/service/all/WebSocketService.java | 18 ++++--------------
1 files changed, 4 insertions(+), 14 deletions(-)
diff --git a/src/main/java/com/moon/server/service/all/WebSocketService.java b/src/main/java/com/moon/server/service/all/WebSocketService.java
index 2d3d690..6066f89 100644
--- a/src/main/java/com/moon/server/service/all/WebSocketService.java
+++ b/src/main/java/com/moon/server/service/all/WebSocketService.java
@@ -68,9 +68,6 @@
/**
* 鍑虹幇閿欒
- *
- * @param session
- * @param error
*/
@OnError
public void onError(Session session, Throwable error) {
@@ -79,13 +76,13 @@
/**
* 鍙戦�佹秷鎭紝瀹炶返琛ㄦ槑锛屾瘡娆℃祻瑙堝櫒鍒锋柊锛宻ession浼氬彂鐢熷彉鍖栥��
- *
- * @param session
- * @param message
*/
public static void sendMessage(Session session, String message) {
try {
- session.getBasicRemote().sendText(String.format("%s", message));
+ // session.getAsyncRemote().sendText(message)
+ synchronized (session){
+ session.getBasicRemote().sendText(message);
+ }
} catch (Exception ex) {
log.error("鍙戦�佹秷鎭嚭閿欙細{}", ex.getMessage());
}
@@ -93,9 +90,6 @@
/**
* 缇ゅ彂娑堟伅
- *
- * @param message
- * @throws IOException
*/
public static void broadCastInfo(String message) throws IOException {
for (Session session : SESSION_SET) {
@@ -107,10 +101,6 @@
/**
* 鎸囧畾Session鍙戦�佹秷鎭�
- *
- * @param sessionId
- * @param message
- * @throws IOException
*/
public static void sendMessage(String message, String sessionId) throws IOException {
Session session = null;
--
Gitblit v1.9.3