websocket 连接测试

src/utils/websocket.js

+export default {
+  listen(url, messageCallback, openCallback, closeCallback, errorCallback) {
+    if (typeof WebSocket === "undefined") {
+      console.log("您的浏览器不支持WebSocket");
+      return;
+    } else {
+      let protocol = "ws";
+      let newUrl = "";
+      if (window.location.protocol == "https:") {
+        protocol = "wss";
+      }
+
+      let env = process.env.NODE_ENV;
+      switch (env) {
+        case 'development':
+          newUrl = `${protocol}://47.92.48.137:4002/${url}`;
+          break;
+        case 'production':
+          newUrl = `${protocol}://${window.location.host}/${url}`;
+          break;
+      }
+
+      const ws = new WebSocket(newUrl);
+      ws.onopen = () => {
+        if (openCallback) openCallback();
+      };
+      ws.onclose = () => {
+        if (closeCallback) closeCallback();
+      };
+      ws.onerror = () => {
+        if (errorCallback) errorCallback();
+      };
+      ws.onmessage = (event) => {
+        try {
+          if (event?.data) {
+            const data = JSON.parse(event.data);
+            messageCallback(data);
+          }
+        } catch (e) {
+          console.log(e);
+        }
+      };
+      return ws;
+    }
+  },
+};

src/views/sjfx/components/messageRemind.vue

@@ -53,26 +53,47 @@
 </template>
 
 <script>
+import websocket from "@/utils/websocket.js";
+
 export default {
   data() {
-    return {};
+    return {
+      ws: null,
+    };
+  },
+  beforeDestroy() {
+    this.closeWebSocket();
   },
   mounted() {
     // this.getLists();
+    // this.wsFn();
   },
   methods: {
-    getLists() {
-      this.$nextTick(() => {
-        jQuery(".messageClass").slide({
-          mainCell: ".infoListUl",
-          autoPage: true,
-          effect: "top",
-          autoPlay: true,
-          scroll: 6,
-          vis: 6,
-        });
-      });
+    closeWebSocket() {
+      if (this.ws && this.ws.readyState <= 1) this.ws.close();
+    },
+    wsFn() {
+      let url = "ws/asset";
+      this.ws = websocket.listen(url, this.websocketCB, this.websocketErrCB);
+    },
+    websocketCB(data) {
+      // console.log("data", data);
+    },
+    websocketErrCB(err) {
+      // console.log("err", err);
     },
+    // getLists() {
+    //   this.$nextTick(() => {
+    //     jQuery(".messageClass").slide({
+    //       mainCell: ".infoListUl",
+    //       autoPage: true,
+    //       effect: "top",
+    //       autoPlay: true,
+    //       scroll: 6,
+    //       vis: 6,
+    //     });
+    //   });
+    // },
   },
 };
 </script>