微信小程序+mqtt.js實現實時接收消息

文檔說明

mqtt官方文檔

MDN

下載

示例

const mqtt = require('../../common/js/mqtt2.18.8.min.js');
Page({
  data: {
  },
  onLoad: function() {
    this.initSocket();
  },
  initSocket: function() {
  //小程序中只能用wxs://開頭
    var url = 'wxs://kabao.chanyecloud.com';//替換本身的請求地址

    var client = mqtt.connect(url, {
      clientId: "clientUserId"
    });
    console.log('lihdhhf')
    client.on('connect',function(){
      console.log('鏈接成功');
      //訂閱
      client.subscribe('/test');
    })
    
    client.on('message', function(topic, payload) {
      console.log("rev:" + [topic, payload].join(": "))
    })
  }
})
複製代碼