diff --git a/tuoheng-service/tuoheng-admin/src/main/java/com/tuoheng/admin/mqtt/MqttProviderConfig.java b/tuoheng-service/tuoheng-admin/src/main/java/com/tuoheng/admin/mqtt/MqttProviderConfig.java
index 6ad9128..3550e66 100644
--- a/tuoheng-service/tuoheng-admin/src/main/java/com/tuoheng/admin/mqtt/MqttProviderConfig.java
+++ b/tuoheng-service/tuoheng-admin/src/main/java/com/tuoheng/admin/mqtt/MqttProviderConfig.java
@@ -49,7 +49,7 @@ public class MqttProviderConfig {
         try {
             String ip = IpUtils.getHostIp();
             //创建MQTT客户端对象
-            client = new MqttClient(hostUrl, ip, new MemoryPersistence());
+            client = new MqttClient(hostUrl, ip + "@" + clientId, new MemoryPersistence());
             //连接设置
             MqttConnectOptions options = new MqttConnectOptions();
             //是否清空session，设置false表示服务器会保留客户端的连接记录（订阅主题，qos）,客户端重连之后能获取到服务器在客户端断开连接期间推送的消息