From 7558f23c7123fc1dd505c274efe5279aa827cf49 Mon Sep 17 00:00:00 2001
From: GGJ <357021191@qq.com>
Date: Mon, 14 Apr 2025 11:13:18 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9WebSocket=E5=9C=B0=E5=9D=80?=
 =?UTF-8?q?=E4=BB=8Enginx=E4=B8=AD=E8=AF=BB=E5=8F=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/utils/webSocketClient.ts                   | 18 +++++++++++-------
 .../monitoringPoint/online/index.vue           |  2 +-
 2 files changed, 12 insertions(+), 8 deletions(-)

diff --git a/src/utils/webSocketClient.ts b/src/utils/webSocketClient.ts
index a707d801..317ddc7f 100644
--- a/src/utils/webSocketClient.ts
+++ b/src/utils/webSocketClient.ts
@@ -38,19 +38,23 @@ export default class SocketService {
     }
 
     // 定义连接服务器的方法
-    public connect(id: string): void {
+    public async connect(id: string) {
         if (!window.WebSocket) {
             console.log('您的浏览器不支持WebSocket')
             return
         }
 
-        const url = 'ws://192.168.1.67:10407/api/pushMessage/' + id
-        this.ws = new WebSocket(url)
+        const response = await fetch('/')
+        const mqttUrl = response.headers.get('X-Mqtt-Url')
+        setTimeout(() => {
+            const url = (mqttUrl || 'ws://192.168.1.67:10407/api/pushMessage/') + id
+            this.ws = new WebSocket(url)
 
-        this.ws.onopen = () => this.handleOpen()
-        this.ws.onclose = () => this.handleClose()
-        this.ws.onerror = () => this.handleError()
-        this.ws.onmessage = event => this.handleMessage(event)
+            this.ws.onopen = () => this.handleOpen()
+            this.ws.onclose = () => this.handleClose()
+            this.ws.onerror = () => this.handleError()
+            this.ws.onmessage = event => this.handleMessage(event)
+        }, 0)
     }
 
     // 处理连接成功事件
diff --git a/src/views/pqs/harmonicMonitoring/monitoringPoint/online/index.vue b/src/views/pqs/harmonicMonitoring/monitoringPoint/online/index.vue
index fb9e65fb..93ba14e0 100644
--- a/src/views/pqs/harmonicMonitoring/monitoringPoint/online/index.vue
+++ b/src/views/pqs/harmonicMonitoring/monitoringPoint/online/index.vue
@@ -73,7 +73,7 @@ import Shishishuju from './shishishuju/index.vue'
 import router from '@/router'
 
 defineOptions({
-    name: 'harmonic-boot/monitor/online'
+    // name: 'harmonic-boot/monitor/online'
 })
 
 const monitoringPoint = useMonitoringPoint()