From 7881cef5c3dcea8e6037101db2c3eeb2fd3ba5da Mon Sep 17 00:00:00 2001
From: 826220679@qq.com <826220679@qq.com>
Date: 星期六, 27 十二月 2025 23:42:36 +0800
Subject: [PATCH] 1211
---
src/Mqttmessage/PushCallback.java | 10 +++-------
1 files changed, 3 insertions(+), 7 deletions(-)
diff --git a/src/Mqttmessage/PushCallback.java b/src/Mqttmessage/PushCallback.java
index 08d523b..4c0e0d4 100644
--- a/src/Mqttmessage/PushCallback.java
+++ b/src/Mqttmessage/PushCallback.java
@@ -1,5 +1,6 @@
package Mqttmessage;
import Mqttmessage.Util.DeviceMessageParser;
+import gecaoji.Getgecaojiimu_data;
import gecaoji.gecaojistatus;
import Mqttmessage.Entity.GPSData;
import Mqttmessage.Entity.GPSData.StatusInfo;
@@ -65,7 +66,6 @@
try {
// 閲嶆柊璁㈤槄涓婚
clientInstance.getClient().subscribe(topic, qos);
- System.out.println("MQTT閲嶈繛鎴愬姛锛屽凡閲嶆柊璁㈤槄涓婚: " + topic);
return; // 閲嶈繛鎴愬姛锛岄��鍑哄惊鐜�
} catch (Exception e) {
System.err.println("閲嶆柊璁㈤槄涓婚澶辫触: " + e.getMessage());
@@ -73,9 +73,6 @@
}
retryCount++;
- if (retryCount % 5 == 0) {
- System.out.println("绛夊緟MQTT鑷姩閲嶈繛... (" + retryCount + "/" + maxRetries + ")");
- }
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
System.err.println("閲嶈繛绾跨▼琚腑鏂�");
@@ -91,7 +88,6 @@
clientInstance.connect();
if (clientInstance.isConnected()) {
clientInstance.subscribe(qos);
- System.out.println("鎵嬪姩閲嶈繛鎴愬姛锛屽凡閲嶆柊璁㈤槄涓婚: " + topic);
}
}
} catch (Exception e) {
@@ -101,7 +97,7 @@
}
public void deliveryComplete(IMqttDeliveryToken token) {
- System.out.println("deliveryComplete---------" + token.isComplete());
+ // 浜や粯瀹屾垚鍥炶皟
}
public void messageArrived(String topic, MqttMessage message) throws Exception {
@@ -112,7 +108,7 @@
String gpsRaw = gpsData.getGps_raw();
UDPServer.processSerialData(gpsRaw);
gecaojistatus.parseStatus(gpsData.getStatus());
- gpsData.getImu_data();
+ Getgecaojiimu_data.parseStatus(gpsData.getImu_data());
}
}
--
Gitblit v1.10.0