update 优化 使用 vueuse 重构 websocket 实现

src/utils/websocket.ts

@@ -22,118 +22,50 @@ import { getToken } from '@/utils/auth';
 import { ElNotification } from 'element-plus';
 import useNoticeStore from '@/store/modules/notice';
 
-let socketUrl: any = ''; // socket地址
-let websocket: any = null; // websocket 实例
-let heartTime: any = null; // 心跳定时器实例
-let socketHeart = 0 as number; // 心跳次数
-const HeartTimeOut = 10000; // 心跳超时时间 10000 = 10s
-let socketError = 0 as number; // 错误次数
-
 // 初始化socket
 export const initWebSocket = (url: any) => {
   if (import.meta.env.VITE_APP_WEBSOCKET === 'false') {
     return;
   }
-  socketUrl = url;
+  url = url + '?Authorization=Bearer ' + getToken() + '&clientid=' + import.meta.env.VITE_APP_CLIENT_ID
-  // 初始化 websocket
+  useWebSocket(url, {
-  websocket = new WebSocket(url + '?Authorization=Bearer ' + getToken() + '&clientid=' + import.meta.env.VITE_APP_CLIENT_ID);
+    autoReconnect: {
-  websocketonopen();
+      // 重连最大次数
-  websocketonmessage();
+      retries: 3,
-  websocketonerror();
+      // 重连间隔
-  websocketclose();
+      delay: 1000,
-  sendSocketHeart();
+      onFailed() {
-  return websocket;
+        console.log('websocket重连失败');
-};
+      },
-
+    },
-// socket 连接成功
+    heartbeat: {
-export const websocketonopen = () => {
+      message: JSON.stringify({type: 'ping'}),
-  websocket.onopen = function () {
+      // 发送心跳的间隔
-    console.log('连接 websocket 成功');
+      interval: 10000,
-    resetHeart();
+      // 接收到心跳response的超时时间
-  };
+      pongTimeout: 2000,
-};
+    },
-
+    onConnected() {
-// socket 连接失败
+      console.log('websocket已经连接');
-export const websocketonerror = () => {
+    },
-  websocket.onerror = function (e: any) {
+    onDisconnected() {
-    console.log('连接 websocket 失败', e);
+      console.log('websocket已经断开');
-  };
+    },
-};
+    onMessage: (_, e) => {
-
+      if (e.data.indexOf('ping') > 0) {
-// socket 断开链接
+        return;
-export const websocketclose = () => {
+      }
-  websocket.onclose = function (e: any) {
+      useNoticeStore().addNotice({
-    console.log('断开连接', e);
+        message: e.data,
-  };
+        read: false,
-};
+        time: new Date().toLocaleString()
-
+      });
-// socket 重置心跳
+      ElNotification({
-export const resetHeart = () => {
+        title: '消息',
-  socketHeart = 0;
+        message: e.data,
-  socketError = 0;
+        type: 'success',
-  clearInterval(heartTime);
+        duration: 3000
-  sendSocketHeart();
+      });
-};
-
-// socket心跳发送
-export const sendSocketHeart = () => {
-  heartTime = setInterval(() => {
-    // 如果连接正常则发送心跳
-    if (websocket.readyState == 1) {
-      // if (socketHeart <= 30) {
-      websocket.send(
-        JSON.stringify({
-          type: 'ping'
-        })
-      );
-      socketHeart = socketHeart + 1;
-    } else {
-      // 重连
-      reconnect();
     }
-  }, HeartTimeOut);
+  });
-};
-
-// socket重连
-export const reconnect = () => {
-  if (socketError <= 2) {
-    clearInterval(heartTime);
-    initWebSocket(socketUrl);
-    socketError = socketError + 1;
-    // eslint-disable-next-line prettier/prettier
-    console.log('socket重连', socketError);
-  } else {
-    // eslint-disable-next-line prettier/prettier
-    console.log('重试次数已用完');
-    clearInterval(heartTime);
-  }
-};
-
-// socket 发送数据
-export const sendMsg = (data: any) => {
-  websocket.send(data);
-};
-
-// socket 接收数据
-export const websocketonmessage = () => {
-  websocket.onmessage = function (e: any) {
-    if (e.data.indexOf('heartbeat') > 0) {
-      resetHeart();
-    }
-    if (e.data.indexOf('ping') > 0) {
-      return;
-    }
-    useNoticeStore().addNotice({
-      message: e.data,
-      read: false,
-      time: new Date().toLocaleString()
-    });
-    ElNotification({
-      title: '消息',
-      message: e.data,
-      type: 'success',
-      duration: 3000
-    });
-    return e.data;
-  };
 };