uniapp---初步使用websocket（长链接实现）

onLoad() {
  this.connectSocketInit()
},
  
  
  // // 进入这个页面的时候创建websocket连接【整个页面随时使用】
  connectSocketInit() {
     //判断当前是否有websocket连接，如果有的话不在走创建sock方法
    let socketTaskIsOpen = uni.getStorageSync("socketTaskIsOpen")
    if (socketTaskIsOpen != "") return

    // // 创建一个this.socketTask对象【发送、接收、关闭socket都由这个对象操作】
    this.socketTask = uni.connectSocket({
      // 【非常重要】必须确保你的服务器是成功的,如果是手机测试千万别使用ws://127.0.0.1:9099【特别容易犯的错误】
      url: config.monitorSocketBaseUrl,
      success(data) {
        console.log("是否在线websocket连接成功");
        uni.setStorageSync('socketTaskIsOpen', true)
      },
    })

    //这里对这个方法赋值是为了将这些方法进行拆分，防止一个初始化方法中拥有太多的代码。
    this.socketTaskIsOpen = true;
    this.socketTask.onOpen = this.connectSocketOnOpen();
    this.socketTask.onClose = this.connectSocketonClose()
    this.socketTask.onMessage = this.connectSocketonMessage();
    this.socketTask.onError = this.connectSocketonError()
  },
    
    
    
    // 打开时发送消息
    connectSocketOnOpen(e) {

      // 消息的发送和接收必须在正常连接打开中,才能发送或接收【否则会失败】
   
      // 注：只有连接正常打开中 ，才能正常成功发送消息
      var jsonObject = uni.getStorageSync("MonitorInfo")
      // 如果要将json的格式通过websocket发送过去需要通过
      // json。stringfy() 来进行转化
      var jsonString = JSON.stringify(jsonObject)
      // 这里的timer 组件实现的是一个长链接，通过每间隔一段时间来进行发送数据包。
      this.timer = setInterval(() => {
        try {
          this.getMonitorInfo()
          jsonObject = uni.getStorageSync("MonitorInfo")
          jsonString = JSON.stringify(jsonObject)
          this.socketTask.send({
            data: jsonString,
            async success() {
              console.log("是否在线消息发送成功");
            },
          });
        } catch (err) {
          console.log('是否在线websocket断开了：' + err);
        }
      }, 15000)
    },
      
      
      
      connectSocketonClose(e) {
        // 这里仅是事件监听【如果socket关闭了会执行】
        this.socketTask.onClose(() => {
          uni.setStorageSync('socketTaskIsOpen', false)
          console.log("是否在线websocket已经被关闭了")
        })
      },
        
        
        //监听服务器事件
        connectSocketonMessage(e) {},
          
          
          //连接建立失败重连
          connectSocketonError(e) {
            // this.connectSocketInit();
          }

注意事项：

1.如果要将json的格式通过websocket发送过去需要通过 json。stringfy() 来进行转化才可进行发送

2.长链接的实现是通过在websocketOnOpen方法中增加一个计时器来通过间隔时间来进行发送。

3.connectSocketInit（）方法中进行判断是否有sock链接，如果有的话不在进行创建socket

4.connectSocketInit（）方法中对onOpen，onClose，onMessage进行了查分，防止各个方法进行耦合。