| | |
|---|
| | | package cn.flightfeather.supervision.socket.config |
|---|
| | | |
|---|
| | | import cn.flightfeather.supervision.common.utils.Constant |
|---|
| | | import cn.flightfeather.supervision.socket.WebSocketMessageParser |
|---|
| | | import cn.flightfeather.supervision.socket.WsSessionManager |
|---|
| | | import cn.flightfeather.supervision.socket.processor.WebSocketReceiver |
|---|
| | | import org.springframework.stereotype.Component |
|---|
| | |
|---|
| | | val payload = message.payload |
|---|
| | | val sessionId = session.attributes["session_id"] |
|---|
| | | println("server 接收到 $sessionId 发送的 $payload") |
|---|
| | | if (WebSocketMessageParser.decodeMessage(payload).type == |
|---|
| | | Constant.SocketHeartMessageType.HEART_MESSAGE_TYPE.value) { |
|---|
| | | webSocketReceiver.onReceiveHeartMsg(payload, sessionId.toString()) |
|---|
| | | } |
|---|
| | | webSocketReceiver.onReceiveMsg(payload) |
|---|
| | | // session.sendMessage(TextMessage("server 发送给 " + sessionId + " 消息 " + payload + " " + LocalDateTime.now() |
|---|
| | | // .toString())) |
|---|
