vue使用封装websocket心跳包

这套代码可以拿过去直接用一些注意我会在下面代码中加上注释:

谢谢支持

核心代码

 //这里需要引入vuex

 import store from './store';

 let wsConnection = {

   $ws: null,

   lockReturn: false,

   timeout: 60 * 1000 * 5,

   timeoutObj: null,

   timeoutNum: null,

   serverTimeoutObj: null,

   //初始化webSocket长连接

   initWebSocket: function () {

     let corpId = localStorage.getItem('corpId');

     let name = localStorage.getItem('username');

     this.$ws = new WebSocket(wsurl);//写入地址 这里的地址可以在initWebSocket方法加入参数

     this.$ws.onopen = this.wsOpen;

     this.$ws.onclose = this.wsClose;

     this.$ws.onmessage = this.wsMsg;

     this.$ws.onerror = this.wsError;

   },

   //打开websocket

   wsOpen: function (e) {

     //开始websocket心跳

     wsConnection.startWsHeartbeat();

     console.log('ws success')

   },

   wsClose: function (e) {

     console.log(e, 'ws close')

   },

   wsMsg: function (msg) {

     //每次接收到服务端消息后 重置websocket心跳

     wsConnection.resetHeartbeat();

     //服务端发送来的消息存到vuex

     store.commit('web_socket_msg', msg)

   },

   wsError: function (err) {

     console.log(err, 'ws error');

     wsConnection.reconnect()

   },

   //重启websocket

   reconnect: function () {

     let _this = this;

     if (_this.lockReturn) {

       return;

     }

     _this.lockReturn = true;

     _this.timeoutNum && clearTimeout(_this.timeoutNum);

     _this.timeoutNum = setTimeout(function () {

       _this.initWebSocket();

       _this.lockReturn = false;

     }, 3000);

   },

   startWsHeartbeat: function () {

     let _this = this;

     _this.timeoutObj && clearTimeout(_this.timeoutObj);

     _this.serverTimeoutObj && clearTimeout(_this.serverTimeoutObj);

     _this.timeoutObj = setInterval(function () {

       //判断websocket当前状态

       if (_this.$ws.readyState != 1) {

         _this.reconnect()

       }

     }, _this.timeout);

   },

   //重置websocket心跳

   resetHeartbeat: function () {

     let _this = this;

     clearTimeout(_this.timeoutObj);

     clearTimeout(_this.serverTimeoutObj);

     _this.startWsHeartbeat()

   }

 };

 //抛出websocket对象

 export default wsConnection

websocket方法调用

 //在main.js引入

 import wsConnection from './vuex/wsStore'

 //挂载vue原型链

 Vue.prototype.$setWs = wsConnection;

 //在使用地方调用

  $this.$setWs.initWebSocket();

 //在需要使用服务端推送过来的消息时

 //在computed方法声明

 getWsMsg() {

    //在核心代码接收到的服务端信息存储到vuex的属性

     return this.$store.state.webSocketMsg

 }

 //在watch方法   监听  getWsMsg

  getWsMsg: function (data, val) {

    console.log(data);

    //.......

 }

此代码为本博主原创,转载请注明出处(支持原创! 谢谢~)

凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~

凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~

凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~

凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~

凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~凑字数~

凑字数

vue使用 封装websocket心跳包

vue使用封装websocket心跳包