微信小程序连接到阿里云物联网平台

概述：介绍使用微信小程序连接到阿里云平台的快捷方法和完整过程。
阿里云平台建立设备，提供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

这不会影响连接。

完成以上操作，编译后，观察控制台输出正常，就可以观察阿里云设备在线就说明成功登录，建立连接了。

以上就是小程序连接阿里云的全部过程了，看了下网上一些其他的博客，有点乱，还要用上加密方法，实际上是不需要的，可以直接使用阿里云中的连接参数就可以了，当然这可能是不安全的，其他考虑就需要各位自己考虑了，有啥问题欢迎评论区留言。