前言
注:
本程序发送心跳包,发送温湿度,返回控制数据这三个发送是单独的,有可能凑到一起发.
由于本身程序就是复杂性的程序,所以这节程序没有使用中断发送,没有使用环形队列发送,为了避免多条消息可能凑到一起发
如果嫌弃这个延时请自行优化,或者采用自己的方式解决,谢谢支持!
抱歉哈!我首先期望的是大部分人都先要看懂程序,至于其他优化我会提供个思路和源码,大家可以根据自己的情况自行优化.
用户须知
整个程序是STM32使用AT指令控制Wi-Fi模块实现SmartConfig配网和MQTT通信控制
程序的整体结构: https://www.cnblogs.com/yangfengwu/p/11669323.html
程序的按键处理: https://www.cnblogs.com/yangfengwu/p/11669354.html
串口接收数据 : https://www.cnblogs.com/yangfengwu/p/11669373.html
配置AT指令模板(阻塞版): https://www.cnblogs.com/yangfengwu/p/11673439.html
配置AT指令模板(非阻塞版): https://www.cnblogs.com/yangfengwu/p/11674814.html
打开这节源码
修改连接自己的服务器
一,如果想连接自己的MQTT服务器,可以直接更改
SmartConfig配网
一,主循环
二,AT指令配置模块启动SmartConfig的程序处理模板是:配置AT指令模板(阻塞版)
三,按键按下3S以后 变量 SmartConfigFlage = 1;
定时器里面开始控制 指示灯100Ms闪耀
四,AT指令控制Wi-Fi模块执行SmartConfig 配网程序部分
五,SmartConfig执行流程-连接路由器
实际上启用SmartConfig指令是 AT+CWSTARTSMART=3
最后的参数 1-SmartConfig配网 2-微信Airkiss配网 3-SmartConfig配网+微信Airkiss配网
下面进入了 while(1) 循环 我设置的30S超时
实际上此时Wi-Fi模块正在监听APP在空气中发出的无线信号
下图只要执行了搜索设备,APP就在不停的发出无线信号
Wi-Fi模块接收到APP发出的路由器信息以后,就会根据信息去连接路由器
Wi-Fi模块连接上了路由器以后便会返回 WIFI CONNECTED 和 WIFI GOT IP
注:只要配网一次,以后Wi-Fi模块便会自动连接此路由器,不需要重复配网!
六,SmartConfig执行流程-等待路由器把自己的MAC信息返回给APP
为了让APP确定Wi-Fi模块确实连接上了路由器,Wi-Fi连接上路由器以后
需要返回给APP自己的MAC地址和自己连接路由器后分得的IP地址
所以延时了5S时间,让Wi-Fi模块把信息发给APP
下图中,显示的就是所配网的Wi-Fi模块的MAC地址信息
当然MAC地址很有用(全球唯一),通信的时候可以用来区分设备.
控制Wi-Fi模块连接TCP服务器
配置Wi-Fi模块连接TCP服务器是使用的 "AT+SAVETRANSLINK=1,"%s",%s,"TCP" ",IP,Port
这个指令配置好以后,Wi-Fi模块便是透传模式,而且是自动连接
(串口接收的数据,自动发给TCP服务器)
(从TCP服务器接收的数据自动发给串口)
MQTT服务器规定ClientID必须每个设备不能一样,Wi-Fi模块的MAC作为了ClientID
获取ClientID部分
ClientID 最终存储在了 MQTTid数组里面
发送连接MQTT协议
判断连接状态
官方库里面判断返回的数据都是使用
MQTTPacket_read(数据解析完存到的数组,数组长度,提取数据函数)
最主要的是这个 提取数据函数
transport_getdata
这个函数的格式不能变,官方规定的就是这个格式
因为我的模块是串口透传模式,所以MQTT服务器返回的数据都返回到了串口数组里面
Usart1ReadBuff
假设我现在判断接收的数据类型,(MQTT协议里面第一个返回的数据就能判断出来数据类型)
MqttAnalyzeStruct.Len=0;
transport_getdata(buff,1);
这样执行以后 我就把第一个数据 拷贝到了 buff里面
然后我只需要判断buff数组第一个数据就可以了
其实官方就是这样做的
提取其它数据
接着看订阅
此函数一次性可以订阅多个主题,列如订阅两个主题
char SubTopic1[10]="aaaaa";
char SubTopic2[10]="bbbbb";
MQTTString MQTTStringSubTopic[2] = MQTTString_initializer;
int MQTTStringSubTopicQos[2] = {0,1};//第一个主题的消息等级0,第二个消息等级1
MQTTStringSubTopic[0].cstring = SubTopic1;
MQTTStringSubTopic[1].cstring = SubTopic2;
MainLen = MqttSubscribe(MQTTStringSubTopic,MQTTStringSubTopicQos,2,0,1);
UsartOutStr(MqttSendData,MainLen);
注:我设置的一次性最多订阅3个主题
定义的主题个数大于了此变量,用户需要增大此变量
实际订阅的主题个数 <= MaxSubTopicCount
判断订阅是否成功
发送一条上线消息
一,定义发布的主题变量
MQTTPublishTopicStruct MqttPublishTopicStruct = MQTTPublishTopicStruct_initializer;
该变量在主函数中定义
二, 使用该变量
打包数据函数 MqttPublish
三,,定义多个发布的主题变量
char Publish1[10]="qqqqq";//发布的主题
char Publish1Msg[8]="11223344";//发布的主题,携带的消息
char Publish2[10]="wwww";//发布的主题
char Publish2Msg[6]="000000";//发布的主题,携带的消息
MQTTPublishTopicStruct MqttPublishTopicStruct1 = MQTTPublishTopicStruct_initializer;
MQTTPublishTopicStruct MqttPublishTopicStruct2 = MQTTPublishTopicStruct_initializer;
MqttPublishTopicStruct1.topicName.cstring = Publish1;// 发布的主题
MainLen = MqttPublish(MqttPublishTopicStruct1,Publish1Msg,8);
UsartOutStr(MqttSendData,MainLen);//发送消息
MqttPublishTopicStruct1.topicName.cstring = Publish2;// 发布的主题
MainLen = MqttPublish(MqttPublishTopicStruct2,Publish2Msg,6);
UsartOutStr(MqttSendData,MainLen);//发送消息
连接好MQTT,订阅完主题,然后就是处理MQTT数据
三,每隔一段时间采集发送温湿度数据
看下我的心跳包处理
说下我的处理思路
首先,如果到了发送心跳包的时间了,就发送一次心跳包
然后启动超时,超过3S如果服务器没有回复心跳应答
我就再发送一次,然后启动超时,如果超过3S还是没有收到心跳返回
重新配置模块