uniapp封装websocket以及心跳检测、重连

websocket 封装

在所需文件夹下建立websocketUtils.js文件，封装代码如下：

class websocketUtils {
constructor(openId, time) {
this.url = `wss://****` //ws地址 拼接一下 此处用的是openId
this.data = null
        this.isOpenSocket = false //避免重复连接
this.timeout = time //隔多久执行检测 单位秒（s）
this.heartbeatInterval = null //检测服务器端是否还存活
this.reconnectTimeOut = null //重连之后隔多久才再次重连
try {
return this.connectSocketInit()
} catch (e) {
console.log('===========连接错误捕获catch====================',e);
this.isOpenSocket = false
this.reconnect();
}
}
// 创建websocket连接
connectSocketInit() {
this.socketTask = uni.connectSocket({
url: this.url,
      header: {
        //头部可以添加所需字段如token
        'content-type': 'application/json'
      },
success:()=>{
console.log("============正准备建立websocket中================");
// 返回实例
return this.socketTask
},
});
this.socketTask.onOpen((res) => {
console.log("==============WebSocket连接正常=============");
clearTimeout(this.reconnectTimeOut)
clearInterval(this.heartbeatInterval)
this.isOpenSocket = true;
this.start();
// 只有连接正常打开中 ，才能正常收到消息
this.socketTask.onMessage((res) => {
console.log(res.data,'===============接收===onMessage===============')
            //全局注册uniapp事件，在任何页面都能接受到
        uni.$emit('socketMessage', res)
});
})
// 监听失败，再次打开 判断主动重连
// uni.onSocketError((res) => {
// console.log('==========WebSocket连接打开失败哦===============');
 //this.isOpenSocket = false;
 //this.reconnect();
// });
//  socket关闭了会执行 此处
this.socketTask.onClose((e) => {
console.log("========已经被关闭了====================",e)
this.isOpenSocket = false;
            // 加了flag判断是否为手动（用户主动关闭）
e && e.reason == 'user' ? '' : this.reconnect();
})
}
//发送消息
send(value){
//  连接正常打开时 ，才能正常成功发送消息
this.socketTask.send({
data: value,
async success() {
console.log("===========消息发送成功===============");
},
});
}
//开启心跳检测
start(){
    this.data={value:"发送心跳内容",method:"发送心跳方法名称"}
this.heartbeatInterval = setInterval(()=>{
console.log('======start====开启心跳检测====',this.data)
this.send(JSON.stringify(this.data));
},this.timeout * 1000)
}
//重新连接
reconnect(){
//停止发送心跳
clearInterval(this.heartbeatInterval)
//如果不是人为关闭的话，进行重连
if(!this.isOpenSocket ){
this.reconnectTimeOut = setTimeout(()=>{
this.connectSocketInit();
},3000)
}
}
  // 关闭 WebSocket 连接
  closeSocket(reason = '关闭') {
    const _this = this
    this.socketTask.close({
      reason,
      success() {
        _this.data = null
        _this.isOpenSocket = false
        _this.socketTask = null
        clearTimeout(_this.reconnectTimeOut)
        clearInterval(_this.heartbeatInterval)
        console.log('===============关闭 WebSocket 成功===================')
      },
      fail() {
        console.log('===================关闭 WebSocket 失败=====================')
      }
    })
  }
//将获取的消息导出外部
exportMessage(callback) {
this.socketTask.onMessage((res) => {
      console.log(res,'===============exportMessage============')
return callback(res)
})
}
}
 
 
module.exports = websocketUtils 

页面引入使用 

全局引入：

1.在main.js中引入，并全局注册

//引入websocket文件
import websocketUtils from '@/utils/websocketUtils.js'

//挂载并开启websocket
Vue.prototype.$socketUtils = new websocketUtils("*******",10)

 2.指定页面中使用

// 发送消息
let data={value:"发送的value"}
this.$socketUtils.send(JSON.stringify(data));

// 接收消息
this.$socketUtils.exportMessage(res=>{
console.log(res);
})

 单页面使用引入：

<!--  页面  -->
<template>
  <view class='e-about-operation-wrap'>
  </view>
</template>

<script>
  import websocketUtils  from '@/utils/websocketUtils.js'
  const app = getApp()
  export default {
    name: 'ESign',
    components: {},
    data() {
      return { };
    },
    onLoad: function(option) {
    },
    onShow: function() {
      //在uniapp全局中定义了socketWBObj变量
      app.globalData.socketWBObj = new websocketUtils(this.user.loginInfo.openId,10)
      //监听获取消息
      uni.$on('socketMessage', this.wbSocketGetMsg)
      //方法获取收到的消息
      app.globalData.socketWBObj.exportMessage(res => {
console.warn(res);
  })
    },
    onHide: function() {
      
    },
    onUnload(e) {
     
    },
    created() {},
    mounted() {
    },
    methods: {
      wbSocketGetMsg(res){
        const _this = this
        console.log(res,'======wbSocketGetMsg==========')
        // 关闭连接
        if (app.globalData.socketWBObj) {
           app.globalData.socketWBObj.closeSocket('user')
        }
      }
    },
    watch: {},
    computed: {},
  }
</script>
<style lang='scss' scoped>
.e-about-operation-wrap{
  
}
</style>

原文地址：https://blog.csdn.net/qianqianNingmeng/article/details/137218196

免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！