链接：插件集成 | 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()
