微信小程序使用MQTToverWebSocket连接阿里云IoT物联网平台

准备工作

随便在一个页面的js文件中加入以下代码，注意替换参数为自己产品和设备的参数

var mqtt = require('../../utils/mqtt.min.js') const crypto = require('../../utils/hex_hmac_sha1.js'); Page({ data: { }, onLoad: function () { this.doConnect() }, doConnect(){ const deviceConfig = { productKey: "替换", deviceName: "替换", deviceSecret: "替换", regionId: "cn-shanghai" }; const options = this.initMqttOptions(deviceConfig); console.log(options) //替换productKey为你自己的产品的 const client = mqtt.connect('wxs://productKey.iot-as-mqtt.cn-shanghai.aliyuncs.com',options) client.on('connect', function () { console.log('连接服务器成功') //订阅主题，替换productKey和deviceName(这里的主题可能会不一样，具体请查看后台设备Topic列表或使用自定义主题) client.subscribe('/productKey/deviceName/get', function (err) { if (!err) { console.log('订阅成功！'); } }) }) //接收消息监听 client.on('message', function (topic, message) { // message is Buffer console.log('收到消息：'+message.toString()) //关闭连接 client.end() }) }, //IoT平台mqtt连接参数初始化 initMqttOptions(deviceConfig) { const params = { productKey: deviceConfig.productKey, deviceName: deviceConfig.deviceName, timestamp: Date.now(), clientId: Math.random().toString(36).substr(2), } //CONNECT参数 const options = { keepalive: 60, //60s clean: true, //cleanSession不保持持久会话 protocolVersion: 4 //MQTT v3.1.1 } //1.生成clientId，username，password options.password = this.signHmacSha1(params, deviceConfig.deviceSecret); options.clientId = `${params.clientId}|securemode=2,signmethod=hmacsha1,timestamp=${params.timestamp}|`; options.username = `${params.deviceName}&${params.productKey}`; return options; }, /* 生成基于HmacSha1的password 参考文档：https://help.aliyun.com/document_detail/73742.html?#h2-url-1 */ signHmacSha1(params, deviceSecret) { let keys = Object.keys(params).sort(); // 按字典序排序 keys = keys.sort(); const list = []; keys.map((key) => { list.push(`${key}${params[key]}`); }); const contentStr = list.join(''); return crypto.hex_hmac_sha1(deviceSecret, contentStr); } })

运行代码在控制台设备Topic列表发布消息：

即可看到如下

鉴于很多人加我问了挺多相同的问题，我这里就列出来常见的几个问题

有任何其他疑问，可以加我QQ一起交流：343672271（备注：mqtt）