美文网首页
《微信小程序开发从入门到实战》学习七十一

《微信小程序开发从入门到实战》学习七十一

作者: 阿宅白石 | 来源:发表于2024-01-02 23:54 被阅读0次

    6.6 网络API

    6.6.5 WebSocket API

    使用WebSocket API可使小程序与服务器建立长连接。小程序端和服务端长时间内可主动向对端发送一些数据

    需要先调用wx.connectSocket创建一个连接,返回一个SocketTask对象,然后WebSocket方式通信。

    SocketTask对象可建立四监听函数:

    监听webSocket连接打开的onOpen函数,

    监听webSocket接收到onMessage的onMessage函数,

    监听webSocket错误的onError函数,

    监听webSocket连接关闭的onClose函数。

    SocketTask对象还可调用send函数向服务端发送数据,调用close函数关闭WebSocket连接。示例代码如下:

    // 使用一个变量记录WebSocket连接是否已经建立

        let socketOpen = false

        // 消息队列数组,在WebSocket连接建立之前是不能发送数据的,可以先将数据缓存在这里

        const socketMsgQueue = []

        // 建立 WebSocket 连接

        const socketTask = wx.connectSocket({

          url: 'wss://somewebsite.com',

          header: {

            'content-type': 'application/json'

          }

        })

        // 需要注意,调用建立连接接口后,建立连接需要一定时间,与网络情况有关,大约为数毫秒或数秒

        // 封装一个发送数据的函数,如果当前建立连接还未完成,就先将需要发送的数据缓存到消息队列中

        function sendSocketMessage(msg) {

          if (socketOpen) {

            // 当前未建立连接

            socketTask.send({

              data: msg // 发送的数据需要放到data属性中

            })

          } else {

            // 当前还未建立连接

            socketMsgQueue.push(msg)

          }

        }

        // 监听WebSocket连接打开事件

        socketTask.onOpen(function(res) {

            // 标记连接已经已经建立

            socketOpen = true

            // 将消息队列中的缓存数据全部发送到服务端,并清空消息队列

            for (let i = 0; i < socketMsgQueue.length; i++) {

              const element = socketMsgQueue[i];

              sendSocketMessage(element)

            }

            socketMsgQueue = []

        })

        // 监听webSocket接收到服务器消息的事件

        socketTask.onMessage(function(res) {

          console.log(res.data) 

        })

        // 监听webSocket错误的事件

        socketTask.onError(function(res) {

          console.log(res.errMsg) // 错误消息

        })

        // 监听webSocket关闭事件

        socketTask.onClose(function() {

          // 标记连接已经关闭

          socketOpen = false

        })

        // 主动关闭 WebSocket连接

        socketTask.close({

          code: 1000,  // 关闭连接的状态号,表示连接被关闭的原因。默认为1000,表示正常关闭连接

          reason: '',

          success() {

            // 标记连接已经关闭

            socketOpen = false

          }

        })

    相关文章

      网友评论

          本文标题:《微信小程序开发从入门到实战》学习七十一

          本文链接:https://www.haomeiwen.com/subject/mmemndtx.html