JeroBoot/base
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

【fix sonar】 WebSocket.java 文件

Browse Source
This commit is contained in:
tianwenbo
2023-03-07 16:24:32 +08:00
parent 702eaa7777
commit 759c9c2dac
1 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
jero-boot/jero-boot-module-system/src/main/java/com/jero/modules/message/websocket/WebSocket.java
+7 -7
View File
@@ -44,7 +44,7 @@ public class WebSocket {
* 缓存 webSocket连接到单机服务class中（整体方案支持集群） * 缓存 webSocket连接到单机服务class中（整体方案支持集群）
*/ */
private static CopyOnWriteArraySet<WebSocket> webSockets = new CopyOnWriteArraySet<>(); private static CopyOnWriteArraySet<WebSocket> webSockets = new CopyOnWriteArraySet<>();
private static Map<String, Session> sessionPool = new HashMap<String, Session>(); private static Map<String, Session> sessionPool = new HashMap<>();
@OnOpen @OnOpen
@@ -77,11 +77,11 @@ public class WebSocket {
* @param message * @param message
*/ */
public void pushMessage(String userId, String message) { public void pushMessage(String userId, String message) {
Session session = sessionPool.get(userId); Session s = sessionPool.get(userId);
if (session != null && session.isOpen()) { if (s != null && s.isOpen()) {
try { try {
log.info("【websocket消息】 单点消息:" + message); log.info("【websocket消息】 单点消息:" + message);
session.getAsyncRemote().sendText(message); s.getAsyncRemote().sendText(message);
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
} }
@@ -147,9 +147,9 @@ public class WebSocket {
* @param message * @param message
*/ */
public void sendMessage(String[] userIds, String message) { public void sendMessage(String[] userIds, String message) {
for (String userId : userIds) { for (String uId : userIds) {
sendMessage(userId, message); sendMessage(uId, message);
} }
} }
} }