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 +}