perf: 优化websocket连接机制

zhuanyedecainiao · Apr 2, 2022 · 9a0a04e · 9a0a04e
1 parent 813a49b
commit 9a0a04e
Show file tree

Hide file tree

Showing 4 changed files with 18 additions and 8 deletions.
diff --git a/resources/assets/js/pages/manage.vue b/resources/assets/js/pages/manage.vue
@@ -668,6 +668,13 @@ export default {
             immediate: true
         },
 
+        userId: {
+            handler() {
+                this.$store.dispatch("websocketConnection")
+            },
+            immediate: true
+        },
+
         wsMsg: {
             handler(info) {
                 const {type, action} = info;

diff --git a/resources/assets/js/pages/manage/components/FileContent.vue b/resources/assets/js/pages/manage/components/FileContent.vue
@@ -126,6 +126,7 @@ export default {
                     return true
                 }
             }
+            this.$store.dispatch("websocketConnection")
         }
     },
 
@@ -269,10 +270,6 @@ export default {
                 this.loadContent--;
                 this.contentDetail = data.content;
                 this.updateBak();
-                //
-                if (this.$isSubElectron) {
-                    this.$store.dispatch("websocketConnection")
-                }
             }).catch(({msg}) => {
                 $A.modalError(msg);
                 this.loadIng--;

diff --git a/resources/assets/js/store/actions.js b/resources/assets/js/store/actions.js
@@ -277,7 +277,6 @@ export default {
             state.userIsAdmin = $A.inArray('admin', userInfo.identity);
             $A.setStorage("userInfo", state.userInfo);
             dispatch("getBasicData");
-            dispatch("websocketConnection");
             resolve()
         });
     },
@@ -2170,6 +2169,9 @@ export default {
         url = url.replace("http://", "ws://");
         url += "?action=web&token=" + state.userToken;
         //
+        const wsRandom = $A.randomString(16);
+        state.wsRandom = wsRandom;
+        //
         state.ws = new WebSocket(url);
         state.ws.onopen = (e) => {
             // console.log("[WS] Open", $A.formatDate())
@@ -2181,7 +2183,7 @@ export default {
             //
             clearTimeout(state.wsTimeout);
             state.wsTimeout = setTimeout(() => {
-                dispatch('websocketConnection');
+                wsRandom === state.wsRandom && dispatch('websocketConnection');
             }, 3000);
         };
         state.ws.onerror = (e) => {
@@ -2190,7 +2192,7 @@ export default {
             //
             clearTimeout(state.wsTimeout);
             state.wsTimeout = setTimeout(() => {
-                dispatch('websocketConnection');
+                wsRandom === state.wsRandom && dispatch('websocketConnection');
             }, 3000);
         };
         state.ws.onmessage = (e) => {
@@ -2453,6 +2455,9 @@ export default {
      * @param state
      */
     websocketClose({state}) {
-        state.ws && state.ws.close();
+        if (state.ws) {
+            state.ws.close();
+            state.ws = null;
+        }
     }
 }
diff --git a/resources/assets/js/store/state.js b/resources/assets/js/store/state.js
@@ -43,6 +43,7 @@ const stateData = {
     wsMsg: {},
     wsCall: {},
     wsTimeout: null,
+    wsRandom: 0,
     wsOpenNum: 0,
     wsListener: {},
     wsReadTimeout: null,