| | |
|---|
| | | package org.dromara.common.websocket.handler; |
|---|
| | | |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.dromara.common.core.domain.model.LoginUser; |
|---|
| | | import org.dromara.common.websocket.dto.WebSocketMessageDto; |
|---|
| | | import org.dromara.common.websocket.holder.WebSocketSessionHolder; |
|---|
| | | import org.dromara.common.websocket.utils.WebSocketUtils; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.springframework.web.socket.*; |
|---|
| | | import org.springframework.web.socket.handler.AbstractWebSocketHandler; |
|---|
| | | |
|---|
| | |
|---|
| | | @Override |
|---|
| | | protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception { |
|---|
| | | 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 = new WebSocketMessageDto(); |
|---|
| | | webSocketMessageDto.setSessionKeys(userIds); |
|---|
