| | |
|---|
| | | LoginUser loginUser = (LoginUser) session.getAttributes().get(LOGIN_USER_KEY); |
|---|
| | | log.info("PlusWebSocketHandler, 连接：" + session.getId() + "，已收到消息:" + message.getPayload()); |
|---|
| | | List<Long> userIds = List.of(loginUser.getUserId()); |
|---|
| | | WebSocketMessageDto webSocketMessageDto = WebSocketMessageDto.builder() |
|---|
| | | .sessionKeys(userIds).message(message.getPayload()).build(); |
|---|
| | | WebSocketMessageDto webSocketMessageDto = new WebSocketMessageDto(); |
|---|
| | | webSocketMessageDto.setSessionKeys(userIds); |
|---|
| | | webSocketMessageDto.setMessage(message.getPayload()); |
|---|
| | | WebSocketUtils.publishMessage(webSocketMessageDto); |
|---|
| | | } |
|---|
| | | |
|---|
