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

[复制链接]
查看118 | 回复0 | 2020-6-4 16:10:14 | 显示全部楼层 |阅读模式
使用的是正点原子的mini板,设备是MQTT协议的。在代码里改下产品ID啥的,还有无线网。
完整源码: code.7z (221.15 KB, 售价: 1 工控币)
部分源程序如下:
  1. /*-----------------------------------------------------*/
  2. /*                     程序结构                        */
  3. /*-----------------------------------------------------*/
  4. /*USER     :包含程序的main函数,是整个程序的入口      */
  5. /*HARDWARE :包含开发板各种功能外设的驱动程序          */
  6. /*CORE     :包含STM32的核心程序,官方提供,           */
  7. /*STLIB    :官方提供的库文件,                        */
  8. /*-----------------------------------------------------*/
  9. /*                                                     */
  10. /*           程序main函数,入口函数源文件              */
  11. /*                                                     */
  12. /*-----------------------------------------------------*/

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


回复

使用道具 举报

您需要登录后才可以回帖 登录 | 注册

本版积分规则