uni-app websocket心跳检测

// 放入methods里面在 onLoad() 调用即可

connectSocketInit(){

    // 创建一个this.socketTask对象(发送、接收、关闭socket都由这个对象操作)

let userInfo = uni.getStorageSync('hg_cook');

                        //socket地址：ws://xxx.dd.cn:6586

let socket_url = userInfo.socket_url; 

    uni.connectSocket({

        url: socket_url,

        success(data){

            console.log("websocket连接成功",data);

        }

    });

    //监听socket打开

    uni.onSocketOpen(()=>{

        this.is_opensocket=true

        //console.log('WebSocket连接已打开！');

        this.connectSocketInit();

    });

    //监听socket关闭

    uni.onSocketClose(()=>{

        this.is_opensocket=false;

        this.connectSocketInit()

        console.log('WebSocket连接已关闭！')

    });

    //监听socket错误

    uni.onSocketError(()=>{

        this.is_opensocket=false

        this.connectSocketInit()

        console.log('WebSocket连接打开失败');

    });

    uni.onSocketMessage((res)=>{

let str1 = res.data;

let obj = JSON.parse(str1);

//console.log(obj);

//console.log(str.id);

if(obj.receipt){

this.audioPay(obj.receipt);

let heartData = {

orderId:obj.id,

}

uni.sendSocketMessage({

    data: JSON.stringify(heartData),

});

}

    });

    //先确保清除了之前的心跳定时器

    clearInterval(this.pingpangTimes)

// 每过一段时间发送一次心跳，发送Ping,服务器会反馈pong，这样操作以保持socket一直是连接状态，防止断开连接，心跳停止

this.pingpangTimes=setInterval(()=>{

    // 心跳传参

let userInfo = uni.getStorageSync('hg_cook');

//用户ID

let id = userInfo.userId;

let heartData = {

userId:id,

}

    uni.sendSocketMessage({

        data: JSON.stringify(heartData),

        success:(res)=>{

  //其实监听里面有，或者不返回跟后端，用处不大，可以删除

           //console.log('心跳的返回：',res) 

        },

        fail:(res)=>{

            // console.log(res)

            this.is_opensocket=false;

        },

    });

},3000);

},