init

liusuyi

2024-10-10 38f29e38fcc668171dc05c53d40a36b895c86102

 ard-work/src/main/java/com/ruoyi/utils/websocket/util/WebSocketUtils.java

@@ -23,7 +23,7 @@
public final class WebSocketUtils {

    // 存储 websocket session
    public static final Map<String, Session> ONLINE_USER_SESSIONS = new ConcurrentHashMap<>();
    public static final ConcurrentMap<String, Session> ONLINE_USER_SESSIONS = new ConcurrentHashMap<>();
    //存储房间
    public static final ConcurrentHashMap<String, Set<String>> ROOM_USER_SET = new ConcurrentHashMap<>();

@@ -95,7 +95,17 @@
    public static void sendMessageAll(String message) {
        ONLINE_USER_SESSIONS.forEach((sessionId, session) -> sendMessage(session, message));
    }

    /**
     * 发送消息给指定用户
     *
     * @param  userId 用户id
     * @param  message 消息内容
     * @author 刘苏义
     * @date   2024/8/12 15:43
     */
    public static void sendMessage(String userId,String message) {
        WebSocketUtils.ONLINE_USER_SESSIONS.get(userId).getAsyncRemote().sendText(message);
    }
    /**
     * 推送消息到其他客户端
     *