先上圖看效果
圖上可以清楚的看到連接參數,以及通訊參數。廢話不多說上代碼app.js
import mqtt from './utils/mqtt.js'; let client = null; App({ onLaunch: function () { this.connectMqtt(); }, connectMqtt: function() { var clinet_id = parseInt(Math.random() * 100 + 888888888, 10); console.log('wx_' + clinet_id); const options = { connectTimeout: 4000, // 超時時間 clientId: 'wx_' + clinet_id, port: 8083, username: 'xxxx', password: 'xxxxx', } client = mqtt.connect('wx://xxxxxx', 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('message.queue', { qos: 0 }, function(err) { if (!err) { console.log("訂閱成功") } }) }) client.on('message', function (topic, message) { console.log('received msg:' + message.toString()); }) }, })
做這步之前要下載mqtt.js
https://unpkg.com/mqtt@2.18.8/dist/mqtt.js
https://unpkg.com/mqtt@2.18.8/dist/mqtt.min.js
還不會怎么辦,有大招,關注下方公眾號提問即可,一般最遲一天回復