| | |
| | | |
| | | 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 }; |