websocket封装过程是什么？
发布时间：2022-01-11 22:46:48 所属栏目：语言 来源：互联网
导读：今天我们来了解websocket封装的内容，下文给大家分享了websocket封装过程，及引入和使用，需要的朋友可以参考，下面我们一起来学习一下吧。 在一个应用中，websocket一般都是以单例形式存在的，即在整个应用中，websocket实例始终保持唯一。但有时我们要用到
|
今天我们来了解websocket封装的内容，下文给大家分享了websocket封装过程，及引入和使用，需要的朋友可以参考，下面我们一起来学习一下吧。 在一个应用中，websocket一般都是以单例形式存在的，即在整个应用中，websocket实例始终保持唯一。但有时我们要用到websocket实例的时候，可能websocket还没实例化，所以要做成异步的形式来获取实例。 一、封装。先创建 socket.ts 文件 import EventEmitter from 'events'; // 这里用到了 events 包 const ee = new EventEmitter(); class Ws { private wsUrl: string = ''; private socket: WebSocket | undefined; // socket实例 private lockReconnect: boolean = false; // 重连锁 private timeout: NodeJS.Timeout | undefined; // 初始化socket，一般在应用启动时初始化一次就好了，或者需要更换wsUrl public init(wsUrl: string) { this.wsUrl = wsUrl; this.createWebSocket(); } // 获取socket实例 public getInstance(): Promise<WebSocket> { return new Promise((resolve, reject) => { if (this.socket) { resolve(this.socket); } else { ee.on('socket', (state: string) => { if (state === 'success') { resolve(this.socket); } else { reject(); } }); } }); } // 创建socket private createWebSocket() { try { console.log('websocket 开始链接'); const socket = new WebSocket(this.wsUrl); socket.addEventListener('close', () => { console.log('websocket 链接关闭'); this.socket = undefined; this.reconnect(); }); socket.addEventListener('error', () => { console.log('websocket 发生异常了'); this.socket = undefined; this.reconnect(); }); socket.addEventListener('open', () => { // 可在此进行心跳检测 // this.heartCheck.start(); console.log('websocket open'); this.socket = socket; ee.emit('socket', 'success'); }); socket.addEventListener('message', (event) => { console.log('websocket 接收到消息', event); }); } catch (e) { console.log('socket catch error', e); this.reconnect(); } } // 重连 private reconnect() { if (this.lockReconnect) { return; } console.log('websocket 正在重新连接'); this.lockReconnect = true; //没连接上会一直重连，设置延迟避免请求过多 this.timeout && clearTimeout(this.timeout); this.timeout = setTimeout(() => { this.createWebSocket(); this.lockReconnect = false; }, 5000); } } export default new Ws(); 二、引入并使用 import socket from '@/utils/ws'; socket .getInstance() .then((ws) => { // 这里的 ws 就是实例化后的 websocket，可以直接使用 websocket 原生 api console.log('getInstance ws', ws); ws.addEventListener('message', (event) => { console.log('ws 接收到消息', event); }); }) .catch(() => {}); （编辑：52站长网） 【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容! |
