| | |
|---|
| | | * @param message 消息内容 |
|---|
| | | */ |
|---|
| | | public static void publishAll(String message) { |
|---|
| | | WebSocketSessionHolder.getSessionsAll().forEach(key -> { |
|---|
| | | WebSocketUtils.sendMessage(key, message); |
|---|
| | | }); |
|---|
| | | WebSocketMessageDto broadcastMessage = new WebSocketMessageDto(); |
|---|
| | | broadcastMessage.setMessage(message); |
|---|
| | | RedisUtils.publish(WEB_SOCKET_TOPIC, broadcastMessage, consumer -> { |
|---|
| | |
|---|
| | | |
|---|
| | | private static void sendMessage(WebSocketSession session, WebSocketMessage<?> message) { |
|---|
| | | if (session == null || !session.isOpen()) { |
|---|
| | | log.error("[send] session会话已经关闭"); |
|---|
| | | log.warn("[send] session会话已经关闭"); |
|---|
| | | } else { |
|---|
| | | try { |
|---|
| | | session.sendMessage(message); |
|---|
