| | |
| | | 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.Map; |
| | | import java.util.Objects; |
| | | import java.util.concurrent.CompletableFuture; |
| | | import java.util.concurrent.ConcurrentHashMap; |
| | | |
| | | |
| | | @Component |
| | |
| | | private UavAllManager uavAllManager; |
| | | @Resource |
| | | private TokenService tokenService; |
| | | |
| | | private final Map<Long, Long> lastDisconnectTime = new ConcurrentHashMap<>(); |
| | | @Override |
| | | public void handleTextMessage(WebSocketSession session, TextMessage message) { |
| | | try { |
| | | String userIdStr = (String) session.getAttributes().get("userId"); |
| | | Long userId = Long.parseLong(userIdStr); |
| | | String payload = message.getPayload(); |
| | | log.info("【cmd】Received message: {}", payload); |
| | | log.info("【cmd】size: {}", WebSocketSessionManager.getOnlineUserCount()); |
| | | log.info("【cmd】Received【{}】message: {} size: {}", userId, payload, |
| | | WebSocketSessionManager.getOnlineUserCount()); |
| | | 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); |
| | | } |
| | | |
| | | /** |
| | |
| | | return; |
| | | } |
| | | Long userId = Long.parseLong(userIdStr); |
| | | lastDisconnectTime.remove(userId); // 清除断开标记 |
| | | WebSocketSessionManager.addSession(userId, session); |
| | | log.info("【cmd】size: {}", WebSocketSessionManager.getOnlineUserCount()); |
| | | } |
| | |
| | | Long userId = Long.parseLong(userIdStr); |
| | | WebSocketSessionManager.removeSession(userId); |
| | | log.info("【cmd】size: {}", WebSocketSessionManager.getOnlineUserCount()); |
| | | |
| | | long version = System.currentTimeMillis(); |
| | | lastDisconnectTime.put(userId, version); |
| | | // 释放该用户所有 UAV 控制权 |
| | | uavControlService.releaseAllControls(userId); |
| | | uavStreamManager.stopAllPullStreamByUser(userId); |
| | | uavStateManager.removeSubscribe(userId); |
| | | uavTelemetryManager.removeSubscribe(userId); |
| | | uavSignalManager.removeSubscribe(userId); |
| | | uavControlManager.removeSubscribe(userId); |
| | | |
| | | // 延迟10秒删除token(若期间没重连) |
| | | CompletableFuture.runAsync(() -> { |
| | | try { |
| | | Thread.sleep(10_000); // 延迟10秒 |
| | | } catch (InterruptedException ignored) {} |
| | | |
| | | Thread.sleep(3_000); // 延迟3秒 |
| | | } catch (InterruptedException ignored) { |
| | | } |
| | | // 如果版本号不一致,说明用户曾重连 → 不执行删除 |
| | | if (!Objects.equals(lastDisconnectTime.get(userId), version)) { |
| | | return; |
| | | } |
| | | if (!WebSocketSessionManager.containsUser(userId)) { |
| | | LoginUser loginUser = tokenService.getLoginUserByUserId(userId); |
| | | if (loginUser != null) { |
| | | uavControlService.releaseAllControls(userId); |
| | | uavStreamManager.stopAllPullStreamByUser(userId); |
| | | uavStateManager.removeSubscribe(userId); |
| | | uavTelemetryManager.removeSubscribe(userId); |
| | | uavSignalManager.removeSubscribe(userId); |
| | | uavControlManager.removeSubscribe(userId); |
| | | tokenService.delLoginUser(loginUser.getToken(), userId); |
| | | log.info("【cmd】用户 [{}] 超时未重连,已删除 token", userId); |
| | | } |