设为首页收藏本站
开启辅助访问 切换到宽版

 找回密码
 立即注册

QQ登录

只需一步，快速开始

热门： 51单片机 | 24小时必答区 | 单片机教程 | 单片机DIY制作 | STM32 | Cortex M3 | 模数电子 | 电子DIY制作 | 音响/功放 | 拆机乐园 | Arduino | 嵌入式OS | 程序设计

搜索
»论坛 › 嵌入式/单片机论坛 › STM32/8 › STM32连接OneNET平台 MQTT协议 源程序
返回列表 发新帖
查看: 2410|回复: 2
收起左侧

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

[复制链接]
ID:765743 发表于 2020-5-31 15:12 | 显示全部楼层 |阅读模式
使用的是正点原子的mini板，设备是MQTT协议的。在代码里改下产品ID啥的，还有无线网。

单片机源程序如下:
  1. /*-----------------------------------------------------*/
  2. /*                     程序结构                        */
  3. /*-----------------------------------------------------*/
  4. /*USER     ：包含程序的main函数，是整个程序的入口      */
  5. /*HARDWARE ：包含开发板各种功能外设的驱动程序          */
  6. /*CORE     ：包含STM32的核心程序，官方提供，           */
  7. /*STLIB    ：官方提供的库文件，                        */
  8. /*-----------------------------------------------------*/
  9. /*                                                     */
  10. /*           程序main函数，入口函数源文件              */
  11. /*                                                     */
  12. /*-----------------------------------------------------*/

  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. }
复制代码

所有程序51hei提供下载:
Test.7z (221.15 KB, 下载次数: 81)

评分

参与人数 1黑币 +50 收起 理由
admin + 50 共享资料的黑币奖励！

查看全部评分

回复

使用道具 举报

ID:302325 发表于 2020-6-1 02:04 | 显示全部楼层
好资料，51黑有你更精彩!!!
回复

使用道具 举报

ID:275041 发表于 2020-6-1 09:35 | 显示全部楼层
WIFI用的是那个芯片呢
回复

使用道具 举报

返回列表 发新帖
高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

手机版|小黑屋|51黑电子论坛 |51黑电子论坛6群 QQ 管理员QQ:125739409;技术交流QQ群281945664

Powered by 单片机教程网

快速回复 返回顶部 返回列表