| | |
|---|
| | | package cn.flightfeather.supervision.socket.config |
|---|
| | | |
|---|
| | | import cn.flightfeather.supervision.common.utils.Constant |
|---|
| | | import cn.flightfeather.supervision.socket.WebSocketMessageUtil |
|---|
| | | import cn.flightfeather.supervision.socket.WebSocketMessageDecoder |
|---|
| | | 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 (WebSocketMessageUtil.decodeMessage(payload).type == |
|---|
| | | if (WebSocketMessageDecoder.decodeMessage(payload).type == |
|---|
| | | Constant.SocketHeartMessageType.HEART_MESSAGE_TYPE.value) { |
|---|
| | | webSocketReceiver.onReceiveHeartMsg(payload, sessionId.toString()) |
|---|
| | | } |
|---|
