10;

this.createWebsocket(url);await

this.closeWebsocket();this.createWebsocket(url);}//

(url)

WebSocket(url);this.websocket.onopen

{this.onOpen();};this.websocket.onmessage

{this.onMessage(e);};this.websocket.onerror

{this.onError();};this.websocket.onclose

连接成功*/onOpen

{console.info(ws重连第【${this.reConnectTimes}】次连接成功****${this.websocket.url}****${NowFormatter});}

else

{console.info(ws连接成功****${this.websocket.url}****${NowFormatter});this.reConnectTimes

0;}//

注册onWsOpen方法this.currentComponent.onWsOpen();}/***

收到消息*

{console.info(ws收到消息****${this.websocket.url}****${e.data});//

注册onWsMessage方法接收消息this.currentComponent.onWsMessage(e.data);}/***

连接失败*

this.formatDateTime();console.error(ws连接失败****${this.websocket.url}****${NowFormatter});if

(!this.wsInterVal)

{this.setWsInterval();return;}//

(this.reConnectTimes

{console.error(ws重连第【${this.reConnectTimes}】次失败,不再连接:****${this.websocket.url}****${NowFormatter});this.clearWsInterval();}}/***

设置定时器*/setWsInterval

{console.info(设置定时器);this.reConnect();this.wsInterVal

setInterval(()

this.formatDateTime();this.reConnectTimes

1;console.info(ws重连正在尝试第【${this.reConnectTimes}】次连接:****${this.websocket.url}****${NowFormatter});this.initWebsocket(this.currentComponent,

{console.info(清除定时器);clearInterval(this.wsInterVal);this.wsInterVal

null;}/***

{console.info(关闭websocket);this.websocket

this.websocket.close();this.websocket

关闭连接onClose

this.formatDateTime();console.error(ws断开连接****${NowFormatter});}/***

发送心跳*

{console.info(sendHeartBeat${JSON.stringify(data)});this.websocket.send(JSON.stringify(data));}}/***

格式化new

${Now.getFullYear()}-${Now.getMonth()

1}-${Now.getDate()}

${Now.getHours()}:${Now.getMinutes()}:${Now.getSeconds()}:${Now.getMilliseconds()};}

export

common/ce-websocket-util;2.2、创建连接初始化数据

CeWebsocketUtil.initWebsocketData(this,

URL);2.3、

CeWebsocketUtil.sendHeartBeat({

rule:

CeWebsocketUtil.closeWebsocket();