1

src/util/http_util.js

@@ -852,44 +852,46 @@ let httpSSERequest = (url, success, error) => {
  */
 let fetchEventSource = (url, data, options = {}) => {
     // 发送 POST 请求
-    fetch(url, {
-        method: "get",
-        // body: typeof data == "object" ? JSON.stringify(data) : data,
-        timeout: 0,
-        dataType: "text/event-stream",
-        headers: new Headers(addHeaders(headers))
-    }).then(response => {
-        // 检查响应是否成功
-        if (!response.ok) {
-            throw new Error('Network response was not ok');
-        }
-        // 返回一个可读流
-        options.onopen && options.onopen();
-        return response.body;
-    }).then(body => {
-        // disableLoading();
-        const reader = body.getReader();
-        // 读取数据流
-        const push = () => {
-            return reader.read().then(({ done, value }) => {
-                // 检查是否读取完毕
-                if (done) {
-                    console.log('已传输完毕');
-                    options.onclose && options.onclose();
-                    return;
-                }
-                // 处理每个数据块
-                // console.log('收到的数据:', value);
-                options.onmessage && options.onmessage(new TextDecoder().decode(value));
-                // 继续读取下一个数据块
-                return push();
-            });
-        }
-        // 开始读取数据流
-        return push();
-    }).catch(error => {
-        console.error('Fetch error:', error);
-        options.error && options.error(error);
+    return new Promise((resolve, reject) => {
+        fetch(url, {
+            method: "get",
+            // body: typeof data == "object" ? JSON.stringify(data) : data,
+            timeout: 0,
+            dataType: "text/event-stream",
+            headers: new Headers(addHeaders({}))
+        }).then(response => {
+            // 检查响应是否成功
+            if (!response.ok) {
+                throw new Error('Network response was not ok');
+            }
+            // 返回一个可读流
+            options.onopen && options.onopen();
+            return response.body;
+        }).then(body => {
+            // disableLoading();
+            const reader = body.getReader();
+            // 读取数据流
+            const push = () => {
+                return reader.read().then(({ done, value }) => {
+                    // 检查是否读取完毕
+                    if (done) {
+                        console.log('已传输完毕');
+                        options.onclose && options.onclose();
+                        return;
+                    }
+                    // 处理每个数据块
+                    // console.log('收到的数据:', value);
+                    options.onmessage && options.onmessage(new TextDecoder().decode(value));
+                    // 继续读取下一个数据块
+                    return push();
+                });
+            }
+            // 开始读取数据流
+            return push();
+        }).catch(error => {
+            return fetchEventSource(url, data, options);
+            options.error && options.error(error);
+        });
     });
 }
 //#endregion

src/view/home.vue

@@ -272,7 +272,7 @@ export default {
         const weekList = ['星期日', '星期一', '星期二', '星期三', '星期四', '星期五', '星期六'];
         this.myDate.week = weekList[dayjs().get('day')]
 
-        fetchEventSource("api_ws/stream-sse", {}, {
+        fetchEventSource("api/api_ws/getMsg1", {}, {
             onopen: () => {
                 console.log("打开");
             },
@@ -285,7 +285,7 @@ export default {
             }
         });
 
-        // httpSSERequest("api_ws/stream-sse", (data) => {
+        // httpSSERequest("api/api_ws/stream-sse", (data) => {
         //     console.log(data)
         // }, (err) => {
         //     console.log(err)

webpack.config.js

@@ -113,7 +113,7 @@ module.exports = {
         //后台代理
         proxy: {
             '/api/': {
-                target: 'http://192.168.168.213:8081',
+                target: 'http://localhost:8081',
                 ws: true,
                 secure: false,
                 changeOrigin: true,
@@ -121,12 +121,6 @@ module.exports = {
                     '^/api/': '/'
                 }
             },
-            '/api_ws/**': {
-                target: 'http://localhost:8081',
-                ws: true,
-                secure: false,
-                changeOrigin: true,
-            },
             '/websocket/**': {
                 target: 'ws://192.168.168.213:8081',
                 ws: true,