cuijian
2023-08-29 8e16903f4b9d8430852ebf58ed0d6b8dacf6ac75
lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/message/websocket/WebSocket.java
@@ -173,6 +173,19 @@
            sendMessage(userId, message);
        }
    }
    // 此为单点消息
    public void sendOneMessage(String userId, String message) {
        Session session = sessionPool.get(userId);
        if (session != null&&session.isOpen()) {
            try {
                log.info("【websocket消息】 单点消息:"+message);
                session.getAsyncRemote().sendText(message);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
    //=======【采用redis发布订阅模式——推送消息】==========================================================================================
    
}