wx.previewImage({
      urls: urlList //urlList是數(shù)組
})

var sotk = null;
var socketOpen = false;
var wsbasePath = "ws://開發(fā)者服務器 wss 接口地址/";

//開始webSocket
  webSocketStart(e){
    sotk = wx.connectSocket({
      url: wsbasePath,
      header: { 'content-type': 'application/x-www-form-urlencoded' },
      method: "POST",
      success: res => {
        console.log('小程序連接成功：', res);
      },
      fail: err => {
        console.log('出現(xiàn)錯誤啦！！' + err);
        wx.showToast({
          title: '網(wǎng)絡異常！',
        })
      }
    })

    this.webSokcketMethods();

  },

//監(jiān)聽指令
  webSokcketMethods(e){
    let that = this;
    sotk.onOpen(res => {
      socketOpen = true;
      console.log('監(jiān)聽 WebSocket 連接打開事件。', res);
    })
    sotk.onClose(onClose => {
      console.log('監(jiān)聽 WebSocket 連接關閉事件。', onClose)
      socketOpen = false;
    })
    sotk.onError(onError => {
      console.log('監(jiān)聽 WebSocket 錯誤。錯誤信息', onError)
      socketOpen = false
    })

    sotk.onMessage(onMessage => {
      var data =http://www.wxapp-union.com/ JSON.parse(onMessage.data);
      console.log('監(jiān)聽WebSocket接受到服務器的消息事件。服務器返回的消息',data);
     
    })
   
  },

//發(fā)送消息
  sendSocketMessage(msg) {
    let that = this;
    if (socketOpen){
      console.log('通過 WebSocket 連接發(fā)送數(shù)據(jù)', JSON.stringify(msg))
      sotk.send({
        data: JSON.stringify(msg)
      }, function (res) {
        console.log('已發(fā)送', res)
      })
    }
    
  },
 //關閉連接
  closeWebsocket(str){
    if (socketOpen) {
      sotk.close(
        {
          code: "1000",
          reason: str,
          success: function () {
            console.log("成功關閉websocket連接");
          }
        }
      )
    }
  }

var mqtt = require('utils/mqtt.min.js');
var client = null;
var connect = function(id) {
    return new Promise((resolve,reject)=>{
            const options = {
                connectTimeout: 4000, // 超時時間
                clientId: 'wx_' + parseInt(Math.random() * 100 + 800, 10),
                port:8084
            }

            client = mqtt.connect('wxs://xxx', options)

            client.on('reconnect', (error) => {
                console.log('正在重連:', error)
            })

            client.on('error', (error) => {
                console.log('連接失敗:', error)
            })

            let that = this;
            client.on('connect', (e) => {
                console.log('成功連接服務器')
                //訂閱主題
                client.subscribe(['主題1'+id, '主題2'+id], {
                    qos: 1
                }, function (err) {
                    if (!err) {
                        console.log("訂閱成功")
                        resolve(client)
                    }
                })
            })
    })
}

client.on('message', function (topic, message, packet) {
       console.log(packet)
})