src/socket/index.js
@@ -1,31 +1,20 @@
import { FYWebSocket } from '@/socket/FYWebSocket.js'
import eventBus from '@/socket/eventBus.js';
import { FYWebSocket } from '@/socket/FYWebSocket.js';
import MessageManager from '@/socket/MessageManager.js';
let socket = null;
// 连接websocket
function connectWebSocket() {
  if (socket == null) {
    socket = new FYWebSocket()
  }
  socket.init({
    time: 4 * 1000,
    timeout: 2 * 1000,
    reconnect: 3 * 1000
  }, true)
  socket = new FYWebSocket();
  socket.init(() => {
    connectWebSocket();
  }, MessageManager);
  return socket;
}
// 断线重连websocket
function startReconnectWebSocket() {
  eventBus.register('reconnect', () => {
    connectWebSocket()
  })
}
/**
 * 初始化socket客户端
 */
function initSocketClient() {
  connectWebSocket();
  startReconnectWebSocket();
}
export { initSocketClient }
export { initSocketClient };