Socket-webox NPM

安装

socket-webox是一个前端WebSocket工具库，提供管理WebSocket实例的api。结合事件中心，来对后端推送消息进行分类派发。

可实现灵活的心跳检测机制，区分网络网络差、客户端掉网。避免因网络暂时的拥挤导致的重连，可为网络不佳环境动态修改心跳间隔。
提供创建socket-webox实例的工厂函数，如果浏览器不兼容会返回null。提供服务中断重连api，重连自动销毁旧连接资源，并将旧事件回调应用到新连接上。使用更方便。
排除声明文件，代码仅7kb不到，gzip后3kb不到。

# 本地安装
npm i socket-webox -S

前端原生WebSocket的一些问题

websocket和http一样是应用层协议，在传输层使用了TCP。但地址以ws:或wss:开头。它与http的区别在于，websocket可以互相发起请求。当有新消息时，服务器主动通知客户端，无需客户端主动向服务器询问。

无法准时判断网络状态，没有探测服务器存活的官方api。在网络暂时不佳、或者浏览器断网、服务器未通知前端就关闭了连接的情况下，WebSocket实例的readyState依旧为open状态，依旧认为自己可以收到服务器的推送信息。
在使用组件化开发的框架时，往往不同的业务组件需要接收各自的WebSocket消息，每个WebSocket实例只有一个message事件回调，组件间共用时，它们都可以监听到其它组件的更新信息。
当后端关闭websocket通道后（或服务中断下线），前端WebSocket实例的readyState变为close状态，但实例依旧存在。即使后端恢复了，该WebSocket实例也无法再使用。
需要考虑的边界情况分散：初始化前，需要手动判断当前浏览器是否兼容；实例化时，需要通过监听实例error事件来检测连接错误；后端服务中断则需要监听close事件；WebSocket实例无法及时检测设备端网络不佳、网络断线的情况。

socket-webox特点

使用上：将WebSocket与事件中心整合，让其更好用，只需初始化实例，然后监听事件即可。

功能上：提供声明式api，且涵盖WebSocket的全生命周期。从判断浏览器是否兼容、到异常后找到实例把注册的事件一个个解除。这些能力只需调用一个api即可。

socket-webox不与任何框架耦合，原生环境可用，但在组件化的框架中使用会有更好的体验。注意，开发时使用了主流的ES6+语法，在旧浏览器中可能无法正常运行。
设计上以扩展原生的WebSocket为主，例如初始化参数、事件的触发流程均看齐原生的WebSocket。

使用特点

socket-webox使用上，主要就是监听事件，在事件回调里进行业务操作或者对实例进行配置。可监听的事件分两类：

后端推送消息事件，会进行一对一的事件派发，具体业务注册对应的监听事件。该事件可随组件销毁而取消。
WebSocket生命周期事件，会代理触发websocket的原生事件: open（打开）、error（服务错误）、close（关闭），并增加了服务器心跳应答超时事件，结合灵活的api可辨别客户端网络不佳、掉线的情况。
PS：所有事件只能监听注册和取消，不能通过外部手动来派事件。事件派发只能是内部来处理。

功能特点

渐进式使用体验设计：

使用上和原生的WebSocket类似，初始化，然后监听事件即可。只是要和后端沟通好数据推送的格式。
如果需要心跳检测，传递第二个参数，然后监听心跳应答超时事件即可。

更精细的后端推送事件派发：

只需一个WebSocket连接实例，即可对多个业务组件进行一对一的消息派发，不同组件监听对应的事件即可。
当组件销毁时，可在其销毁钩子中，解除对应的事件监听。

灵活的心跳检测机制：

可设置连续应答超时一定次数后，才派发心跳应答超时事件，防止因为网络暂时不佳而触发重连，此时重连会占用更多的网络资源，失败概率大。
可在应答超时事件派发时，提醒用户网络差，然后设置更久的应答等待时间，适应网络不佳的环境。通过判断应答超时事件触发阈值，以提示用户，可能已经断网。
每次重新启动心跳检测时，会先自动停止正在运行的心跳检测，代码更健壮。

实例销毁更简单：

提供销毁的接口，会把所有的实例监听的原生事件、心跳检测定时器、事件中心注册的事件全部销毁。
发起连接的api可调用多次，以实现服务中断重连。并且每次重连都会先清除旧WebSocket实例的资源，并将已注册的事件应用到新的实例上。

typescript类型提示：

可设置前后端发送消息时，数据的类型结构。
提供open、error、close、心跳应答超时事件名的类型对象，导入后即可使用，无需担心拼写错误。

错误处理：

初始化WebSocket的地址无法连接，事件中心会派发error事件。然后派发close事件。后端中断服务，不会触发error事件，只会触发close事件，并且实例无法再通讯。与原生实例流程一致。
如果客户端不支持WebSocket，实例化时会抛出异常，阻止代码往下执行。socket-webox提供返回一个socket-webox实例的函数，如果浏览器不支持则返回null，否则正常返回socket-webox实例。

使用示例：

使用约束：后端推送的WebSocket消息必须为对象类型，且对象里包含一个标记每次消息类型的字段。

socket-webox使用typescript开发，有对应的声明文件，但示例使用js。

初始化

import initSocket from 'socket-webox'; // 导入初始化一个socket-webox的工厂函数
const initSocketOptions = {
    // websocke连接地址，必传
    url: "ws://127.0.0.1:7070/ws/?name=greaclar",
    // websocke连接子协议，非必传
    protocols: string,
    // 后端每次推送的消息中，标记此次消息的类型的属性名，必传
    // 该属性的值会作为事件名派发事件，并把此次消息作为参数调用事件回调。
    receiveEventKey: 'msgID'
}

// 初始化socket-webox实例
const ws = initSocket(initSocketOptions); 

// 如果浏览器不支持WebSocket，会返回null
if (ws == null) {
    console.log('初始化WebSocket连接失败。您的浏览器不支持。');
} else {
    // 发起连接
	ws.connect();
    // 获取当前WebSocket实例
    console.log(ws.getWebSocket());
}

销毁实例

当实例不需要时（发生错误，连接不可用等），可将实例内的资源释放（解除相关事件的监听及相关定时器、关闭WebSocket实例与后端的连接）：

const ws = initSocket(initSocketOptions); 
ws.dispose();

监听后端websocket消息推送

假设后端websocket服务会不定时推送以下消息：
```
{"msgID": "update-test1", "msg": "hellow"}
```

在任意模块下，通过实例上的on来监听具体的消息推送：

// 每次后端推送以上信息，这里的回调就会触发，
// 也就是说只要返回的消息中，msgID为update-test1，对应的回调就会触发
const callbackFn = (data) => {
    this.msg = data; // data: {msgID: 'update-test1', msg: 'hellow'}
}
ws.on('update-test1', callbackFn);

解除监听：当前端不需要监听该推送事件了，通过off来解除：

// 解除所有通过updata-test1注册的回调函数
ws.off('update-test1');

// 也可以只解除某个回调
ws.off('update-test1', callbackFn);

监听WebSocket实例钩子

可监听的钩子有：

打开事件：当WebSocket成功连接上后端服务时。
关闭事件：后端服务突然断开时，或突然发生错误意外断开。
错误事件：当WebSocket实例发生错误，如初始化时的地址不可用。

心跳应答超时事件：启动心跳检测后，当服务器的心跳应答包无法按时推送到浏览器触发。

socket-webox为所有事件提供一个映射对象，来找到对应的事件名，导入即可使用。

// 'socket-webox';
// ws实例生命周期内会触发的事件
export const WSEventsMap = {
    open: 'inner:open', // 打开事件
    close: 'inner:close', // 关闭事件
    error: 'inner:error', // 错误事件
    heartbeatOvertime: 'inner:heartbeatOvertime' // 心跳应答超时事件
}

使用示例：

import initSocket, { WSEventsMap } from 'socket-webox';
import { Message } from 'element-ui';

// 初始化一个socket-webox实例，并注册事件
export function newSocketWebox() {
    // 初始化socket-webox实例
    const ws = initSocket({
        url: "ws://127.0.0.1:7070/ws/?user_name=user1",
        receiveEventKey: 'msgID'
    }); 
    
    // 如果浏览器不支持WebSocket，会返回null
    if (ws == null) {
        Message('初始化WebSocket连接失败。您的浏览器不支持。');
        return null;
    }

    // 监听ws的打开事件，当ws打开成功后调用
    ws.on(WSEventsMap.open, () => {
        Message('WebSocket 连接成功。');
    });
    
    // 监听当前WebSocket实例连接关闭事件。初始连接失败会触发error、close、后端中断只会触发close
    ws.on(WSEventsMap.close, () => {
        Message.error('WebSocket 网络已断开。');
    })

    // 监听当前WebSocket实例的错误事件。当WebSocket实例出现错误调用，如初始化的地址无法连接
    ws.on(WSEventsMap.error, (error) => {
        console.log('WebSocket error', error);
        Message('WebSocket出现错误。请刷新页面');
    })
    
    // 监听心跳应答超时事件，当心跳包不能按时推送到客户端就会调用。
    ws.on(WSEventsMap.heartbeatOvertime, () => {
        Message('网络拥堵，正在检测网络状态。');
    })

    // 发起连接，推荐先注册事件，再发起连接。
    // connect()每次调用都会先销毁旧的WebSocket实例再初始化一个新的。注册的事件会应用到新的实例上。
    ws.connect();
    return ws;
}

配置心跳检测

设置心跳检测，一是让通讯双方确认对方依旧活跃，二是浏览器端及时检测当前网络线路可用性，保证消息推送的及时性。

心跳检测异常，但close事件没有触发，大概率是双方之间的网络线路不佳，如果立马进行重连，会挤兑更多的网络资源，重连的失败概率更大，也可能阻塞用户的其它操作。
如果设备间的网络环境差异大，统一设置较久的心跳等待时间，又无法满足推送及时性。
socket-webox可为网络不佳的环境动态设置更久的心跳应答等待时间，目的就是为不确定的网络环境设置一个缓冲区间。例如一个系统可能部署在不同的单位中，不同单位的网络环境存在差异，各自使用的业务模块对实时性的要求不同，设置缓冲区间就有必要了。

心跳检测需要在初始化实例时，传递第二个参数：

import initSocket, { WSEventsMap } from 'socket-webox';
import { Message } from 'element-ui';

const initSocketOptions = {
    url: "ws://127.0.0.1:7070/ws/?user_name=user1",
    receiveEventKey: 'msgID' // 读取后端推送消息的msgID属性，用来区分消息类型是心跳包还是普通消息
}
const heartbeatOptions = {
    // 定时向后端发送的心跳包内容
    heartbeatMsg: { msgID: 'heartbeat', msg: null },
    // 后端应答心跳包时，标记消息类型为心跳应答的字符串
    // @example
    // 心跳包发送后，后端需要应答的消息如下:
    // { msgID: 'heartbeat', msg: 'answer' }，只要求msgID为'heartbeat'，msg属性可不定义
    receivedEventName: 'heartbeat',
    // 心跳包发送间隔，两次心跳包发送的实际间隔为3000ms，中间需要检测心跳应答情况。
    heartbeatTime: 1500,
    // 当发送心跳包后无应答连续1次后，再派发心跳包应答超时事件。
    // 即允许连续无应答1次，接着第2次无应答则派发心跳应答超时事件。第二次正常应答则忽略。
    // 非必传，默认值 0
    retryMaxTime: 1,
}
const ws = initSocket(initSocketOptions, heartbeatOptions); // 初始化socket-webox实例

然后监听心跳应答超时事件。该事件在心跳包发送后，前端无法在期望时间内接收达到后端应答时触发。并且触发后，心跳检测会自动停止。

// 监听心跳应答超时事件，当心跳应答包不能按时推送到客户端就会调用
ws.on(WSEventsMap.heartbeatOvertime, () => {
    Message('网络拥堵，已停止心跳检测。');
})

心跳检测更多配置-相关api

配置了心跳检测后，socket-webox提供相关的api来判别不同网络环境，以实现灵活的处理：

ws.getHeartbeatTime(); // 获取当前心跳包发送间隔时间
ws.startHeartbeat(); // 启动（重启）心跳检测
ws.pauseHeartBeat(); // 暂停心跳检测
ws.startHeartbeat(1800, 1); // 以1800ms的间隔，允许连续掉包1次（只掉包一次会忽视）的配置，重新启动心跳检测。

处理思路：

设置retryMaxTime参数，允许范围内的无应答次数（心跳应答包在期望时间内未返回），排除网络暂时拥挤，此时不需要处理。
当心跳应答超时事件触发，此时可能是网络差，也可能是浏览器断网了，此时可设置久一点的心跳包发送间隔，并提醒用户网络不佳，可能无法保证推送及时性。
如果后续继续发生无应答事件，且此时的心跳包发送间隔可能已经超过可忍受阈值了，可以判断为网络不可用，需要提醒用户修复网络。
当然也可能是服务器“假死”了，或者未通知前端就关闭了连接，需要尝试重新连接。一般配合服务中断重连进行设置，在下文完整配置中有介绍。

配置：

import initSocket, { WSEventsMap } from 'socket-webox';
import { Message } from 'element-ui';

export function newSocketWebox() {
    const initSocketOptions = {
        url: "ws://127.0.0.1:7070/ws/?user_name=user1",
        receiveEventKey: 'msgID'
    }
    const heartbeatOptions = {
        heartbeatMsg: { msgID: 'heartbeat', msg: null },
        receivedEventName: 'heartbeat',
        heartbeatTime: 1500,
        retryMaxTime: 0, // 一旦发生后端心跳应答超时，就派发心跳应答超时事件
    }
    const ws = initSocket(initSocketOptions, heartbeatOptions);
    
    if (ws == null) {
        Message('初始化WebSocket连接失败。您的浏览器不支持。');
        return null;
    }

    // 监听ws的打开事件，启动心跳检测
    ws.on(WSEventsMap.open, () => {
        Message('WebSocket 连接成功。');
        ws.startHeartbeat(); // 启动心跳检测
    });
    
    // 监听心跳应答超时事件，当心跳应答包不能按时推送到客户端就会调用
    ws.on(WSEventsMap.heartbeatOvertime, () => {
        // 等待应答时间达到阈值，3000ms间隔还发生延迟，说明网络极差，可以判断为断网了。
        if (ws.getHeartbeatTime() >= 3000) { 
           Message.error('线路不通，请检测网络状态。');
           confirm('线路不通，是否重连？') && ws.connect();
           return;
        }
        Message('网络拥堵，正在检测网络状态。');
        // 更新心跳间隔，及心跳应答包连续超时允许次数
        // 每触发一次心跳无应答，就在原来的等待间隔上加500ms，并允许忽略一次
        ws.startHeartbeat(ws.getHeartbeatTime() + 500, 1); 
    })

    ws.connect();
    return ws;
}

配置服务中断重连

当发生意外断线，一般是服务问题，可能是服务停止了，客户端WebSocket会触发close事件，需要前端重新发起连接。

处理思路：

监听关闭事件，当发生关闭事件，则重新发起连接，并记录重连次数，如果重连次数达到阈值，提示用户连接不可用。
原生WebSocket实例中，当初始化的地址无法连接，会先触发error，再触发close事件，但后端中断连接，只会触发close事件。socket-webox也遵守了该流程。一般只要处理close事件即可。
socket-webox实例上提供connect方法，会先销毁旧的WebSocket实例资源，停止心跳检测。再初始化一个新的WebSocket实例。已注册的事件会应用到新的实例上，例如监听的open、error、close事件会被应用到新的连接实例上。

import initSocket, { WSEventsMap } from 'socket-webox';
import { Message } from 'element-ui'

export function newSocketWebox() {
    const initSocketOptions = {
        url: "ws://127.0.0.1:7070/ws/?user_name=user1",
        receiveEventKey: 'msgID'
    }
    const ws = initSocket(initSocketOptions);
    
    if (ws == null) {
        Message('初始化WebSocket连接失败。您的浏览器不支持。');
        return null;
    }
    
    let reConnectCount = 0; // 当WebSocket异常关闭，重新连接的次数
    const reConnectMaxCount = 3; // 最大重连次数
    let reConnectTimmer = null; // 重连计时器，避免重连间隔太短

    // 监听ws的打开事件，重置重试次数
    ws.on(WSEventsMap.open, () => {
        Message.success('WebSocket 连接成功。');
        reConnectCount = 0; // 重置重连次数
    });
    
    // 监听当前WebSocket实例连接关闭事件。初始连接失败会触发error、close、后端中断只会触发close
    ws.on(WSEventsMap.close, () => {
        // 连续重连次数小于最大尝试重连次数
        if (reConnectCount < reConnectMaxCount) {
            // 使用定时器发起重连，防止重连太频繁
            reConnectTimmer = setTimeout(() => {
                reConnectCount++;
                Message('WebSocket 断开连接，正在尝试第' + reConnectCount + '次重新连接。');
                // connect()每次调用都会先销毁旧的WebSocket实例再初始化一个新的。已注册的事件会应用到新的实例上。
                ws.connect();
            }, 500);
        } else {
            Message.error('WebSocket 网络已断开。');
            clearTimeout(reConnectTimmer);
            ws.dispose();
        }
    })

    // 监听当前WebSocket实例的错误事件。当WebSocket实例出现错误调用，如初始化的地址无法连接
    ws.on(WSEventsMap.error, (error) => {
        Message('WebSocket连接出现错误。请刷新页面');
    })

    // 发起连接。
    ws.connect();
    return ws;
}

完整配置

当实例成功连接后，启动心跳检测，确保通讯双方存活。另外需要配置两种边界情况：

当客户端意外被触发close事件，会进行重连，并设置自动重连最大次数阈值。
如果客户端连接成功后，没有被触发close事件，但心跳检测异常：首先会排除网络暂时不佳，如忽略一两次的心跳不应答，设置更久的等待时间，同时提醒用户网络不佳。最后才是销毁旧连接，走重连逻辑。

import initSocket, { WSEventsMap } from 'socket-webox';
import { Message } from 'element-ui'

export function newSocketWebox() {
    const initSocketOptions = {
        url: "ws://127.0.0.1:7070/ws/?user_name=user1",
        receiveEventKey: 'msgID'
    }
    const heartbeatOptions = {
        heartbeatMsg: { msgID: 'heartbeat', msg: null },
        receivedEventName: 'heartbeat',
        heartbeatTime: 1500,
        retryMaxTime: 0, 
    }
    
    let reConnectCount = 0; 
    const reConnectMaxCount = 3; 
    let reConnectTimmer = null; 
    
    const ws = initSocket(initSocketOptions, heartbeatOptions);
    
    if (ws == null) {
        Message('初始化WebSocket连接失败。您的浏览器不支持。');
        return null;
    }
    
    // 监听ws的打开事件，重置重试次数；启动心跳检测
    ws.on(WSEventsMap.open, () => {
        Message.success('WebSocket 连接成功。');
        reConnectCount = 0; // 重置重连次数
        ws.startHeartbeat(); // 启动心跳检测
        // ws.startHeartbeat(1500, 0); // 启动心跳检测时，指定心跳间隔和心跳不应答连续忽略次数
    });
    
    // 监听心跳应答超时事件，当心跳包不能按时推送到客户端就会调用
    ws.on(WSEventsMap.heartbeatOvertime, () => {
        if (ws.getHeartbeatTime() >= 3000) { 
            Message.error('线路不通，请检测网络状态。');
            confirm('线路不通，是否重连？') && ws.connect();
            return;
        }
        Message('网络拥堵，正在检测网络状态。');
        ws.startHeartbeat(ws.getHeartbeatTime() + 500, 1); 
    })
    
    // 监听当前WebSocket实例连接关闭事件。初始连接失败会触发error、close、后端中断只会触发close
    ws.on(WSEventsMap.close, () => {
        if (reConnectCount < reConnectMaxCount) {
            reConnectTimmer = setTimeout(() => {
                reConnectCount++;
                Message('WebSocket 断开连接，正在尝试第' + reConnectCount + '次重新连接。');
                ws.connect();
            }, 500);
        } else {
            Message.error('WebSocket 网络已断开。');
            clearTimeout(reConnectTimmer);
            ws.dispose();
        }
    })

    // 监听当前WebSocket实例的错误事件。当WebSocket实例出现错误调用，如初始化的地址无法连接
    ws.on(WSEventsMap.error, (error) => {
        Message('WebSocket连接出现错误。请刷新页面');
    })

    // 发起连接。
    ws.connect();
    return ws;
}

业务组件A中监听消息推送：

如果是在vue中使用，可挂载到vue原型上，然后各个组件都可访问。

<template>
  <div> test-1:{{ msg }} </div>
</template>

<script>
import { newSocketWebox } from '@/utils/newSocketWebox';
export default {
  name: 'test-1',
  data() {
    return { msg:null }
  },
  mounted() {
    const ws = newSocketWebox();
    if (ws == null) return;
    this.ws = ws;
    // 监听后端类型为'update-test1'的消息推送
    this.ws.on('update-test1', (data) => {
        this.msg = data;
    })
  },
  destory() {
    // this.ws?.off('update-test1') // 解除监听'update-test1'的消息推送
    this.ws?.dispose();
  }
}
</script>

websocket eventbus tools

@everything-registry/sub-chunk-2792

9 months ago

9 months ago

9 months ago

9 months ago

9 months ago

9 months ago

9 months ago