| | |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 连接成功后 |
|---|
| | | * |
|---|
| | | * @param session |
|---|
| | | */ |
|---|
| | | @Override |
|---|
| | | public void afterConnectionEstablished(WebSocketSession session) { |
|---|
| | |
|---|
| | | 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); |
|---|
| | | } |
|---|
| | | |
|---|
