STM32连接OneNET平台 MQTT协议 源程序

使用的是正点原子的mini板，设备是MQTT协议的。在代码里改下产品ID啥的，还有无线网。
完整源码： code.7z (221.15 KB, 售价: 1 E币)

2020-6-4 16:09 上传

点击文件名下载附件

部分源程序如下:

1. /*-----------------------------------------------------*/
   
2. /*                     程序结构                        */
   
3. /*-----------------------------------------------------*/
   
4. /*USER     ：包含程序的main函数，是整个程序的入口      */
   
5. /*HARDWARE ：包含开发板各种功能外设的驱动程序          */
   
6. /*CORE     ：包含STM32的核心程序，官方提供，           */
   
7. /*STLIB    ：官方提供的库文件，                        */
   
8. /*-----------------------------------------------------*/
   
9. /*                                                     */
   
10. /*           程序main函数，入口函数源文件              */
    
11. /*                                                     */
    
12. /*-----------------------------------------------------*/
    
13. 
    
14. #include "stm32f10x.h"  //包含需要的头文件
    
15. #include "main.h"       //包含需要的头文件
    
16. #include "delay.h"      //包含需要的头文件
    
17. #include "usart1.h"     //包含需要的头文件
    
18. #include "usart2.h"     //包含需要的头文件
    
19. #include "timer1.h"     //包含需要的头文件
    
20. #include "timer2.h"     //包含需要的头文件
    
21. #include "timer3.h"     //包含需要的头文件
    
22. #include "timer4.h"     //包含需要的头文件
    
23. #include "timer5.h"     //包含需要的头文件
    
24. #include "wifi.h"            //包含需要的头文件
    
25. #include "led.h"        //包含需要的头文件
    
26. #include "mqtt.h"       //包含需要的头文件
    
27. #include "key.h"        //包含需要的头文件
    
28. #include "iic.h"        //包含需要的头文件
    
29. #include "dht11.h"
    
30. #include "bh1750.h"
    
31. #include "sr501.h"
    
32. char *CMD1 = "PC+CH1=C";     //通道1控制命令，状态翻转，停止->采集   采集->停止  
    
33. char *CMD2 = "PC+CH2=C";     //通道2控制命令，状态翻转，停止->采集   采集->停止
    
34. char *CMD3 = "PC+SW1=C";     //开关1控制命令，状态翻转，开->关       关->开
    
35. char *CMD4 = "PC+SW2=C";     //开关2控制命令，状态翻转，开->关       关->开
    
36. char *CMD5 = "PC+STA=?";     //查询2路开关状态 和 采集状态
    
37. char  CH1_flag = 0;          //通道1 温度数据 是否处于采集状态， 0：停止采集  1：采集中
    
38. char  CH2_flag = 0;          //通道2 湿度数据 是否处于采集状态， 0：停止采集  1：采集中
    
39. int main(void)
    
40. {      
    
41.         Delay_Init();                   //延时功能初始化              
    
42.         Usart1_Init(9600);              //串口1功能初始化，波特率9600
    
43.         Usart2_Init(115200);            //串口2功能初始化，波特率115200      
    
44.         TIM4_Init(500,7200);            //TIM4初始化，定时时间 500*7200*1000/72000000 = 50ms
    
45.         LED_Init();                            //LED初始化
    
46.         KEY_Init();                     //按键初始化
    
47.         IIC_Init();                     //初始化IIC接口
    
48.     Init_BH1750();
    
49.         SR501_Init();
    
50.         WiFi_ResetIO_Init();            //初始化WiFi的复位IO
    
51.         IoT_Parameter_Init();                //初始化云IoT平台MQTT服务器的参数      
    
52.       
    
53.         while(1)                        //主循环
    
54.         {      
    
55.             if(SR501)
    
56.                 {
    
57.                
    
58.                
    
59.                 }      
    
60.                 /*--------------------------------------------------------------------*/
    
61.                 /*   Connect_flag=1同服务器建立了连接,我们可以发布数据和接收推送了    */
    
62.                 /*--------------------------------------------------------------------*/
    
63.                 if(Connect_flag==1){     
    
64.                         /*-------------------------------------------------------------*/
    
65.                         /*                     处理发送缓冲区数据                      */
    
66.                         /*-------------------------------------------------------------*/
    
67.                                 if(MQTT_TxDataOutPtr != MQTT_TxDataInPtr){                //if成立的话，说明发送缓冲区有数据了
    
68.                                 //3种情况可进入if
    
69.                                 //第1种：0x10 连接报文
    
70.                                 //第2种：0x82 订阅报文，且ConnectPack_flag置位，表示连接报文成功
    
71.                                 //第3种：SubcribePack_flag置位，说明连接和订阅均成功，其他报文可发
    
72.                                 if((MQTT_TxDataOutPtr[2]==0x10)||((MQTT_TxDataOutPtr[2]==0x82)&&(ConnectPack_flag==1))||(SubcribePack_flag==1)){   
    
73.                                         u1_printf("发送数据:0x%x\r\n",MQTT_TxDataOutPtr[2]);  //串口提示信息
    
74.                                         MQTT_TxData(MQTT_TxDataOutPtr);                       //发送数据
    
75.                                         MQTT_TxDataOutPtr += TBUFF_UNIT;                      //指针下移
    
76.                                         if(MQTT_TxDataOutPtr==MQTT_TxDataEndPtr)              //如果指针到缓冲区尾部了
    
77.                                                 MQTT_TxDataOutPtr = MQTT_TxDataBuf[0];            //指针归位到缓冲区开头
    
78.                                 }                                
    
79.                         }//处理发送缓冲区数据的else if分支结尾
    
80.                        
    
81.                         /*-------------------------------------------------------------*/
    
82.                         /*                     处理接收缓冲区数据                      */
    
83.                         /*-------------------------------------------------------------*/
    
84.                         if(MQTT_RxDataOutPtr != MQTT_RxDataInPtr){  //if成立的话，说明接收缓冲区有数据了                                                                                                               
    
85.                                 u1_printf("接收到数据:");
    
86.                                 /*-----------------------------------------------------*/
    
87.                                 /*                    处理CONNACK报文                  */
    
88.                                 /*-----------------------------------------------------*/                              
    
89.                                 //if判断，如果第一个字节是0x20，表示收到的是CONNACK报文
    
90.                                 //接着我们要判断第4个字节，看看CONNECT报文是否成功
    
91.                                 if(MQTT_RxDataOutPtr[2]==0x20){                                    
    
92.                                     switch(MQTT_RxDataOutPtr[5]){                                       
    
93.                                                 case 0x00 : u1_printf("CONNECT报文成功\r\n");                            //串口输出信息      
    
94.                                                                     ConnectPack_flag = 1;                                        //CONNECT报文成功，订阅报文可发
    
95.                                                                         break;                                                       //跳出分支case 0x00                                             
    
96.                                                 case 0x01 : u1_printf("连接已拒绝，不支持的协议版本，准备重启\r\n");     //串口输出信息
    
97.                                                                         Connect_flag = 0;                                            //Connect_flag置零，重启连接
    
98.                                                                         break;                                                       //跳出分支case 0x01   
    
99.                                                 case 0x02 : u1_printf("连接已拒绝，不合格的客户端标识符，准备重启\r\n"); //串口输出信息
    
100.                                                                         Connect_flag = 0;                                            //Connect_flag置零，重启连接
     
101.                                                                         break;                                                       //跳出分支case 0x02
     
102.                                                 case 0x03 : u1_printf("连接已拒绝，服务端不可用，准备重启\r\n");         //串口输出信息
     
103.                                                                         Connect_flag = 0;                                            //Connect_flag置零，重启连接
     
104.                                                                         break;                                                       //跳出分支case 0x03
     
105.                                                 case 0x04 : u1_printf("连接已拒绝，无效的用户名或密码，准备重启\r\n");   //串口输出信息
     
106.                                                                         Connect_flag = 0;                                            //Connect_flag置零，重启连接                                               
     
107.                                                                         break;                                                       //跳出分支case 0x04
     
108.                                                 case 0x05 : u1_printf("连接已拒绝，未授权，准备重启\r\n");               //串口输出信息
     
109.                                                                         Connect_flag = 0;                                            //Connect_flag置零，重启连接                                               
     
110.                                                                         break;                                                       //跳出分支case 0x05               
     
111.                                                 default   : u1_printf("连接已拒绝，未知状态，准备重启\r\n");             //串口输出信息
     
112.                                                                         Connect_flag = 0;                                            //Connect_flag置零，重启连接                                       
     
113.                                                                         break;                                                       //跳出分支case default                                                               
     
114.                                         }                              
     
115.                                 }                       
     
116.                                 //if判断，第一个字节是0x90，表示收到的是SUBACK报文
     
117.                                 //接着我们要判断订阅回复，看看是不是成功
     
118.                                 else if(MQTT_RxDataOutPtr[2]==0x90){
     
119.                                                 switch(MQTT_RxDataOutPtr[6]){                                       
     
120.                                                 case 0x00 :
     
121.                                                 case 0x01 : u1_printf("订阅成功\r\n");            //串口输出信息
     
122.                                                                 SubcribePack_flag = 1;                //SubcribePack_flag置1，表示订阅报文成功，其他报文可发送
     
123.                                                                         Ping_flag = 0;                        //Ping_flag清零
     
124.                                                                        TIM3_ENABLE_30S();                    //启动30s的PING定时器                                                      
     
125.                                                                         break;                                //跳出分支                                             
     
126.                                                 default   : u1_printf("订阅失败，准备重启\r\n");  //串口输出信息
     
127.                                                                         Connect_flag = 0;                     //Connect_flag置零，重启连接
     
128.                                                                         break;                                //跳出分支                                                               
     
129.                                         }                                       
     
130.                                 }
     
131.                                 //if判断，第一个字节是0xD0，表示收到的是PINGRESP报文
     
132.                                 else if(MQTT_RxDataOutPtr[2]==0xD0){
     
133.                                         u1_printf("PING报文回复\r\n");                   //串口输出信息
     
134.                                         if(Ping_flag==1){                     //如果Ping_flag=1，表示第一次发送
     
135.                                                  Ping_flag = 0;                                      //要清除Ping_flag标志
     
136.                                         }else if(Ping_flag>1){                                   //如果Ping_flag>1，表示是多次发送了，而且是2s间隔的快速发送
     
137.                                                 Ping_flag = 0;                                       //要清除Ping_flag标志
     
138.                                                 TIM3_ENABLE_30S();                                   //PING定时器重回30s的时间
     
139.                                         }                              
     
140.                                 }      
     
141.                                 //if判断，如果第一个字节是0x30，表示收到的是服务器发来的推送数据
     
142.                                 //我们要提取控制命令
     
143.                                 else if((MQTT_RxDataOutPtr[2]==0x30)){
     
144.                                         u1_printf("服务器等级0推送\r\n");                    //串口输出信息
     
145.                                         MQTT_DealPushdata_Qs0(MQTT_RxDataOutPtr);  //处理等级0推送数据
     
146.                                 }                              
     
147.                                                                
     
148.                                 MQTT_RxDataOutPtr +=RBUFF_UNIT;                     //指针下移
     
149.                                 if(MQTT_RxDataOutPtr==MQTT_RxDataEndPtr)            //如果指针到缓冲区尾部了
     
150.                                         MQTT_RxDataOutPtr = MQTT_RxDataBuf[0];          //指针归位到缓冲区开头                        
     
151.                         }//处理接收缓冲区数据的else if分支结尾
     
152.                        
     
153.                         /*-------------------------------------------------------------*/
     
154.                         /*                     处理命令缓冲区数据                      */
     
155.                         /*-------------------------------------------------------------*/
     
156.                         if(MQTT_CMDOutPtr != MQTT_CMDInPtr){                             //if成立的话，说明命令缓冲区有数据了                              
     
157.                                 MQTT_CMDOutPtr[MQTT_CMDOutPtr[0]+1] = '\0';                  //加入字符串结束符
     
158.                                 u1_printf("命令:%s\r\n",&MQTT_CMDOutPtr[2]);                 //串口输出信息
     
159.                                 if(!memcmp(&MQTT_CMDOutPtr[2],CMD1,strlen(CMD1))){           //判断指令，如果是CMD1
     
160.                                         if(CH1_flag==0){                                         //如果，CH1_flag等于0，表示当前处于停止采集状态，我们开始采集
     
161.                                                 CH1_flag = 1;                                        //CH1_flag置1，表示处于采集状态了
     
162.                                             TIM5_ENABLE_10S();                                   //定时器1，,10s间隔采集温度
     
163.                                         }else{                                                   //反之，DCH1_flag等于1，表示当前处于采集状态，我们停止
     
164.                                                 CH1_flag = 0;                                        //CH1_flag置1，表示处于停止状态了
     
165.                                                 TIM_Cmd(TIM5,DISABLE);                               //关TIM2
     
166.                                         }
     
167.                                         CH_SW_State();                                           //判断2路通道，2路开关状态，并发布给服务器   
     
168.                                 }else if(!memcmp(&MQTT_CMDOutPtr[2],CMD2,strlen(CMD2))){     //判断指令，如果是CMD2
     
169.                                         if(CH2_flag==0){                                         //如果，CH2_flag等于0，表示当前处于停止采集状态，我们开始采集
     
170.                                                 CH2_flag = 1;                                        //CH2_flag置1，表示处于采集状态了
     
171.                                             TIM2_ENABLE_10S();                                   //定时器2，,10s间隔采集温度
     
172.                                         }else{                                                   //反之，DCH2_flag等于1，表示当前处于采集状态，我们停止
     
173.                                                 CH2_flag = 0;                                        //CH2_flag置0，表示处于停止状态了
     
174.                                                 TIM_Cmd(TIM2,DISABLE);                               //关TIM2
     
175.                                         }
     
176.                                         CH_SW_State();                                           //判断2路通道，2路开关状态，并发布给服务器
     
177.                                 }else if(!memcmp(&MQTT_CMDOutPtr[2],CMD3,strlen(CMD3))){     //判断指令，如果是CMD3
     
178.                                         LED1_OUT(!LED1_IN_STA);                                  //开关1状态翻转 如果点亮就熄灭，反之如果熄灭就点亮                                                                                                                 //我们只有两路，第3路通道，不做处理，仅返回状态
     
179.                                         CH_SW_State();                                           //判断2路通道，2路开关状态，并发布给服务器   
     
180.                                 }else if(!memcmp(&MQTT_CMDOutPtr[2],CMD4,strlen(CMD4))){     //判断指令，如果是CMD4
     
181.                                         LED2_OUT(!LED2_IN_STA);                                  //开关2状态翻转 如果点亮就熄灭，反之如果熄灭就点亮                                                                                                                 //我们只有两路，第4路通道，不做处理，仅返回状态
     
182.                                         CH_SW_State();                                           //判断2路通道，2路开关状态，并发布给服务器     
     
183.                                 }else if(!memcmp(&MQTT_CMDOutPtr[2],CMD5,strlen(CMD5))){     //判断指令，如果是CMD5
     
184.                                         CH_SW_State();                                           //判断2路通道，2路开关状态，并发布给服务器  
     
185.                                 }else u1_printf("未知指令\r\n");                              //串口输出信息      
     
186.                               
     
187.                                 MQTT_CMDOutPtr += CBUFF_UNIT;                                      //指针下移
     
188.                                 if(MQTT_CMDOutPtr==MQTT_CMDEndPtr)                                //如果指针到缓冲区尾部了
     
189.                                         MQTT_CMDOutPtr = MQTT_CMDBuf[0];                               //指针归位到缓冲区开头                              
     
190.                         }//处理命令缓冲区数据的else if分支结尾      
     
191.                 }//Connect_flag=1的if分支的结尾
     
192.                
     
193.                 /*--------------------------------------------------------------------*/
     
194.                 /*      Connect_flag=0同服务器断开了连接,我们要重启连接服务器         */
     
195.                 /*--------------------------------------------------------------------*/
     
196.                 else{
     
197.                         u1_printf("需要连接服务器\r\n");                 //串口输出信息
     
198.                         TIM_Cmd(TIM4,DISABLE);                           //关闭TIM4
     
199.                         TIM_Cmd(TIM3,DISABLE);                           //关闭TIM3  
     
200.                         WiFi_RxCounter=0;                                //WiFi接收数据量变量清零                        
     
201.                         memset(WiFi_RX_BUF,0,WiFi_RXBUFF_SIZE);          //清空WiFi接收缓冲区
     
202.                         if(WiFi_Connect_IoTServer()==0){                                //如果WiFi连接云服务器函数返回0，表示正确，进入if
     
203.                                 u1_printf("建立TCP连接成功\r\n");            //串口输出信息
     
204.                                 Connect_flag = 1;                            //Connect_flag置1，表示连接成功      
     
205.                                 WiFi_RxCounter=0;                            //WiFi接收数据量变量清零                        
     
206.                                 memset(WiFi_RX_BUF,0,WiFi_RXBUFF_SIZE);      //清空WiFi接收缓冲区
     
207.                                 MQTT_Buff_Init();                            //初始化发送缓冲区                    
     
208.                         }                              
     
209.                 }
     
210.         }
     
211. }
     
212. /*-------------------------------------------------*/
     
213. /*函数名：判断2路通道，2路开关状态，并发布给服务器 */
     
214. /*参  数：无                                       */
     
215. /*返回值：无                                       */
     
216. /*-------------------------------------------------*/
     
217. void CH_SW_State(void)
     
218. {
     
219.         char temp[10];                                  //定义一个临时缓冲区
     
220.       
     
221.         memset(temp,0,10);                                 //清空临时缓冲区
     
222.         sprintf(temp,"+STA:");                          //构建回复数据               
     
223.         if(LED1_IN_STA)  temp[5] = '0';                  //如果LED1是高电平，说明是熄灭状态，开关1状态位置0
     
224.         else             temp[5] = '1';                        //反之，说明是点亮状态，开关1状态位置1      
     
225.         if(LED2_IN_STA)  temp[6] = '0';                  //如果LED2是高电平，说明是熄灭状态，开关2状态位置0
     
226.         else             temp[6] = '1';                        //反之，说明是点亮状态，开关2状态位置1      
     
227.         if(CH1_flag==0)  temp[7] = '0';         //如果，CH1_flag等于0，表示当前通道1处于停止采集状态，状态位置0
     
228.         else             temp[7] = '1';         //反之，CH1_flag等于1，表示当前通道1处于采集状态，状态位置1
     
229.         if(CH2_flag==0)  temp[8] = '0';         //如果，CH2_flag等于0，表示当前通道2处于停止采集状态，状态位置0
     
230.         else             temp[8] = '1';         //反之，CH2_flag等于1，表示当前通道2处于采集状态，状态位置1
     
231.         MQTT_PublishQs0(P_TOPIC_NAME,temp,9);   //添加数据，发布给服务器      
     
232. }
     

复制代码

【必读】版权免责声明

1、本主题所有言论和内容纯属会员个人意见，与本论坛立场无关。2、本站对所发内容真实性、客观性、可用性不做任何保证也不负任何责任，网友之间仅出于学习目的进行交流。3、对提供的数字内容不拥有任何权利，其版权归原著者拥有。请勿将该数字内容进行商业交易、转载等行为，该内容只为学习所提供，使用后发生的一切问题与本站无关。 4、本网站不保证本站提供的下载资源的准确性、安全性和完整性;同时本网站也不承担用户因使用这些下载资源对自己和他人造成任何形式的损失或伤害。 5、本网站所有软件和资料均为网友推荐收集整理而来，仅供学习用途使用，请务必下载后两小时内删除，禁止商用。6、如有侵犯你版权的，请及时联系我们（电子邮箱1370723259@qq.com）指出，本站将立即改正。