From f4820b809ff9e87452185b51f691fb450dbf2dfc Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=AD=99=E5=B0=8F=E4=BA=91?= Date: Tue, 24 Mar 2026 10:18:05 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E9=85=8D=E7=BD=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/com/ruoyi/device/service/impl/DjiService.java | 2 +- src/main/java/com/ruoyi/device/service/impl/TuohengService.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/ruoyi/device/service/impl/DjiService.java b/src/main/java/com/ruoyi/device/service/impl/DjiService.java index 46b876b..c14c91b 100644 --- a/src/main/java/com/ruoyi/device/service/impl/DjiService.java +++ b/src/main/java/com/ruoyi/device/service/impl/DjiService.java @@ -65,7 +65,7 @@ public class DjiService { DjiMqttClientConfig config = DjiMqttClientConfig.builder() .host(mqttProperties.getHost()) .port(mqttProperties.getPort()) - .clientId(mqttProperties.getClientId()) + .clientId(mqttProperties.getClientId() + "_" + System.currentTimeMillis()) .username(mqttProperties.getUsername()) .password(mqttProperties.getPassword()) .connectionTimeout(mqttProperties.getConnectionTimeout()) diff --git a/src/main/java/com/ruoyi/device/service/impl/TuohengService.java b/src/main/java/com/ruoyi/device/service/impl/TuohengService.java index 5a746e0..6e909db 100644 --- a/src/main/java/com/ruoyi/device/service/impl/TuohengService.java +++ b/src/main/java/com/ruoyi/device/service/impl/TuohengService.java @@ -89,7 +89,7 @@ public class TuohengService { TuohengMqttClientConfig config = TuohengMqttClientConfig.builder() .host(mqttProperties.getHost()) .port(mqttProperties.getPort()) - .clientId(mqttProperties.getClientId()) + .clientId(mqttProperties.getClientId() + "_" + System.currentTimeMillis()) .username(mqttProperties.getUsername()) .password(mqttProperties.getPassword()) .connectionTimeout(mqttProperties.getConnectionTimeout())