首先new一个webscoket的连接

 this.noticeSocketLink = new WebSocket(‘webSocket的地址’)

 

这里是连接成功之后的操作

linkNoticeWebsocket(){

        this.noticeSocketLink.onopen = ()=>{

　　在连接成功打开的时候调用短线重连的函数

          this.webCloseLink(this.noticeSocketLink)

        }

        this.noticeSocketLink.onmessage = res => {}

        this.noticeSocketLink.onclose = res => {

          console.log(“websocket is closed”)

        }

      },

//断开连接
webCloseLink(WebSocketId){
let _self = this;

每个15秒发送一次心跳包
WebSocketId.send(JSON.stringify({“心跳包的内容要与后台商量确定”))
let hb = setInterval(function(){
WebSocketId.send(JSON.stringify({code:999,data:_self.userInfo.id}))

检测到websocket连接断开
if(WebSocketId.readyState == 2 || WebSocketId.readyState == 3){
clearInterval(_self.hb)
let i = 1
let myVar = setInterval(function(){
if(WebSocketId.readyState == 2 || WebSocketId.readyState == 3){

重新new一个websocket的连接
_self.noticeSocketLink = new WebSocket(WebSocketId.url);
WebSocketId = _self.noticeSocketLink;
if(i == 5){
clearInterval(myVar);
// location.reload();
return
}
i++
}else if(WebSocketId.readyState == 0){

}else if(WebSocketId.readyState == 1){ // websocket重连成功
_self.linkNoticeWebsocket();
clearInterval(hb)
clearInterval(myVar)
}
},4*1000)
}
}, 15000)
},

版权声明：本文为qisimx原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。
本文链接：https://www.cnblogs.com/qisimx/p/10518355.html