| | |
| | | import com.ard.common.core.domain.model.LoginUser; |
| | | import com.ard.framework.web.service.TokenService; |
| | | import com.ard.work.component.websocket.WebSocketSessionManager; |
| | | import com.ard.work.component.websocket.utils.WebSocketUtil; |
| | | import com.ard.work.domain.enums.MessageType; |
| | | import com.ard.work.domain.message.*; |
| | | import com.ard.work.service.control.UavControlService; |
| | |
| | | import org.springframework.web.socket.TextMessage; |
| | | import org.springframework.web.socket.WebSocketSession; |
| | | import org.springframework.web.socket.handler.TextWebSocketHandler; |
| | | |
| | | import javax.annotation.Resource; |
| | | import java.util.concurrent.CompletableFuture; |
| | | |
| | |
| | | BaseMessage<?> baseMessage = JSON.parseObject(payload, BaseMessage.class); |
| | | MessageType messageType = MessageType.fromString(baseMessage.getType()); |
| | | switch (messageType) { |
| | | case HEARTBEAT: |
| | | handleHeartbeatMessage(payload, userId); |
| | | break; |
| | | case STREAM: |
| | | handleStreamMessage(payload, userId); |
| | | break; |
| | |
| | | } catch (Exception e) { |
| | | log.error("Error handling message: {}", message, e); |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 处理心跳消息 |
| | | * <p> |
| | | * 该方法解析给定的负载数据,以获取无人机流消息,并根据消息类型决定是否开始或停止流 |
| | | * |
| | | * @param payload 消息的负载数据,通常为JSON字符串 |
| | | * @param userId 接收消息的用户ID |
| | | */ |
| | | private void handleHeartbeatMessage(String payload, Long userId) { |
| | | |
| | | WebSocketUtil.sendMessage(userId, "服务端收到:" + payload); |
| | | } |
| | | |
| | | /** |
| | |
| | | CompletableFuture.runAsync(() -> { |
| | | try { |
| | | Thread.sleep(10_000); // 延迟10秒 |
| | | } catch (InterruptedException ignored) {} |
| | | } catch (InterruptedException ignored) { |
| | | } |
| | | |
| | | if (!WebSocketSessionManager.containsUser(userId)) { |
| | | LoginUser loginUser = tokenService.getLoginUserByUserId(userId); |