This commit is contained in:
ran.shang
2025-08-26 13:19:19 +08:00
parent bd2475a5e2
commit 6e5a55a0eb

View File

@@ -125,6 +125,7 @@ public class DefaultTextWebSocketHandler extends TextWebSocketHandler {
log.info("{}用户未建立ws...");
return ;
}
log.info("websocket send msg to {}-{}", userId, message.getType());
sessions.stream().forEach(session -> DefaultTextWebSocketHandler.sendMessage(session, message));
}