From 759c9c2dac48a7a9f4732458915f44204117abf5 Mon Sep 17 00:00:00 2001 From: tianwenbo Date: Tue, 7 Mar 2023 16:24:24 +0800 Subject: [PATCH] =?UTF-8?q?=E3=80=90fix=20sonar=E3=80=91=20WebSocket.java?= =?UTF-8?q?=20=E6=96=87=E4=BB=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../jero/modules/message/websocket/WebSocket.java | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/jero-boot/jero-boot-module-system/src/main/java/com/jero/modules/message/websocket/WebSocket.java b/jero-boot/jero-boot-module-system/src/main/java/com/jero/modules/message/websocket/WebSocket.java index df8a22f4..f7d3f144 100644 --- a/jero-boot/jero-boot-module-system/src/main/java/com/jero/modules/message/websocket/WebSocket.java +++ b/jero-boot/jero-boot-module-system/src/main/java/com/jero/modules/message/websocket/WebSocket.java @@ -44,7 +44,7 @@ public class WebSocket { * 缓存 webSocket连接到单机服务class中（整体方案支持集群） */ private static CopyOnWriteArraySet webSockets = new CopyOnWriteArraySet<>(); - private static Map sessionPool = new HashMap(); + private static Map sessionPool = new HashMap<>(); @OnOpen @@ -77,11 +77,11 @@ public class WebSocket { * @param message */ public void pushMessage(String userId, String message) { - Session session = sessionPool.get(userId); - if (session != null && session.isOpen()) { + Session s = sessionPool.get(userId); + if (s != null && s.isOpen()) { try { log.info("【websocket消息】 单点消息:" + message); - session.getAsyncRemote().sendText(message); + s.getAsyncRemote().sendText(message); } catch (Exception e) { e.printStackTrace(); } @@ -147,9 +147,9 @@ public class WebSocket { * @param message */ public void sendMessage(String[] userIds, String message) { - for (String userId : userIds) { - sendMessage(userId, message); + for (String uId : userIds) { + sendMessage(uId, message); } } -} \ No newline at end of file +}