From c197c31a1a7bc8a0d7011e39193e3d94060b397c Mon Sep 17 00:00:00 2001
From: liusuyi <1951119284@qq.com>
Date: Tue, 11 Mar 2025 13:35:37 +0800
Subject: [PATCH] 优化websocket应答信息
---
ard-work/src/main/java/com/ard/tianyu/websocket/handler/UavStateManager.java | 4 +++-
1 files changed, 3 insertions(+), 1 deletions(-)
diff --git a/ard-work/src/main/java/com/ard/tianyu/websocket/handler/UavStateManager.java b/ard-work/src/main/java/com/ard/tianyu/websocket/handler/UavStateManager.java
index f548e9e..cf6df72 100644
--- a/ard-work/src/main/java/com/ard/tianyu/websocket/handler/UavStateManager.java
+++ b/ard-work/src/main/java/com/ard/tianyu/websocket/handler/UavStateManager.java
@@ -4,6 +4,7 @@
import com.alibaba.fastjson2.JSONObject;
import com.ard.tianyu.domain.cache.UavStateCache;
import com.ard.tianyu.domain.dto.state.UavState;
+import com.ard.tianyu.websocket.domain.BaseMessage;
import com.ard.tianyu.websocket.utils.WebSocketUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
@@ -128,12 +129,13 @@
private void sendDroneStateToSubscribers(String boxSn) {
// 获取当前无人机状态
UavState uavState = getDroneState(boxSn);
+ BaseMessage<UavState>baseMessage=new BaseMessage<>("state",uavState);
// 向所有订阅者推送状态
Set<Long> userIds = stateSubscriptions.get(boxSn);
if (userIds != null) {
for (Long userId : userIds) {
try {
- WebSocketUtil.sendMessage(userId, JSON.toJSONString(uavState));
+ WebSocketUtil.sendMessage(userId, JSON.toJSONString(baseMessage));
} catch (Exception e) {
log.error("Error sending state message to session {}", userId, e);
}
--
Gitblit v1.9.3