在一个应用中,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(() => {});
以上就是记录一次websocket封装的过程的详细内容,更多关于websocket封装的资料请关注其它相关文章!
标签:
websocket,封装
免责声明:本站文章均来自网站采集或用户投稿,网站不提供任何软件下载或自行开发的软件!
如有用户或公司发现本站内容信息存在侵权行为,请邮件告知! 858582#qq.com
暂无“记录一次websocket封装的过程”评论...
RTX 5090要首发 性能要翻倍!三星展示GDDR7显存
三星在GTC上展示了专为下一代游戏GPU设计的GDDR7内存。
首次推出的GDDR7内存模块密度为16GB,每个模块容量为2GB。其速度预设为32 Gbps(PAM3),但也可以降至28 Gbps,以提高产量和初始阶段的整体性能和成本效益。
据三星表示,GDDR7内存的能效将提高20%,同时工作电压仅为1.1V,低于标准的1.2V。通过采用更新的封装材料和优化的电路设计,使得在高速运行时的发热量降低,GDDR7的热阻比GDDR6降低了70%。
更新动态
20240518
20240518
- 群星《承欢记 电视剧影视原声带》[320K/MP3][109.99MB]
- 【欧美乡村】JohnnyLee-2024-13thOfJulyandEmotions(FLAC)
- 【流行爵士】PattiAustin-2024-LoveSongs(FLAC)
- 【爵士乐】VA-2024-SupremeLoungeChillSelectionJazzyVibeTunes(FLAC)
- 群星《承欢记 电视剧影视原声带》[FLAC/分轨][219.8MB]
- 群星《乘风2024 第1期》[320K/MP3][110.09MB]
- 群星《乘风2024 第1期》[FLAC/分轨][322.4MB]
- 【古典音乐】卡拉扬《莫扎特·魔笛(全剧)》2CD.2015[FLAC+CUE整轨]
- Yurika《ただいま》【Hi-Res】24bit-96kHz【flac】
- 张琍敏2006-金鼎奖系列14[台湾版]CD1[WAV+CUE]
- 林一峰2008-城市旅人[香港首版][WAV+CUE]
- 群星1990-六个梦电视原声带[日本版][WAV+CUE]
- [In-Akustik7801]KissedByASong-《Dynaudio丹拿发烧示范盘》(2014)HQCD[WAV+CUE]
- 群星《17号音乐仓库2 第10期》[320K/MP3][66.53MB]
- 群星《17号音乐仓库2 第10期》[FLAC/分轨][163.67MB]