ruoyi-vue插件集成websocket

链接：插件集成 | RuoYi

WebSocketServer.java：补充代码

/*** 此为广播消息* @param message 消息内容*/public void sendAllMessage(String message) {LOGGER.info("【websocket.sendAllMessage】广播消息:"+message);try {for(String sessionId : WebSocketUsers.getUsers().keySet()) {Session session = WebSocketUsers.getUsers().get(sessionId);WebSocketUsers.sendMessageToUserByText(session, message);}} catch (Exception e) {e.printStackTrace();}}/*** 此为单点消息* @param userId 用户编号* @param message 消息内容*/public void sendOneMessage(String sessionId, String message) {try {Session session = WebSocketUsers.getUsers().get(sessionId);if (session != null && session.isOpen()) {LOGGER.info("【websocket.sendOneMessage】 单点消息:"+message);WebSocketUsers.sendMessageToUserByText(session, message);}} catch (Exception e) {e.printStackTrace();}}/*** 此为单点消息(多人)* @param userIds 用户编号组* @param message 消息内容*/public void sendMoreMessage(String sessionIds, String message) {try {String[] sids = sessionIds.split(",");for(String sessionId : sids) {Session session = WebSocketUsers.getUsers().get(sessionId);if (session != null && session.isOpen()) {LOGGER.info("【websocket.sendMoreMessage】 多人消息:"+message);WebSocketUsers.sendMessageToUserByText(session, message);}}} catch (Exception e) {e.printStackTrace();}}

.antMatchers("/websocket/**", "/test/**").permitAll()