sse

package-lock.json

@@ -4323,6 +4323,11 @@
       "integrity": "sha1-Qa4u62XvpiJorr/qg6x9eSmbCIc=",
       "dev": true
     },
+    "event-source-polyfill": {
+      "version": "1.0.31",
+      "resolved": "https://registry.npmmirror.com/event-source-polyfill/-/event-source-polyfill-1.0.31.tgz",
+      "integrity": "sha512-4IJSItgS/41IxN5UVAVuAyczwZF7ZIEsM1XAoUzIHA6A+xzusEZUutdXz2Nr+MQPLxfTiCvqE79/C8HT8fKFvA=="
+    },
     "eventemitter3": {
       "version": "4.0.7",
       "resolved": "https://registry.npmjs.org/eventemitter3/-/eventemitter3-4.0.7.tgz",

package.json

@@ -43,6 +43,7 @@
     "el-table-infinite-scroll": "^1.0.10",
     "element-ui": "^2.15.2",
     "esri-loader": "^3.1.0",
+    "event-source-polyfill": "^1.0.31",
     "file-saver": "^2.0.5",
     "flv.js": "^1.6.2",
     "gsap": "^3.12.2",

src/util/http_util.js

@@ -7,6 +7,8 @@ import {
     saveAs
 } from 'file-saver';
 import { ACCESS_TOKEN, ACCESS_USER, HTTP_STATUS } from "../constant/user";
+import { EventSourcePolyfill } from "event-source-polyfill";
+
 
 
 /**
@@ -844,6 +846,29 @@ let httpSSERequest = (url, success, error) => {
     }
 }
 
+/**
+ * 支持请求头的
+ * @param {*} url 
+ * @param {*} success 
+ * @param {*} error 
+ */
+let httpSSERequestPoly = (url, success, error) => {
+    const evtSource = new EventSourcePolyfill(url, {
+        headers: addHeaders({})
+    })
+    evtSource.onmessage = function (event) {
+        let result = JSON.parse(event.data);
+        if (result.code == 9000) {
+            success(result.data);
+        } else {
+            console.log(event.message);
+        }
+    }
+    evtSource.onerror = function (event) {
+        error(event);
+    }
+}
+
 /**
  * 通过fetch去流式读取
  * @param {*} url 
@@ -893,6 +918,7 @@ let fetchEventSource = (url, data, options = {}) => {
         });
     });
 }
+
 //#endregion
 
 export {
@@ -935,6 +961,7 @@ export {
     fileUploadProgress,
     post_machineWriting,
     httpSSERequest,
+    httpSSERequestPoly,
     uploadOSS,
     uploadOSSProgress,
     fetchEventSource

src/view/home.vue

@@ -77,7 +77,7 @@
 import "../assets/css/home.css";
 // import jh_bg from "../assets/img/main/logo-bg.png";
 // import jh from "/static/img/main/logo.png";
-import { endLoading, get, post, httpSSERequest, fetchEventSource } from "../util/http_util";
+import { endLoading, get, post, httpSSERequest, fetchEventSource, httpSSERequestPoly } from "../util/http_util";
 import { queryDictItem } from '../api/dictitem';
 import Push from 'push.js'
 import dayjs from 'dayjs';
@@ -272,36 +272,46 @@ export default {
         const weekList = ['星期日', '星期一', '星期二', '星期三', '星期四', '星期五', '星期六'];
         this.myDate.week = weekList[dayjs().get('day')]
 
-        fetchEventSource("api/api_ws/connect", {}, {
-            onopen: () => {
-                console.log("打开");
-            },
-            onclose: () => {
-                console.log("关闭");
-            },
-            onmessage: (value) => {
-                console.log(value);
-                value = value.replace("data:", "");
-                if (!value) {
-                    return;
-                }
-                this.$notify({
-                    title: '成功',
-                    message: value,
-                    type: 'success'
-                });
-            }
-        }).then(res => {
+        // fetchEventSource("api/api_ws/connect", {}, {
+        //     onopen: () => {
+        //         console.log("打开");
+        //     },
+        //     onclose: () => {
+        //         console.log("关闭");
+        //     },
+        //     onmessage: (value) => {
+        //         console.log(value);
+        //         value = value.replace("data:", "");
+        //         if (!value) {
+        //             return;
+        //         }
+        //         this.$notify({
+        //             title: '成功',
+        //             message: value,
+        //             type: 'success'
+        //         });
+        //     }
+        // }).then(res => {
 
-        }).catch(err => {
+        // }).catch(err => {
 
-        });
+        // });
 
         // httpSSERequest("api/api_ws/connect", (data) => {
         //     console.log(data)
         // }, (err) => {
         //     console.log(err)
         // });
+
+        httpSSERequestPoly("api/api_ws/connect", (data) => {
+            this.$notify({
+                title: '消息',
+                message: data,
+                type: 'success'
+            });
+        }, (err) => {
+            console.log(err)
+        });
     },
     computed: {
         userInfo() {

webpack.config.js

@@ -113,7 +113,7 @@ module.exports = {
         //后台代理
         proxy: {
             '/api/': {
-                target: 'http://localhost:8081',
+                target: 'http://192.168.168.213:8081',
                 ws: true,
                 secure: false,
                 changeOrigin: true,