From dc728a4c0f437c80c5a361a52071f392ce5066bf Mon Sep 17 00:00:00 2001
From: zhufu <17863654727@163.com>
Date: Tue, 30 Dec 2025 15:01:39 +0800
Subject: [PATCH] =?UTF-8?q?=E6=97=A0=E4=BA=BA=E6=9C=BA=E5=8F=8A=E6=9C=BA?=
 =?UTF-8?q?=E5=9C=BA=E7=9B=B4=E6=92=AD=E4=B8=8D=E7=A8=B3=E5=AE=9A=E9=97=AE?=
 =?UTF-8?q?=E9=A2=98=EF=BC=9B=E5=A4=9A=E7=BB=84=E4=BB=B6=E5=90=8C=E6=97=B6?=
 =?UTF-8?q?=E8=BF=9E=E6=8E=A5mqtt=E4=BD=86=E6=98=AFmqtt=E6=96=B9=E6=B3=95?=
 =?UTF-8?q?=E5=BC=82=E6=AD=A5=E5=AF=BC=E8=87=B4=E8=BF=9E=E6=8E=A5=E5=86=B2?=
 =?UTF-8?q?=E7=AA=81=E4=B8=80=E7=9B=B4=E9=87=8D=E8=BF=9E=E9=97=AE=E9=A2=98?=
 =?UTF-8?q?=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/utils/mqtt.ts | 18 +++++++++++++++++-
 1 file changed, 17 insertions(+), 1 deletion(-)

diff --git a/src/utils/mqtt.ts b/src/utils/mqtt.ts
index 0df67c1..ac626fa 100644
--- a/src/utils/mqtt.ts
+++ b/src/utils/mqtt.ts
@@ -6,6 +6,7 @@ import { timestampToFormattedDate } from '@/utils/index';
 
 const userStore = useUserStore();
 const userInfo = userStore.getUserInfo;
+let connectLock = false
 
 const { createMessage } = useMessage();
 const seizeClientId = 'mqtt_client_1581F8HGX254V00A0BUY_seize';
@@ -55,6 +56,21 @@ const createConnection = (callback?) => {
   // 连接mqtt的时候，先用GetRedisUser查一下有没有，
   // 然后AddOrUpdateRedisUser更新或添加，
   // 控制的时候先查一下有没有锁定的用户GetLockedClients
+  if(connectLock){
+    if (callback) {
+      if(client && client.connected){
+        callback();
+      }else{
+        setTimeout(() => {
+          client.on('connect', () => {
+            callback();
+          });
+        }, 3000)
+      }
+    }
+    return
+  }
+  connectLock = true
   try {
     getRedisUser(userInfo.id).then((res) => {
       console.log("getRedisUser",res);
@@ -120,7 +136,7 @@ const destroyConnection = () => {
 };
 // 订阅事件
 const clientSubscribe = (topic: string, options?: any) => {
-  if(!topic){
+  if(topic.includes('/null/')){
     return
   }
   // if (!client || !client.connected) {