1. class websocketUtil {
    2.     constructor(url, time) {
    3.         this.is_open_socket = false //避免重复连接
    4.         this.url = url //地址
    5.         this.data = null
    6.         //心跳检测
    7.         this.timeout= time //多少秒执行检测
    8.         this.heartbeatInterval= null //检测服务器端是否还活着
    9.         this.reconnectTimeOut= null //重连之后多久再次重连
    11.         try {
    12.             return this.connectSocketInit()
    13.         } catch (e) {
    14.             console.log('catch');
    15.             this.is_open_socket = false
    16.             this.reconnect();
    17.         }
    18.     }
    20.     // 进入这个页面的时候创建websocket连接【整个页面随时使用】
    21.     connectSocketInit() {
    22.         this.socketTask = uni.connectSocket({
    23.             url: this.url,
    24.             success:()=>{
    25.                 console.log("正准备建立websocket中...");
    26.                 // 返回实例
    27.                 return this.socketTask
    28.             },
    29.         });
    30.         this.socketTask.onOpen((res) => {
    31.             console.log("WebSocket连接正常！");
    32.             clearTimeout(this.reconnectTimeOut)
    33.             clearTimeout(this.heartbeatInterval)
    34.             this.is_open_socket = true;
    35.             this.start();
    36.             // 注：只有连接正常打开中 ，才能正常收到消息
    37.             this.socketTask.onMessage((res) => {
    38.                 console.log(res.data)
    39.             });
    40.         })
    41.         // 监听连接失败，这里代码我注释掉的原因是因为如果服务器关闭后，和下面的onclose方法一起发起重连操作，这样会导致重复连接
    42.         // uni.onSocketError((res) => {
    43.         //     console.log('WebSocket连接打开失败，请检查！');
    44.         //     this.is_open_socket = false;
    45.         //     this.reconnect();
    46.         // });
    47.         // 这里仅是事件监听【如果socket关闭了会执行】
    48.         this.socketTask.onClose(() => {
    49.             console.log("已经被关闭了")
    50.             this.is_open_socket = false;
    51.             this.reconnect();
    52.         })
    53.     }
    55.     //发送消息
    56.     send(value){
    57.         // 注：只有连接正常打开中 ，才能正常成功发送消息
    58.         this.socketTask.send({
    59.             data: value,
    60.             async success() {
    61.                 console.log("消息发送成功");
    62.             },
    63.         });
    64.     }
    65.     //开启心跳检测
    66.     start(){
    67.         this.heartbeatInterval = setTimeout(()=>{
    68.             this.data={value:"传输内容",method:"方法名称"}
    69.             console.log(this.data)
    70.             this.send(JSON.stringify(this.data));
    71.         },this.timeout)
    72.     }
    73.     //重新连接
    74.     reconnect(){
    75.         //停止发送心跳
    76.         clearInterval(this.heartbeatInterval)
    77.         //如果不是人为关闭的话，进行重连
    78.         if(!this.is_open_socket){
    79.             this.reconnectTimeOut = setTimeout(()=>{
    80.                 this.connectSocketInit();
    81.             },3000)
    82.         }
    83.     }
    84. }
    86. module.exports = websocketUtil
    1. //    在测试环境时url可以写成  ws://xxx:3100/connect/websocket
    2. new wsRequest("ws://xxx:3100/connect/websocket",5000)
    4. //    发布体验版或正式版，url一定要写成  wss://xxx:3100/connect/websocket
    5. new wsRequest("wss://xxx:3100/connect/websocket",5000)
    7. //    除此之外，还需要在微信管理平台中对小程序的开发–>开发管理–>开发设置–>服务器域名 加入socket配置

    烈阳，（uni-app使用websocket（封装、心跳检测））