From b3dbfe5ab42efc7e744df5a391a8568e1b7c2289 Mon Sep 17 00:00:00 2001
From: zhangnaisong <2434969829@qq.com>
Date: 星期五, 16 二月 2024 17:06:18 +0800
Subject: [PATCH] 无人机websocket客户端心跳保活提交
---
ard-work/src/main/java/com/ruoyi/utils/qymqtt/AutoMqtt.java | 10 ++++++----
1 files changed, 6 insertions(+), 4 deletions(-)
diff --git a/ard-work/src/main/java/com/ruoyi/utils/qymqtt/AutoMqtt.java b/ard-work/src/main/java/com/ruoyi/utils/qymqtt/AutoMqtt.java
index d6bff1d..a945fb0 100644
--- a/ard-work/src/main/java/com/ruoyi/utils/qymqtt/AutoMqtt.java
+++ b/ard-work/src/main/java/com/ruoyi/utils/qymqtt/AutoMqtt.java
@@ -12,9 +12,9 @@
import java.util.List;
import java.util.UUID;
-@Slf4j
+@Slf4j(topic = "mqttCar")
@Component
-public class AutoMqtt {
+public class AutoMqtt {
@Autowired
private ArdSyCarRtuService ardSyCarRtuService;
@@ -33,13 +33,15 @@
// MqttCustomerClient mqttCustomerClient = new MqttCustomerClient();
// mqttCustomerClient.connect(carId+"mqtt"+ UUID.randomUUID());
// mqttCustomerClient.subscribe(subscribe);
- EmqClient emqClient = new EmqClient(carId+"mqttSubscribe");
+ EmqClient emqClient = new EmqClient(carId+"mqttSubscribe"+UUID.randomUUID());
emqClient.connect();
emqClient.subscribe(subscribe, QosEnum.QoS2);
- log.info("璁㈤槄涓婚锛�"+subscribe);
+ log.debug("璁㈤槄涓婚锛�"+subscribe);
}catch (Exception e) {
e.printStackTrace();
}
}
}
+
+
}
--
Gitblit v1.9.3