找回密码
 立即注册

QQ登录

只需一步,快速开始

搜索
查看: 2910|回复: 3
打印 上一主题 下一主题
收起左侧

阿里云物联网平台,stm32,mqtt协议 源程序

  [复制链接]
跳转到指定楼层
楼主
使用stm32,ESP8266WiFi数据传输,mqtt协议,阿里云物联网平台,程序源码,下载可用。附app应用。

单片机源程序如下:
  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 "timer3.h"     //包含需要的头文件
  20. #include "timer4.h"     //包含需要的头文件
  21. #include "wifi.h"            //包含需要的头文件
  22. #include "led.h"        //包含需要的头文件
  23. #include "mqtt.h"       //包含需要的头文件
  24. #include "key.h"        //包含需要的头文件

  25. char *CMD1 = "APP+OneSW=C";    //开关控制命令,状态翻转,开->关 关->开  
  26. char *CMD2 = "APP+OneSW=?";    //开关查询命令,回复服务器当前开关状态
  27. char *CMD3 = "APP+OneSWCD";    //设置开关倒计时,倒计时时间到的时候,开关状态翻转
  28. int   CDTime= 0;               //记录开关倒计时时间

  29. int main(void)
  30. {        
  31.         Delay_Init();                   //延时功能初始化              
  32.         Usart1_Init(9600);              //串口1功能初始化,波特率9600
  33.         Usart2_Init(115200);            //串口2功能初始化,波特率115200        
  34.         TIM4_Init(300,7200);            //TIM4初始化,定时时间 300*7200*1000/72000000 = 30ms
  35.         LED_Init();                            //LED初始化
  36.         KEY_Init();                     //按键初始化
  37.         WiFi_ResetIO_Init();            //初始化WiFi的复位IO
  38.     MQTT_Buff_Init();               //初始化接收,发送,命令数据的 缓冲区 以及各状态参数
  39.         AliIoT_Parameter_Init();            //初始化连接阿里云IoT平台MQTT服务器的参数               
  40.         while(1)                        //主循环
  41.         {               
  42.                 /*--------------------------------------------------------------------*/
  43.                 /*   Connect_flag=1同服务器建立了连接,我们可以发布数据和接收推送了    */
  44.                 /*--------------------------------------------------------------------*/
  45.                 if(Connect_flag==1){     
  46.                         /*-------------------------------------------------------------*/
  47.                         /*                     处理发送缓冲区数据                      */
  48.                         /*-------------------------------------------------------------*/
  49.                                 if(MQTT_TxDataOutPtr != MQTT_TxDataInPtr){                //if成立的话,说明发送缓冲区有数据了
  50.                                 //3种情况可进入if
  51.                                 //第1种:0x10 连接报文
  52.                                 //第2种:0x82 订阅报文,且ConnectPack_flag置位,表示连接报文成功
  53.                                 //第3种:SubcribePack_flag置位,说明连接和订阅均成功,其他报文可发
  54.                                 if((MQTT_TxDataOutPtr[1]==0x10)||((MQTT_TxDataOutPtr[1]==0x82)&&(ConnectPack_flag==1))||(SubcribePack_flag==1)){   
  55.                                         u1_printf("发送数据:0x%x\r\n",MQTT_TxDataOutPtr[1]);  //串口提示信息
  56.                                         MQTT_TxData(MQTT_TxDataOutPtr);                       //发送数据
  57.                                         MQTT_TxDataOutPtr += BUFF_UNIT;                       //指针下移
  58.                                         if(MQTT_TxDataOutPtr==MQTT_TxDataEndPtr)              //如果指针到缓冲区尾部了
  59.                                                 MQTT_TxDataOutPtr = MQTT_TxDataBuf[0];            //指针归位到缓冲区开头
  60.                                 }                                 
  61.                         }//处理发送缓冲区数据的else if分支结尾
  62.                         
  63.                         /*-------------------------------------------------------------*/
  64.                         /*                     处理接收缓冲区数据                      */
  65.                         /*-------------------------------------------------------------*/
  66.                         if(MQTT_RxDataOutPtr != MQTT_RxDataInPtr){  //if成立的话,说明接收缓冲区有数据了                                                                                                               
  67.                                 u1_printf("接收到数据:");
  68.                                 /*-----------------------------------------------------*/
  69.                                 /*                    处理CONNACK报文                  */
  70.                                 /*-----------------------------------------------------*/                                
  71.                                 //if判断,如果一共接收了4个字节,第一个字节是0x20,表示收到的是CONNACK报文
  72.                                 //接着我们要判断第4个字节,看看CONNECT报文是否成功
  73.                                 if((MQTT_RxDataOutPtr[0]==4)&&(MQTT_RxDataOutPtr[1]==0x20)){                                    
  74.                                     switch(MQTT_RxDataOutPtr[4]){                                       
  75.                                                 case 0x00 : u1_printf("CONNECT报文成功\r\n");                            //串口输出信息        
  76.                                                                     ConnectPack_flag = 1;                                        //CONNECT报文成功,订阅报文可发
  77.                                                                         break;                                                       //跳出分支case 0x00                                             
  78.                                                 case 0x01 : u1_printf("连接已拒绝,不支持的协议版本,准备重启\r\n");     //串口输出信息
  79.                                                                         Connect_flag = 0;                                            //Connect_flag置零,重启连接
  80.                                                                         break;                                                       //跳出分支case 0x01   
  81.                                                 case 0x02 : u1_printf("连接已拒绝,不合格的客户端标识符,准备重启\r\n"); //串口输出信息
  82.                                                                         Connect_flag = 0;                                            //Connect_flag置零,重启连接
  83.                                                                         break;                                                       //跳出分支case 0x02
  84.                                                 case 0x03 : u1_printf("连接已拒绝,服务端不可用,准备重启\r\n");         //串口输出信息
  85.                                                                         Connect_flag = 0;                                            //Connect_flag置零,重启连接
  86.                                                                         break;                                                       //跳出分支case 0x03
  87.                                                 case 0x04 : u1_printf("连接已拒绝,无效的用户名或密码,准备重启\r\n");   //串口输出信息
  88.                                                                         Connect_flag = 0;                                            //Connect_flag置零,重启连接                                                
  89.                                                                         break;                                                       //跳出分支case 0x04
  90.                                                 case 0x05 : u1_printf("连接已拒绝,未授权,准备重启\r\n");               //串口输出信息
  91.                                                                         Connect_flag = 0;                                            //Connect_flag置零,重启连接                                                
  92.                                                                         break;                                                       //跳出分支case 0x05                 
  93.                                                 default   : u1_printf("连接已拒绝,未知状态,准备重启\r\n");             //串口输出信息
  94.                                                                         Connect_flag = 0;                                            //Connect_flag置零,重启连接                                       
  95.                                                                         break;                                                       //跳出分支case default                                                                 
  96.                                         }                                
  97.                                 }                        
  98.                                 //if判断,如果一共接收了5个字节,第一个字节是0x90,表示收到的是SUBACK报文
  99.                                 //接着我们要判断订阅回复,看看是不是成功
  100.                                 else if((MQTT_RxDataOutPtr[0]==5)&&(MQTT_RxDataOutPtr[1]==0x90)){
  101.                                                 switch(MQTT_RxDataOutPtr[5]){                                       
  102.                                                 case 0x00 :
  103.                                                 case 0x01 : u1_printf("订阅成功\r\n");            //串口输出信息
  104.                                                                 SubcribePack_flag = 1;                //SubcribePack_flag置1,表示订阅报文成功,其他报文可发送
  105.                                                                         Ping_flag = 0;                        //Ping_flag清零
  106.                                                                        TIM3_ENABLE_30S();                    //启动30s的PING定时器
  107.                                                                         break;                                //跳出分支                                             
  108.                                                 default   : u1_printf("订阅失败,准备重启\r\n");  //串口输出信息
  109.                                                                         Connect_flag = 0;                     //Connect_flag置零,重启连接
  110.                                                                         break;                                //跳出分支                                                                 
  111.                                         }                                       
  112.                                 }
  113.                                 //if判断,如果一共接收了2个字节,第一个字节是0xD0,表示收到的是PINGRESP报文
  114.                                 else if((MQTT_RxDataOutPtr[0]==2)&&(MQTT_RxDataOutPtr[1]==0xD0)){
  115.                                         u1_printf("PING报文回复\r\n");                   //串口输出信息
  116.                                         if(Ping_flag==1){                     //如果Ping_flag=1,表示第一次发送
  117.                                                  Ping_flag = 0;                                      //要清除Ping_flag标志
  118.                                         }else if(Ping_flag>1){                                   //如果Ping_flag>1,表示是多次发送了,而且是2s间隔的快速发送
  119.                                                 Ping_flag = 0;                                       //要清除Ping_flag标志
  120.                                                 TIM3_ENABLE_30S();                                   //PING定时器重回30s的时间
  121.                                         }                                
  122.                                 }        
  123.                                 //if判断,如果第一个字节是0x30,表示收到的是服务器发来的推送数据
  124.                                 //我们要提取控制命令
  125.                                 else if((MQTT_RxDataOutPtr[1]==0x30)){
  126.                                         u1_printf("服务器等级0推送\r\n");                    //串口输出信息
  127.                                         MQTT_DealPushdata_Qs0(MQTT_RxDataOutPtr);  //处理等级0推送数据
  128.                                 }                                
  129.                                                                
  130.                                 MQTT_RxDataOutPtr += BUFF_UNIT;                     //指针下移
  131.                                 if(MQTT_RxDataOutPtr==MQTT_RxDataEndPtr)            //如果指针到缓冲区尾部了
  132.                                         MQTT_RxDataOutPtr = MQTT_RxDataBuf[0];          //指针归位到缓冲区开头                        
  133.                         }//处理接收缓冲区数据的else if分支结尾
  134.                         
  135.                         /*-------------------------------------------------------------*/
  136.                         /*                     处理命令缓冲区数据                      */
  137.                         /*-------------------------------------------------------------*/
  138.                         if(MQTT_CMDOutPtr != MQTT_CMDInPtr){                             //if成立的话,说明命令缓冲区有数据了                        
  139.                                 MQTT_CMDOutPtr[MQTT_CMDOutPtr[0]+1] = '\0';                  //加入字符串结束符        
  140.                                 u1_printf("命令:%s\r\n",&MQTT_CMDOutPtr[1]);                 //串口输出信息
  141.                                 if(!memcmp(&MQTT_CMDOutPtr[1],CMD1,strlen(CMD1))){           //判断指令,如果是CMD1
  142.                                         LED1_OUT(!LED1_IN_STA);                                  //开关1状态翻转 如果点亮就熄灭,反之如果熄灭就点亮
  143.                                         LED_CD_State();                                          //判断开关和倒计时状态,并发布给服务器
  144.                                 }else if(!memcmp(&MQTT_CMDOutPtr[1],CMD2,strlen(CMD2))){     //判断指令,如果是CMD2,回复开关状态
  145.                                         LED_CD_State();                                          //判断开关和倒计时状态,并发布给服务器                                
  146.                                 }else if(!memcmp(&MQTT_CMDOutPtr[1],CMD3,strlen(CMD3))){     //判断指令,如果是CMD3,设置倒计时时间
  147.                                         CDTime = MQTT_CMDOutPtr[12];                             //记录倒计时时间
  148.                                         if(CDTime!=0){                                           //如果CDTime不等于0,进入if
  149.                                                 u1_printf("倒计时:%d分钟\r\n",CDTime);               //串口输出信息
  150.                                                 TIM1_ENABLE_60S();                                   //启动定时器1 60s钟定时
  151.                                         }else{                                                   //反之CDTime等于0,进入else,取消定时
  152.                                             u1_printf("取消倒计时\r\n");                         //串口输出信息
  153.                                                 TIM_Cmd(TIM1,DISABLE);                               //关闭TIM1
  154.                                         }
  155.                                         LED_CD_State();                                          //判断开关和倒计时状态,并发布给服务器                                                        
  156.                                 }else u1_printf("未知指令\r\n");                             //串口输出信息
  157.                                 MQTT_CMDOutPtr += BUFF_UNIT;                                      //指针下移
  158.                                 if(MQTT_CMDOutPtr==MQTT_CMDEndPtr)                                //如果指针到缓冲区尾部了
  159.                                         MQTT_CMDOutPtr = MQTT_CMDBuf[0];                               //指针归位到缓冲区开头                                
  160.                         }//处理命令缓冲区数据的else if分支结尾        
  161.                 }//Connect_flag=1的if分支的结尾
  162.                
  163.                 /*--------------------------------------------------------------------*/
  164.                 /*      Connect_flag=0同服务器断开了连接,我们要重启连接服务器         */
  165.                 /*--------------------------------------------------------------------*/
  166.                 else{
  167.                         u1_printf("需要连接服务器\r\n");                 //串口输出信息
  168.                         TIM_Cmd(TIM4,DISABLE);                           //关闭TIM4
  169.                         TIM_Cmd(TIM3,DISABLE);                           //关闭TIM3  
  170.                         WiFi_RxCounter=0;                                //WiFi接收数据量变量清零                        
  171.                         memset(WiFi_RX_BUF,0,WiFi_RXBUFF_SIZE);          //清空WiFi接收缓冲区
  172.                         if(WiFi_Connect_IoTServer()==0){                                //如果WiFi连接云服务器函数返回0,表示正确,进入if
  173.                                 u1_printf("建立TCP连接成功\r\n");            //串口输出信息
  174.                                 Connect_flag = 1;                            //Connect_flag置1,表示连接成功        
  175.                                 WiFi_RxCounter=0;                            //WiFi接收数据量变量清零                        
  176.                                 memset(WiFi_RX_BUF,0,WiFi_RXBUFF_SIZE);      //清空WiFi接收缓冲区
  177.                                 MQTT_Buff_ReInit();                          //重新初始化发送缓冲区                    
  178.                         }                                
  179.                 }
  180.         }
  181. }
  182. /*-------------------------------------------------*/
  183. /*函数名:判断开关和倒计时状态,并发布给服务器     */
  184. /*参  数:无                                       */
  185. /*返回值:无                                       */
  186. /*-------------------------------------------------*/
  187. void LED_CD_State(void)
  188. {
  189.         char temp[20];                                  //定义一个临时缓冲区
  190.         
  191.         memset(temp,0,20);                                 //清空临时缓冲区
  192.         sprintf(temp,"+OneSW:");                      //构建回复数据        
  193.         
  194.         if(LED1_IN_STA) temp[7] = '0';                  //如果LED1是高电平,说明是熄灭状态,开关1状态位置0
  195.         else            temp[7] = '1';                        //反之,说明是点亮状态,开关1状态位置1        
  196.         temp[8] = CDTime;                       //加入剩余倒计时时间

  197.         MQTT_PublishQs0(P_TOPIC_NAME,temp,9);   //添加数据,发布给服务器        
  198. }
复制代码

所有资料51hei提供下载:
STM32代码: 阿里云IoT物联网平台 MQTT 1路开关控制(手机APP)(WiFi例程).7z (211.48 KB, 下载次数: 216)
apk文件: MQTT 一路开关控制安卓app.7z (2.13 MB, 下载次数: 127)

评分

参与人数 2黑币 +60 收起 理由
王者不可阻挡 + 10 共享资料的黑币奖励!至此表达我由衷的感谢
admin + 50 共享资料的黑币奖励!

查看全部评分

分享到:  QQ好友和群QQ好友和群 QQ空间QQ空间 腾讯微博腾讯微博 腾讯朋友腾讯朋友
收藏收藏10 分享淘帖 顶1 踩
回复

使用道具 举报

沙发
ID:911562 发表于 2021-4-24 21:25 | 只看该作者
附件还是不完整,能分享一下apk的代码吗?
回复

使用道具 举报

板凳
ID:836950 发表于 2022-5-23 14:08 | 只看该作者
感谢作者的分享,你是分享给了我极大的帮助,由衷的表达我的感谢
回复

使用道具 举报

地板
ID:99525 发表于 2022-6-16 01:39 | 只看该作者
上云啦,不错不错!
回复

使用道具 举报

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

本版积分规则

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

Powered by 单片机教程网

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