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

 找回密码
 立即注册

QQ登录

只需一步，快速开始

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

搜索
»论坛 › 嵌入式/单片机论坛 › STM32/8 › 阿里云物联网平台，stm32，mqtt协议 源程序
返回列表 发新帖
查看: 5014|回复: 4
打印 上一主题 下一主题
收起左侧

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

  [复制链接]
跳转到指定楼层
楼主
ID:808464 发表于 2020-7-27 15:38 | 只看该作者 |只看大图 回帖奖励 |倒序浏览 |阅读模式
使用stm32，ESP8266WiFi数据传输，mqtt协议，阿里云物联网平台，程序源码，下载可用。附app应用。

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

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

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

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

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

评分

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

查看全部评分

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

使用道具 举报

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

使用道具 举报

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

使用道具 举报

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

使用道具 举报

5#
ID:25103 发表于 2024-3-3 17:43 | 只看该作者
由衷的表达我的感谢
回复

使用道具 举报

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

本版积分规则

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

Powered by 单片机教程网

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