湖畔科技设为首页收藏本站
切换到窄版

湖畔开源电子论坛

 找回密码
 立即注册

扫一扫，访问微社区

QQ登录

只需一步，快速开始

搜索
热搜: 4G NB ZigBee WiFi
湖畔开源电子论坛»首页 › 物联网技术开发 › NB-IOT窄带通信 › NB-IoT模块 移远BC35全网通接入OneNET平台MQTT协议实现 ...
返回列表 发新帖
查看: 2775|回复: 0

NB-IoT模块 移远BC35全网通接入OneNET平台MQTT协议实现数据传输

[复制链接]
湖畔科技

88

主题

89

帖子

846

积分

超级版主

Rank: 8Rank: 8

积分
846
发表于 2019-6-6 11:24:48 | 显示全部楼层 |阅读模式
NB-IoT模块 移远BC35全网通接入OneNET平台MQTT协议实现数据传输
网上很多NB-IOT模块的资料都是使用LWM2M、COAP协议去连接onenet平台
因为现在很多的NB-IOT模块都支持TCP协议，因此就想使用TCP协议然后转MQTT协议连接onenet平台，经过试验证明是可以的。
首先我们先分析一下如何登陆接入Onenet平台。


先从它数据格式开始分析。首先我们要从后台取出三个信息，我们以这个为例。
鉴权信息：test（具体的看你设置的）设备ID：123456789 产品ID：789123  （具体是什么看你自己的设备）
MQTT接入都是发十六进制的数据。
那么我们发送的时候就是这样子的一串数据
0x10 0x24 0x00 0x04 0x4D 0x51 0x54 0x54 0x04 0xC0 0x00 0x78 0x00 0x09 0x31 0x32 0x33 0x34 0x35 0x36 0x37 0x38 0x39 0x00 0x07 0x37 0x38 0x39 0x31 0x32 0x33 0x20 0x00 0x04 0x74 0x65 0x73 0x74

  1. <p>[ 0x10 ] // MQTT类型=1 DupFlag=0 QosLevel=0 Retain=0
  2. [ 0x22 ] // remainedLength=34  以下的数据长度  0x00 04......0x74 0x65 0x73 0x74这个之间的长度，您可以数一下看看</p><p>[ 0x00 0x04 ] // protocolNameLength=4 这是发固定的MQTT这4个字母，长度为4.但是需要两个字节保存长度
  3. [ 0x4D 0x51 0x54 0x54 ] // protocolName=MQTT
  4. [ 0x04 ] // protocolLevel=4  固定的一种类型
  5. [ 0xC0 ] // userFlag=1 passwordFlag=1 willFlag=0 willRetainFlag=0 willQosFlag=0 clenSessionFlag=0 clenSessionFlag=0  固定的一种类型
  6. [ 0x00 0x78 ] // keepAlive=120  这是保持连接的时间为120S</p><p>[ 0x00 0x08] // clientIdentifierLen=8 这是设备ID的长度 用两个字节记录
  7. [ 0x31 0x32 0x33 0x34 0x35 0x36 0x37 0x38 ] // clientIdentifier=12345678 设备ID
  8. [ 0x00 0x06 ] // userNameLen=6 这是产品ID的长度 用两个字节记录
  9. [ 0x37 0x38 0x39 0x31 0x32 0x33] // userName=789123
  10. [ 0x00 0x04 ] // userPasswordLen=4 这是鉴权信息的长度 用两个字节记录
  11. [ 0x74 0x65 0x73 0x74 ] // userPassword=test</p>
复制代码


这里面有个坑，长度的十六进制是十进制转换为十六进制。而“MQTT” ，test（具体的看你设置的）设备ID：123456789 产品ID：789123 这些信息都是字符串转十六进制
下面我们直接上指令

  1. <p>[indent]AT
  2. OK
  3. AT+NRB//重启模块的指令，在单片机里面最好进行重启一下
  4. AT+CMEE=1
  5. OK
  6. AT+CGSN=1
  7. +CGSN:867725030027605
  8. OK
  9. AT+NBAND?
  10. +NBAND:8 //移动的返回+NBAND:8，电信的返回+NBAND:5</p><p>OK
  11. AT+NBAND=8 //设置为移动的，电信的指令为AT+NBAND=5
  12. OK
  13. AT+CIMI //查询卡号
  14. 460042437100213
  15. OK
  16. AT+CSQ //查询信号指令，如果返回+CSQ:99,99 说明还没有信号
  17. +CSQ:29,99
  18. OK
  19. AT+NSOCR=STREAM,6,56000,1 //做TCP socket创建准备
  20. AT+NSOCO=1,183.230.40.33,6002//连接服务器。6002为服务器端口号
  21. OK</p>
复制代码

注意：NB发送数据的时候数据内容需要转换为十六进制。大家可以使用在线转换工具
发送数据的指令为：AT+NSOSD=1,发送内容的长度,内容。//注意长度不可以多或者少

  1. <p>AT+NSOSD=1,36,102200044D51545404C00078000831323334353637380006373839313233000474657374[indent]OK
  2. +NSONMI:1,4//这是服务器返回来的数据。
  3. AT+NSORF=1,4//查询接收内容的指令203是需要查询的长度。可以多，
  4. 1,183.230.40.33,80,203,20200000,0</p><p>
  5. </p><p>
  6. </p><p>OK </p><p>
  7. </p><p>
  8. </p>
复制代码

这个时候已经连接上服务器了，那么现在就发送数据，原始数据如下

  1. {"datastreams":[{"id":"temp","datapoints":[{"value":50}]}]}
复制代码

但是需要增加一些数据头之类的格式

  1. <div>这是转换后的数据</div><div>[/indent][indent]0x30 0x43 0x00 0x03 0x24 0x64 0x70 0x01 0x00 0x3B 0x7B 0x22 0x64 0x61 0x74 0x61 0x73 0x74 0x72 0x65 0x61 0x6D 0x73 0x22 0x3A 0x5B 0x7B 0x22 0x69 0x64 0x22 0x3A 0x22 0x74 0x65 0x6D 0x70 0x22 0x2C 0x22 0x64 0x61 0x74 0x61 0x70 0x6F 0x69 0x6E 0x74 0x73 0x22 0x3A 0x5B 0x7B 0x22 0x76 0x61 0x6C 0x75 0x65 0x22 0x3A 0x35 0x30 0x7D 0x5D 0x7D 0x5D 0x7D[/indent][indent]</div><div>
  2. </div><div>各个数据的含义[/indent][indent][indent][ 0x30 ]   // MQTT类型=3  DupFlag=0 QosLevel=0 Retain=0  选用类型为3[/indent][indent][ 0x43 ]   // remainedLength=67 [/indent][indent][ 0x00 0x03 ]   // TopicNameLen=3 [/indent][indent][ 0x24 0x64 0x70 ]   // TopicName=$dp </div><div>这是固定的数据[/indent][indent][ 0x01 ]   // DpType=1 TimeSet=0 [/indent][indent][ 0x00 0x3B ]   // JsonStrLen=59 这是json数据的长度[/indent][indent][ 0x7B 0x22 0x64 0x61 0x74 0x61 0x73 0x74 0x72 0x65 0x61 0x6D 0x73 0x22 0x3A 0x5B 0x7B 0x22 0x69 0x64 0x22 0x3A 0x22 0x74 0x65 0x6D 0x70 0x22 0x2C 0x22 0x64 0x61 0x74 0x61 0x70 0x6F 0x69 0x6E 0x74 0x73 0x22 0x3A 0x5B 0x7B 0x22 0x76 0x61 0x6C 0x75 0x65 0x22 0x3A 0x35 0x30 0x7D 0x5D 0x7D 0x5D 0x7D ]   // JsonStr={"datastreams":[{"id":"temp","datapoints":[{"value":50}]}]} [/indent]</div>
复制代码


下面我们开始发送数据到服务器

  1. AT+NSOSD=1,69,3043000324647001003B7B226461746173747265616D73223A5B7B226964223A2274656D70222C2264617461706F696E7473223A5B7B2276616C7565223A35307D5D7D5D7D[/indent][indent]OK
  2. +NSONMI:1,4//这是服务器返回来的数据。[/indent]AT+NSOCL=1 //关闭连接
  3. OK
复制代码


完整的步骤

  1. <p>AT
  2. OK
  3. AT+NRB//重启模块的指令，在单片机里面最好进行重启一下
  4. AT+CMEE=1
  5. OK
  6. AT+CGSN=1
  7. +CGSN:867725030027605
  8. OK
  9. AT+NBAND?
  10. +NBAND:8 //移动的返回+NBAND:8，电信的返回+NBAND:5</p><p>OK
  11. AT+NBAND=8 //设置为移动的，电信的指令为AT+NBAND=5
  12. OK
  13. AT+CIMI //查询卡号
  14. 460042437100213
  15. OK
  16. AT+CSQ //查询信号指令，如果返回+CSQ:99,99 说明还没有信号
  17. +CSQ:29,99
  18. OK
  19. AT+NSOCR=STREAM,6,56000,1 //做TCP socket创建准备
  20. AT+NSOCO=1,183.230.40.33,6002//连接服务器。6002为服务器端口号
  21. OK
  22. AT+NSOSD=1,36,102200044D51545404C00078000831323334353637380006373839313233000474657374</p><p>OK
  23. +NSONMI:1,4//这是服务器返回来的数据。
  24. AT+NSORF=1,4//查询接收内容的指令203是需要查询的长度。可以多，
  25. 1,183.230.40.33,80,203,20200000,0</p><p>OK
  26. [indent]AT+NSOSD=1,69,3043000324647001003B7B226461746173747265616D73223A5B7B226964223A2274656D70222C2264617461706F696E7473223A5B7B2276616C7565223A35307D5D7D5D7D[/indent][indent]OK
  27. +NSONMI:1,4//这是服务器返回来的数据。[/indent][indent]AT+NSOCL=1 //关闭连接
  28. OK[/indent]</p>
复制代码


附上C语言转十六进制函数

  1. <p>int Str2Hex(char *str,char *hex)
  2. {
  3. int high = 0;
  4. int low = 0;
  5. int temp = 0;</p><p>if (NULL==str || NULL==hex){
  6. //printf("the str or hex is wrong\n");
  7. return -1;
  8. }</p><p>if (0==strlen(str)){
  9. //printf("the input str is wrong\n");
  10. return -2;
  11. }</p><p>while(*str)
  12. {
  13. temp = (int)(*str);
  14. high = temp>>4;
  15. low = temp & 15;
  16. *hex = Value2Hex(high);
  17. hex++;
  18. *hex = Value2Hex(low);
  19. hex++;
  20. str++;
  21. }
  22. *hex = '\0';
  23. return 0;
  24. }</p>
复制代码


附上发送MQTT连接服务器的数据及发送数据的格式化函数

  1. <p>void ClearRAM(u8* ram,u32 n)
  2. {
  3. u32 i;
  4. for (i = 0;i < n;i++)
  5. {
  6. ram[i] = 0x00;
  7. }
  8. }
  9. //构建MQTT连接包
  10. u16 mqtt_connect_message(char *mqtt_message,char *PROID,char *AUTH_INFO,char *DEVID)
  11. {
  12. //        char HTTP_Buf[400]; //HTTP报文缓存区
  13. char str[500];
  14. char strHEX[500];
  15. u16 PROID_length = strlen(PROID);
  16. u16 DEVID_length = strlen(DEVID);
  17. u16 AUTH_INFO_length = strlen(AUTH_INFO);
  18. u16 MQTT_length = strlen("MQTT");
  19. u16 packetLen;
  20. u16 i,baseIndex;
  21. ClearRAM((u8*)str,200); //清空commandAT数据包缓存，发送命令包含ip端口和长度
  22. ClearRAM((u8*)strHEX,200); //清空locationHex数据包缓存，转换为hex 需要发送的真实数据
  23. packetLen = 12;//固定的数据头长度
  24. if(PROID_length > 0)
  25. packetLen = packetLen + 2 + PROID_length;
  26. if(DEVID_length > 0)
  27. packetLen = packetLen+ 2 + DEVID_length;
  28. if(AUTH_INFO_length > 0)
  29. packetLen = packetLen+ 2 + AUTH_INFO_length;</p><p>strncpy((char*)(mqtt_message+strlen((char*)mqtt_message)),"10",2);
  30. sprintf(strHEX,"%02x",(packetLen-2));</p><p>strcat(mqtt_message,strHEX);
  31. ClearRAM((u8*)str,200); //清空commandAT数据包缓存，发送命令包含ip端口和长度
  32. ClearRAM((u8*)strHEX,200); //清空locationHex数据包缓存，转换为hex 需要发送的真实数据
  33. strcat(mqtt_message,"00044D51545404C00100");        
  34. //装载设备ID到数据包        
  35. sprintf(str, "%02x%02x",((0xff00&(DEVID_length))>>8),(0xff&DEVID_length));
  36. strcat(mqtt_message,str);
  37. ClearRAM((u8*)str,200);
  38. sprintf(str, "%s",DEVID);
  39. Str2Hex((char*)str,(char*)strHEX);
  40. strcat(mqtt_message,strHEX);        
  41. ClearRAM((u8*)str,200);
  42. ClearRAM((u8*)strHEX,200);
  43. //装载产品ID到数据包        
  44. sprintf(str, "%02x%02x",((0xff00&(PROID_length))>>8),(0xff&PROID_length));
  45. strcat(mqtt_message,str);
  46. ClearRAM((u8*)str,200);
  47. sprintf(str, "%s",PROID);
  48. Str2Hex((char*)str,(char*)strHEX);
  49. strcat(mqtt_message,strHEX);        
  50. ClearRAM((u8*)str,200);
  51. ClearRAM((u8*)strHEX,200);
  52. //装载产品ID到数据包        
  53. sprintf(str, "%02x%02x",((0xff00&(AUTH_INFO_length))>>8),(0xff&AUTH_INFO_length));
  54. strcat(mqtt_message,str);
  55. ClearRAM((u8*)str,200);
  56. sprintf(str, "%s",AUTH_INFO);
  57. Str2Hex((char*)str,(char*)strHEX);
  58. strcat(mqtt_message,strHEX);        
  59. ClearRAM((u8*)str,200);
  60. ClearRAM((u8*)strHEX,200);
  61. Str2Hex((char*)str,(char*)strHEX);
  62. strcat(mqtt_message,strHEX);
  63. strcat(mqtt_message,"\r\n");        
  64. return packetLen;
  65. }
  66. //构建MQTT数据包
  67. u16 mqtt_SendData_message(char *mqtt_messageHEX,char *SendData,short length)
  68. {
  69. char str[200];
  70. char strHEX[200];
  71. u16 packetLen=length+8;
  72. u16 SendData_length = strlen(SendData);
  73. strncpy((char*)(mqtt_messageHEX+strlen((char*)mqtt_messageHEX)),"30",2);
  74. sprintf(strHEX,"%02x",(packetLen));
  75. strcat(mqtt_messageHEX,strHEX);
  76. ClearRAM((u8*)str,200); //清空commandAT数据包缓存，发送命令包含ip端口和长度
  77. ClearRAM((u8*)strHEX,200); //清空locationHex数据包缓存，转换为hex 需要发送的真实数据
  78. strcat(mqtt_messageHEX,"01000324647001");        
  79. //装载json数据到数据包        
  80. sprintf(str, "%02x%02x",((0xff00&(SendData_length))>>8),(0xff&SendData_length));
  81. strcat(mqtt_messageHEX,str);
  82. ClearRAM((u8*)str,200);
  83. sprintf(str, "%s",SendData);
  84. Str2Hex((char*)str,(char*)strHEX);
  85. strcat(mqtt_messageHEX,strHEX);        
  86. ClearRAM((u8*)str,200);
  87. ClearRAM((u8*)strHEX,200);        
  88. return packetLen;
  89. }        </p>
复制代码


到此结束。有什么不对的地方还望指正
MQTT ONEnet测试调试工具


回复

使用道具 举报

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

本版积分规则

QQ|官方淘宝店|手机版|湖畔科技官网|加入QQ群|湖畔开源电子论坛 ( 公安备案：45010702001370（交互式论坛） 工信部备案：桂ICP备17008293号 )

GMT+8, 2024-11-23 16:00 , Processed in 0.042479 second(s), 22 queries .

Powered by 湖畔科技

Copyright © 2001-2021

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