链接mqtt

package-lock.json

@@ -13,7 +13,7 @@
         "delaunator": "^5.0.0",
         "echarts": "^5.5.0",
         "gsap": "^3.12.2",
-        "mqtt": "^5.11.0",
+        "mqtt": "^5.0.0",
         "normalize.css": "^8.0.1",
         "point-in-polygon": "^1.1.0",
         "three": "0.161.0",

package.json

@@ -14,7 +14,7 @@
     "delaunator": "^5.0.0",
     "echarts": "^5.5.0",
     "gsap": "^3.12.2",
-    "mqtt": "^5.11.0",
+    "mqtt": "^5.0.0",
     "normalize.css": "^8.0.1",
     "point-in-polygon": "^1.1.0",
     "three": "0.161.0",

src/utils/mqttClient.js

@@ -3,16 +3,17 @@ import mqtt from 'mqtt'
 // MQTT 配置
 const options = {
   // clean: true,
-  keepalive: 30,      // 心跳间隔（秒）
-  connectTimeout: 15000, // 连接超时（毫秒）
+  // keepalive: 30,      // 心跳间隔（秒）
+  // connectTimeout: 15000, // 连接超时（毫秒）
   clientId: 'web-client-' + Math.random().toString(16).substring(2, 8),
   // username: '', // 如果需要认证
   // password: '',
-  protocolVersion: 4,
+  // protocolVersion: 4,
 }
 
 // MQTT 代理地址（示例使用公共测试服务器）
-const brokerUrl = 'ws://192.168.1.177:1883/mqtt'
+// const brokerUrl = 'mqtt://192.168.1.177:1883'
+const brokerUrl = 'ws://192.168.1.177:8883/mqtt'
 
 class MQTTClient {
   constructor() {
@@ -22,7 +23,8 @@ class MQTTClient {
   connect() {
     console.log('Connecting to MQTT...')
     console.log("brokerUrl", brokerUrl)
-    this.client = mqtt.connect(brokerUrl, options)
+    console.log("options", options)
+    this.client = mqtt.connect(brokerUrl,options)
 
     // 连接成功
     this.client.on('connect', () => {