微信小程序连接到阿里云物联网平台
目录
- 准备阶段
- 阿里云配置
- 下载mqtt.min.js文件
- 小程序实现
- 注意
- 小程序配置服务器域名
概述：介绍使用微信小程序连接到阿里云平台的快捷方法和完整过程。
阿里云平台建立设备，提供mqtt连接参数，小程序借助mqtt.min.js，也就是基于Github下的MQTT.js 库，实现mqtt通信连接到阿里云，过程简单清晰。
https://github.com/mqttjs/MQTT.js
准备阶段
1.需要有阿里云物联网平台账号，已注册。
2.需要下载好微信开发者工具。
3.下载mqtt.min.js文件。
阿里云配置
阿里云上创建设备获取相关连接信息的参数，相关操作可参考物联网平台配置（MQTT）
需要用到的参数如下图所示：
下载mqtt.min.js文件
这个的话，确实也是网上找的资源，链接：源代码
但是需要自己保存为文件。
我也保存了文件，大家可以直接免费下载使用。
通过网盘分享的文件：mqtt.min.js
链接: https://pan.baidu.com/s/1IXoG50OWMruQ6I4iYeNtWg?pwd=wbs9 提取码: wbs9
小程序实现
首先创建项目
选用测试号即可，这里不用选云服务，看个人需求吧，模板选js 基础模板即可。
界面控件什么的就不多说了，自己随便弄个开关什么，按钮什么的即可。
或者直接就是登录到该界面就直接后台自动连接到阿里云平台。
先说下目录结构
vx-app-test/
├── app.js # 小程序全局逻辑
├── app.json # 全局配置
├── app.wxss # 全局样式
├── project.config.json # 项目配置文件
├── pages/
│ └── index/ # 首页
│ ├── index.js
│ ├── index.json
│ ├── index.wxml
│ └── index.wxss
└── utils/└── mqtt-client.js # 封装的MQTT连接模块
index.js是json源码，控制逻辑实现，index.wxml和 index.wxss这个是界面配置文件，login.json和页面也有关联，默认即可。mqtt-client.js 可以理解为接口库。
index.js的详细源码：
const mqtt = require('../../utils/mqtt.min.js');
const subTopic = "" //订阅的topic，接收订阅信息
const publishTopic = "" //发布的topic，用来向平台传递信息
Page({
//定义全局变量data: {userInfo: null, // 用户信息mqttStatus: '未连接', // MQTT连接状态mqttConnected: false, // MQTT连接标识mqttClient: null, //MQTT连接},onLoad() { // 初始化MQTT连接this.initMQTT()},onUnload() {// 页面卸载时断开MQTT连接this.data.mqttClient.disconnect()},initMQTT(){const options = {keepalive: 60, //60sclean: true, //cleanSession不保持持久会话protocolVersion: 4 //MQTT v3.1.1}//将前面阿里云平台获取到的连接信息，复制到下面对应变量中即可。options.clientId =""options.username =""options.password = ""const mqtt_url = "wxs:/{ProductKey}.iot-as-mqtt.{Region ID}.aliyuncs.com"const client = mqtt.connect(mqtt_url ,options)//连接事件client.on('connect', function () {console.log('连接服务器成功')//连接后可进行订阅// 订阅多个主题// client.subscribe(['topic1', 'topic2'], {qos: 0}, function(err)/*QoS级别说明：0：最多一次，发送者只发送一次消息，不进行重试1：至少一次，确保消息到达Broker2：恰好一次，使用两阶段确认保证消息不丢失不重复*/client.subscribe(subTopic, {qos: 1}, function (err) {if (!err) {console.log('订阅成功！');}})});//接收消息监听client.on('message', function (topic, message) {// message is Buffer // message 是 Buffer 类型，需要转换为字符串let msg = message.toString();console.log('收到消息：'+ msg);//关闭连接 client.end()});//理论上有这两个就够了，订阅后，接收消息，处理消息。//错误事件client.on('error', function(error) {console.error('连接错误:', error);}); this.data.mqttClient = client; // 保存到全局},//举例一个开关触发接口，实现消息上报。
// 开关状态变化onPowerChange(e) {const powerOn = e.detail.value//获取开关值this.setData({ powerOn }) // 发送控制命令 构建msg消息，字符或者整型，自行处理，最终需要转为json// const msg = {staus: powerOn ? '1' : '0' };const message = JSON.stringify({cmd: 'status',value: powerOn ? 1 : 0})this.data.mqttClient.publish(publishTopic , message, {qos: 1});},
})
一些其他接口
//重连事件
client.on('reconnect', function() {console.log('正在尝试重新连接...');
});//断开连接事件
client.on('close', function() {console.log('连接已关闭');
});
注意
这里有几个需要注意的地方
mqtt链接域名问题
const mqtt_url = "wxs:/{ProductKey}.iot-as-mqtt.{Region ID}.aliyuncs.com"
这里的{ProductKey}，要替换为你的产品key，来自阿里云平台，这里的{Region ID}也需要替换为你的地域。
物联网平台中的地域是什么，如何查询？
常用地域对照表
| 地域名称 | 所在城市 | Region ID |
|---|---|---|
| 华北 2 | 北京 | cn-beijing |
| 华东 2 | 上海 | cn-shanghai |
| 华南 1 | 深圳 | cn-shenzhen |
官网地域对照表链接
综上:一个案例，ProductKey : h6xxxxxwI , Region ID:cn-shanghai
const mqtt_url = "wxs:h6xxxxxwI.iot-as-mqtt.cn-shanghai.aliyuncs.com"
小程序配置服务器域名
此外小程序需要设置服务器域名，才能访问，不然无法访问阿里云物联网平台。
登录微信公众平台-》扫码登录（用开发者助手同一个vx）
登录的时候会有一个选项，需要根据开发者助手中的信息选择登录。
登录后可以找到下面的页面，修改并在对应栏下添加域名即可。
注意一个关键的地方，这里输入的域名是wss：的，而实际代码中使用的是wssd :
const mqtt_url = "wxs:h6xxxxxwI.iot-as-mqtt.cn-shanghai.aliyuncs.com"
注意将代码中的mqtt_url进行替换为:
wss:h6xxxxxwI.iot-as-mqtt.cn-shanghai.aliyuncs.com
这不会影响连接。
完成以上操作，编译后，观察控制台输出正常，就可以观察阿里云设备在线就说明成功登录，建立连接了。
以上就是小程序连接阿里云的全部过程了，看了下网上一些其他的博客，有点乱，还要用上加密方法，实际上是不需要的，可以直接使用阿里云中的连接参数就可以了，当然这可能是不安全的，其他考虑就需要各位自己考虑了，有啥问题欢迎评论区留言。