21ic电子技术开发论坛 › 非技术讨论区 › 活动专区 › 二姨家买单活动】之二：NB模块BC26模块MQTT测试 ...
返回列表 发新帖我要提问

[活动] 二姨家买单活动】之二：NB模块BC26模块MQTT测试

[复制链接]
1149|0
 楼主| abner_ma 发表于 2022-4-2 17:14 | 显示全部楼层 |阅读模式
QT
     接上一篇【二姨家买单活动】之一：万物物联之NB模块牛刀小试   继续捣鼓BC26模块。

     为了满足当下IoT应用的多样化需求，市面上开放了包括CoAP、XMPP和DDS在内的多种协议，可供各个应用场景按需选择。MQTT是IBM开发的一个即时通讯协议，基于TCP的，号称是可以支持所有的平台。CoAP是运行于UDP之上的，并且非常的小巧，最小只有4个字节。可以说两者都是营运物联网大趋势和为了适应M2M而生的，相比于其他的通信协议也有较大的优势。其中，消息队列遥测传输(MQTT)及其衍生协议MQTT-SN正广泛应用在日益普遍的低功耗广域(LPWA)网络中。MQTT，目前物联网的最主要的协议，基本所有的云平台都是基于MQTT协议，比如阿里云华为云，中国移动的oneNet、百度的云平台也都支持MQTT的接入
1、MQTT 协议
作为一种轻量级协议，MQTT拥有简单紧凑的架构和较小的代码占用空间，适用于低成本、低功耗的IoT微控制设备。MQTT可在TCP/IP协议上兼容运行，专攻延迟较高、质量不佳的网络环境。该协议适用于具有以下通信需求的应用：
   使用极小带宽
   无线网络通信
   低功耗
   必要时保证高可靠性
   对处理和内存资源的需求很低
   MQTT在IoT多种应用中都备受青睐，如智能表计、资产追踪工具和工业设备的互联传感器。凭借对有限带宽的高效利用，因此MQTT非常适用于网络成本高、功耗大的应用场景，例如远程传感器阵列就需要在现场自主运行数年且期间无需维修。MQTT是多个客户端通过一个中央服务器传递信息的多对多协议，能高效地将信息分发给一个或多个订阅者，加之其代码占用空间小，便使得MQTT成为移动应用通信的理想之选。


2、MQTT 功能概述
   MQTT基于发布和订阅模型，而非“客户端-服务器”模型，它具有两个功能实体——MQTT服务器和MQTT客户端。IoT网络上的任何“事物”，无论是硬件设备还是软件程序，都可以视为MQTT的客户端。所有的客户端并非直接向彼此发布或订阅消息，而是向MQTT服务器所管理的“主题”来发布或订阅消息。“主题”可理解为电子邮件的收件箱；客户端向主题发布消息，订阅该主题的其他客户端都将收到该消息。MQTT服务器负责接收所有已发布的消息，并需要确保将其传输到所有订阅的客户端。消息根据多个商定的QoS级别进行发布。服务器还将对网络上的所有IoT设备进行验证。
  
BC26模块：



  BC26 AT阿里云MQTT 核心指令
复制
  1. AT+CGPADDR=1
    

  2. +CGPADDR: 1,100.91.141.117
    


  3. 

  4. OK
    

  5. AT+QMTCFG="ALIAUTH",0,"a18dtRetCT0","BC26TEST","2oBrMJHjTlHbi8V1uoRGQZcC2SlKBXHE" 
    

  6. OK
    

  7. AT+QMTOPEN=0,"iot-as-mqtt.cn-shanghai.aliyuncs.com",1883
    

  8. OK
    


  9. 

  10. +QMTOPEN: 0,0
    

  11. AT+QMTCONN=0,"BC26TEST"
    

  12. OK
    


  13. 

  14. +QMTCONN: 0,0,0
    

  15. AT+QMTSUB=0,1,"/a18dtRetCT0/BC26TEST/user/get",0 
    

  16. OK
    


  17. 

  18. +QMTSUB: 0,1,0,1
    

  19. AT+QMTPUB=0,1,1,0,"/sys/a18dtRetCT0/BC26TEST/thing/event/property/post","{params:{IndoorTemperature:58.8}}"
    

  20. OK
    


  21. 

  22. +QMTPUB: 0,1,0
         
一，在阿里云物联网平台新建产品和添加设备
   阿里物联网平台连接https://account.aliyun.com/login/login.htm?oauth_callback=https%3A%2F%2Fiot.console.aliyun.com%2Fdevices&lang=zh
   在后面接入设备时需要用到三要素：ProductKey，DeviceName，DeviceSecret
   ProductKey会在新建产品时生成，DeviceName可以自己定义，应该是只支持英文和数字，DeviceSecret会在添加设备完成后自动生成。

  
二，设计产品上传数据结构

三 STM32 BC26 MQTT核心代码
复制
  1. #include "bc26.h"
    

  2. #include "string.h"
    

  3. #include "usart.h"
    

  4. #include "wdg.h"
    

  5. #include "led.h"
    

  6. char *strx,*extstrx;
    

  7. extern unsigned char  RxBuffer[255],RxCounter;
    

  8. BC26 BC26_Status;
    


  9. 

  10. #define ProductKey     "a1dxl58BsE6"             //²úÆ·KEY
    

  11. #define DeviceName          "m001"      //
    

  12. #define DeviceSecret    "b9c04a0d041aa2eb8f2e5fd437ae7fd5"  //
    

  13. #define PubTopic         "/sys/a1dxl58BsE6/m001/thing/event/property/post"//·¢²¼Ö÷Ìâ
    

  14. #define SubTopic        "/sys/a1NXoxeFw4c/mzh002/thing/service/property/set"//¶©ÔÄÖ÷Ìâ
    

  15. void Clear_Buffer(void)//Çå¿Õ»º´æ
    

  16. {
    

  17.                 u8 i;
    

  18.                 Uart1_SendStr((char*)RxBuffer);
    

  19.                 for(i=0;i<100;i++)
    

  20.                 RxBuffer[i]=0;//»º´æ
    

  21.                 RxCounter=0;
    

  22.                 IWDG_Feed();//ι¹·
    

  23.         
    

  24. }
    

  25. void BC26_Init(void)
    

  26. {
    

  27.     printf("AT\r\n"); 
    

  28.     delay_ms(300);
    

  29.     strx=strstr((const char*)RxBuffer,(const char*)"OK");//·µ»ØOK
    

  30.     Clear_Buffer();        
    

  31.     while(strx==NULL)
    

  32.     {
    

  33.         Clear_Buffer();        
    

  34.         printf("AT\r\n"); 
    

  35.         delay_ms(300);
    

  36.         strx=strstr((const char*)RxBuffer,(const char*)"OK");//·µ»ØOK
    

  37.     }
    

  38.     printf("AT+CFUN=1\r\n");//»ñÈ¡¿¨ºÅ£¬ÀàËÆÊÇ·ñ´æÔÚ¿¨µÄÒâ˼£¬±È½ÏÖØÒª¡£
    

  39.     delay_ms(300);
    

  40.     printf("AT+CIMI\r\n");//»ñÈ¡¿¨ºÅ£¬ÀàËÆÊÇ·ñ´æÔÚ¿¨µÄÒâ˼£¬±È½ÏÖØÒª¡£
    

  41.     delay_ms(300);
    

  42.     strx=strstr((const char*)RxBuffer,(const char*)"460");//·µ460£¬±íÃ÷ʶ±ðµ½¿¨ÁË
    

  43.     Clear_Buffer();        
    

  44.     while(strx==NULL)
    

  45.     {
    

  46.         Clear_Buffer();        
    

  47.         printf("AT+CIMI\r\n");//»ñÈ¡¿¨ºÅ£¬ÀàËÆÊÇ·ñ´æÔÚ¿¨µÄÒâ˼£¬±È½ÏÖØÒª¡£
    

  48.         delay_ms(300);
    

  49.         strx=strstr((const char*)RxBuffer,(const char*)"460");//·µ»ØOK,˵Ã÷¿¨ÊÇ´æÔÚµÄ
    

  50.     }
    

  51.         printf("AT+CGATT=1\r\n");//¼¤»îÍøÂ磬PDP
    

  52.         delay_ms(300);
    

  53.         strx=strstr((const char*)RxBuffer,(const char*)"OK");//·µOK
    

  54.         Clear_Buffer();        
    

  55.         printf("AT+CGATT?\r\n");//²éѯ¼¤»î״̬
    

  56.         delay_ms(300);
    

  57.         strx=strstr((const char*)RxBuffer,(const char*)"+CGATT: 1");//·µ1
    

  58.         Clear_Buffer();        
    

  59.                 while(strx==NULL)
    

  60.                 {
    

  61.             Clear_Buffer();        
    

  62.             printf("AT+CGATT?\r\n");//»ñÈ¡¼¤»î״̬
    

  63.             delay_ms(300);
    

  64.             strx=strstr((const char*)RxBuffer,(const char*)"+CGATT: 1");//·µ»Ø1,±íÃ÷×¢Íø³É¹¦
    

  65.                 }
    

  66.                 printf("AT+CESQ\r\n");//²é¿´»ñÈ¡CSQÖµ
    

  67.         delay_ms(300);
    

  68.         strx=strstr((const char*)RxBuffer,(const char*)"+CESQ");//·µ»ØCSQ
    

  69.                 if(strx)
    

  70.                         {
    

  71.                                 BC26_Status.CSQ=(strx[7]-0x30)*10+(strx[8]-0x30);//»ñÈ¡CSQ
    

  72.                                 if((BC26_Status.CSQ==99)||((strx[7]-0x30)==0))//˵Ã÷ɨÍøʧ°Ü
    

  73.                                 {
    

  74.                                         while(1)
    

  75.                                         {
    

  76.             BC26_Status.netstatus=0;
    

  77.                                                 Uart1_SendStr("ÐźÅËÑË÷ʧ°Ü£¬Çë²é¿´Ô­Òò!\r\n");
    

  78.                                                 delay_ms(300);//ûÓÐÐźž͸´Î»
    

  79.                         
    

  80.                                         }
    

  81.                                 }
    

  82.              else
    

  83.              {
    

  84.                  BC26_Status.netstatus=1;
    

  85.               }
    

  86.                 
    

  87.             }
    

  88.               Clear_Buffer();        
    

  89. }
    


  90. 


  91. 


  92. 


  93. 

  94. void BC26_ConTCP(void)
    

  95. {
    

  96.         printf("AT+QICLOSE=0\r\n");//¹Ø±ÕsocektÁ¬½Ó
    

  97.         delay_ms(300);
    

  98.     Clear_Buffer();
    

  99.     IWDG_Feed();//ι¹·
    

  100. }
    

  101. void BC26_CreateTCPSokcet(void)//´´½¨sokcet
    

  102. {
    


  103. 

  104.     printf("AT+QIOPEN=1,0,"TCP","47.99.80.89",14269,1234,1\r\n");//´´½¨Á¬½ÓTCP,ÊäÈëIPÒÔ¼°·þÎñÆ÷¶Ë¿ÚºÅÂë ,²ÉÓÃÖ±½ÓͳöµÄ·½Ê½
    

  105.     delay_ms(300);
    

  106.     strx=strstr((const char*)RxBuffer,(const char*)"+QIOPEN: 0,0");//¼ì²éÊÇ·ñµÇ½³É¹¦
    

  107.          while(strx==NULL)
    

  108.                 {
    

  109.             strx=strstr((const char*)RxBuffer,(const char*)"+QIOPEN: 0,0");//¼ì²éÊÇ·ñµÇ½³É¹¦
    

  110.             delay_ms(100);
    

  111.                 }  
    

  112.      Clear_Buffer();        
    

  113.     
    

  114. }
    

  115. void BC26_Senddata(uint8_t *len,uint8_t *data)//×Ö·û´®ÐÎʽ
    

  116. {
    

  117.     printf("AT+QSOSEND=0,%s,%s\r\n",len,data);
    

  118. }
    


  119. 

  120. void BC26_Senddatahex(uint8_t *len,uint8_t *data)//·¢ËÍÊ®Áù½øÖÆÊý¾Ý
    

  121. {
    

  122.     printf("AT+QISENDEX=0,%s,%s\r\n",len,data);
    

  123.         delay_ms(300);
    

  124.          while(strx==NULL)
    

  125.                 {
    

  126.             strx=strstr((const char*)RxBuffer,(const char*)"SEND OK");//¼ì²éÊÇ·ñ·¢Ëͳɹ¦
    

  127.             delay_ms(100);
    

  128.                 }  
    

  129.      Clear_Buffer();        
    

  130. }
    


  131. 

  132. void BC26_RECData(void)
    

  133. {
    


  134. 

  135.   
    

  136. }
    


  137. 


  138. 


  139. 

  140. void  MQTT_Init(void)
    

  141. {
    

  142.   
    

  143.     printf("AT+QMTCFG="aliauth",0,"%s","%s","%s"\r\n",ProductKey,DeviceName,DeviceSecret);
    

  144.     delay_ms(300);
    

  145.     printf("AT+QMTOPEN=0,"139.196.135.135",1883\r\n");//ͨ¹ýTCP·½Ê½È¥Á¬½ÓMQTT°¢ÀïÔÆ·þÎñÆ÷ 
    

  146.     delay_ms(300);
    

  147.     strx=strstr((const char*)RxBuffer,(const char*)"+QMTOPEN: 0,0");//¿´Ï·µ»Ø״̬
    

  148.   while(strx==NULL)
    

  149.     {
    

  150.       strx=strstr((const char*)RxBuffer,(const char*)"+QMTOPEN: 0,0");//È·ÈÏ·µ»ØÖµÕýÈ·
    

  151.     }
    

  152.     Clear_Buffer(); 
    

  153.    printf("AT+QMTCONN=0,"clientExample_1987"\r\n");//È¥µÇ¼MQTT·þÎñÆ÷
    

  154.     delay_ms(300);
    

  155.     strx=strstr((const char*)RxBuffer,(const char*)"+QMTCONN: 0,0,0");//¿´Ï·µ»Ø״̬
    

  156.   while(strx==NULL)
    

  157.     {
    

  158.         strx=strstr((const char*)RxBuffer,(const char*)"+QMTCONN: 0,0,0");//¿´Ï·µ»Ø״̬
    

  159.     }
    

  160.     Clear_Buffer(); 
    

  161.     /*
    

  162.     printf("AT+QMTSUB=0,1,"mzh_m26",0\r\n");//¶©ÔĸöÖ÷Ìâ
    

  163.         delay_ms(500);
    

  164.     strx=strstr((const char*)RxBuffer,(const char*)"+QMTSUB: 0,1,0,0");//¶©Ôijɹ¦
    

  165.   while(strx==NULL)
    

  166.     {
    

  167.         strx=strstr((const char*)RxBuffer,(const char*)"+QMTSUB: 0,1,0,0");//¶©Ôijɹ¦
    

  168.     }
    

  169.     Clear_Buffer(); 
    

  170.     */
    

  171. }
    


  172. 

  173. void aliyunMQTT_PUBdata(u8 temp,u8 humi)
    

  174. {
    

  175.      u8 t_payload[200],len;
    

  176.      printf("AT+QMTPUB=0,0,0,0,%s\r\n",PubTopic);//·¢²¼Ö÷Ìâ
    

  177.      delay_ms(300);
    

  178.      len=Mqttaliyun_Savedata(t_payload,temp,humi);
    

  179.      t_payload[len]=0;
    

  180.      printf("%s",t_payload);
    

  181.   while((USART2->SR&0X40)==0){}//Ñ­»··¢ËÍ,Ö±µ½·¢ËÍÍê±Ï   
    

  182.      USART2->DR = (u8) 0x1A;    
    

  183.      delay_ms(100);
    

  184.      strx=strstr((const char*)RxBuffer,(const char*)"+QMTPUB: 0,0,0");//¿´Ï·µ»Ø״̬
    

  185.   while(strx==NULL)
    

  186.     {
    

  187.         strx=strstr((const char*)RxBuffer,(const char*)"+QMTPUB: 0,0,0");//¿´Ï·µ»Ø״̬
    

  188.     }
    

  189.     Clear_Buffer(); 
    

  190. }
    


  191. 

  192. //·ÃÎÊ°¢ÀïÔÆÐèÒªÌá½»JSONÊý¾Ý
    

  193. u8 Mqttaliyun_Savedata(u8 *t_payload,u8 temp,u8 humi)
    

  194. {
    


  195. 

  196.     char json[]="{"id":"26","version":"1.0","params":{"CurrentTemperature":{"value":%d},"CurrentHumidity":{"value":%d}},"method":"thing.event.property.post"}";         //     char json[]="{"datastreams":[{"id":"location","datapoints":[{"value":{"lon":%2.6f,"lat":%2.6f}}]}]}";
    

  197.     char t_json[200];
    

  198.     unsigned short json_len;
    

  199.     sprintf(t_json, json, temp, humi);
    

  200.     json_len = strlen(t_json)/sizeof(char);
    

  201.           memcpy(t_payload, t_json, json_len);
    

  202.     return json_len;
    

  203. }
    


  204.




MQTT把数据传送到阿里云



代码见附件

MQTT 协议 3.1.1 中文版
  



本帖子中包含更多资源

您需要 登录 才可以下载或查看，没有账号？注册

×
回复

收藏 举报

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

本版积分规则

abner_ma Image
认证：项目经理
简介：资深嵌入式开发工程师

104

主题

191

帖子

3

粉丝
快速回复 在线客服 返回列表 返回顶部