From c9b1d33979b3972fe6a82fa427b4ba9a20989112 Mon Sep 17 00:00:00 2001
From: 张世豪 <979909237@qq.com>
Date: 星期三, 24 十二月 2025 18:56:28 +0800
Subject: [PATCH] 新增mqtt相关功能
---
src/Mqttmessage/Client.java | 13 ++++++++-----
1 files changed, 8 insertions(+), 5 deletions(-)
diff --git a/src/Mqttmessage/Client.java b/src/Mqttmessage/Client.java
index 90ff9f1..60be1c3 100644
--- a/src/Mqttmessage/Client.java
+++ b/src/Mqttmessage/Client.java
@@ -4,6 +4,9 @@
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import org.eclipse.paho.client.mqttv3.MqttException;
+import set.Setsys;
+import user.Usrdell;
+
/**
* MQTT瀹㈡埛绔伐鍏风被
* 鐢ㄤ簬杩炴帴MQTT鏈嶅姟鍣ㄥ苟璁㈤槄涓婚
@@ -94,12 +97,12 @@
* 绀轰緥鐢ㄦ硶
*/
- public static void test() {
+ public static void lianjiemqqt() {
try {
String host = "tcp://39.99.43.227:1883";
- String deiveID="6258";
- String clientId = "hxzkMQTT";
- String clientId2 = "hxzkMQTT2";
+ String deiveID=Setsys.getMowerIdValue();
+ String clientId =Usrdell.getUserEmail()+"mower";
+ String clientId2 =Usrdell.getUserEmail()+"response";
String topic = "mower/"+deiveID+"/gps";
String topic2 = "mower/"+deiveID+"/response";
Client mqttClient = new Client(host, topic, clientId);
@@ -111,7 +114,7 @@
mqttClient1.subscribe();
// 淇濇寔绋嬪簭杩愯
- //Thread.sleep(Long.MAX_VALUE);
+// Thread.sleep(Long.MAX_VALUE);
} catch (MqttException e) {
throw new RuntimeException(e);
}
--
Gitblit v1.10.0