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())