【OneNET麒麟座试用体验】5.OneNET之网络协议HTTP上传

一：配置与原理

1、OneNet的简单介绍

OneNET是中国移动物联网有限公司响应“大众创新、万众创业”以及基于开放共赢的理念，面向公共服务自主研发的开放云平台，为各种跨平台物联网应用、行业解决方案提供简便的海量连接、云端存储、消息分发和大数据分析等优质服务，从而降低物联网企业和个人（创客）的研发、运营和运维成本，使物联网企业和个人（创客）更加专注于应用，共建以OneNET为中心的物联网生态环境。

OneNET平台提供设备全生命周期管理相关工具，帮助个人、企业快速实现大规模设备的云端管理；开放第三方API接口，推进个性化应用系统构建；提供定制化“和物”APP，加速个性化智能应用生成。(我是copy的，五毛一条 ~.~ )

对于我们开发来讲，支持多种行业标准协议的解析和转换，如MQTT、Modbus、EDP、http等就可以了。

2、http协议

超文本传输协议（HTTP，HyperText Transfer Protocol)是互联网上应用最为广泛的一种网络协议。所有的WWW文件都必须遵守这个标准。即我们上网冲浪就少不了使用它。这里是使用的HTTP 1.1，关于网络协议不是很懂，这里程序也就移植别人写好的，这里贴上onenet 的HTTP协议介绍及使用 ：点我跳转。

3. 网络接入

这里先选择使用wifi模块，esp8266来接入网络，根据其手册，可以使用透传模式来post http数据。

wifi连接OK后，使用AT+CIPSTART="TCP","183.230.40.33",80  接入移动的服务器，再使用AT+CIPSEND=“数据流长度”发送我们准备好的数据。更多信息可参考文档和例程。

4.硬件软件配置

开发板硬件已经ok，我们需要配置的是STM的软件资源，依旧使用CUBEMX，方便快捷：

勾选定时器6和7

定时器的预分频和计数周期配置，

然后生成代码。

二、软件的编写与网络协议移植

1、在上面的基础上，我们首先根据所需要移植的网络协议部分添加到工程：

修改wifi连接的ssid密码，OneNET的设备ID和apikey

1. NET_DEVICE_INFO netDeviceInfo = {"wifi ssid", "password", 0, 0, 0, 0};
   
2. ONETNET_INFO oneNetinfo = {"device id", "your api key", 0, 0, 0, 0};

复制代码

添加定时器中断程序：

修改串口接收中断回调函数：

1. void HAL_UART_RxCpltCallback(UART_HandleTypeDef *UartHandle)
   
2. {
   
3.     if(netIOInfo.dataLen >= sizeof(netIOInfo.buf))        netIOInfo.dataLen = 0; //·ÀÖ¹´®¿Ú±»Ë¢±¬
   
4.     netIOInfo.buf[netIOInfo.dataLen++] = AT_rxdata;
   
5.     AT_rxdata = 0;
   
6.     HAL_UART_Receive_IT(&huart2,&AT_rxdata,1);
   
7. }
   

复制代码

修改net_io.c里的串口发送函数：

copy过来的程序主要需要修改的就是这些地方了，

2、main.c的修改

在我之前工程主函数里添加数据流数组：

main函数里修改如下：

1. int main(void)
   
2. {
   
3. 
   
4.     /* USER CODE BEGIN 1 */
   
5.     uint8_t *dataPtr;
   
6.     uint16_t runTime = 0;
   
7.     _Bool sendFlag = 0;
   
8.     /* USER CODE END 1 */
   
9. 
   
10.     /* MCU Configuration----------------------------------------------------------*/
    
11. 
    
12.     /* Reset of all peripherals, Initializes the Flash interface and the Systick. */
    
13.     HAL_Init();
    
14. 
    
15.     /* Configure the system clock */
    
16.     SystemClock_Config();
    
17. 
    
18.     /* Initialize all configured peripherals */
    
19.     MX_GPIO_Init();
    
20.     MX_I2C2_Init();
    
21.     MX_USART1_UART_Init();
    
22.     MX_USART2_UART_Init();
    
23.     MX_TIM6_Init();
    
24.     MX_TIM7_Init();
    
25. 
    
26.     /* USER CODE BEGIN 2 */
    
27.     HAL_TIM_Base_Start_IT(&htim6);
    
28.     HAL_TIM_Base_Start_IT(&htim7);
    
29.     HAL_UART_Receive_IT(&huart2,&AT_rxdata,1);
    
30.     LED_test();
    
31.     Dev_Check();
    
32.     //ESP8266_Rst();
    
33.     HAL_Delay(2000);
    
34.     // NET_device_test();
    
35.     // AT24C02_test();
    
36.     SHT20_init();
    
37.     //SHT20_test();
    
38.     ADXL345_init();
    
39. 
    
40.     NET_DEVICE_IO_Init();                                                                //网络设备IO初始化
    
41.     NET_DEVICE_Set_DataMode(DEVICE_CMD_MODE);                        //设置为命令收发模式(例如ESP8266要区分AT的返回还是平台下发数据的返回)
    
42.     printf("Connect->> SSID: %s,   PSWD: %srn"
    
43.            "DEVID: %s,     APIKEY: %srn"
    
44.            , netDeviceInfo.staName, netDeviceInfo.staPass
    
45.            , oneNetInfo.devID, oneNetInfo.apiKey);
    
46. 
    
47.     netDeviceInfo.reboot = 1;
    
48.     /* USER CODE END 2 */
    
49. 
    
50.     /* Infinite loop */
    
51.     /* USER CODE BEGIN WHILE */
    
52.     while (1)
    
53.     {
    
54.         /* USER CODE END WHILE */
    
55. 
    
56.         /* USER CODE BEGIN 3 */
    
57.         HAL_GPIO_TogglePin(GPIOC,LED_Green_Pin);  //led
    
58. //        SHT20_test();
    
59. //        adxl345_test();
    
60. //                           HAL_Delay(200);
    
61. //        angle_test();
    
62.         if(oneNetInfo.netWork == 1)
    
63.         {
    
64.             if(timInfo.timer6Out - runTime >= 800)                                                                        //25s一次(25ms中断)
    
65.             {
    
66.                 runTime = timInfo.timer6Out;
    
67.                 if(sendFlag)
    
68.                 {
    
69.                     HAL_TIM_Base_Stop_IT(&htim6);
    
70.                     OneNet_Status();                                                                                                //状态检查
    
71.                     HAL_TIM_Base_Start_IT(&htim6);
    
72.                 }
    
73.                 else
    
74.                 {
    
75.                     HAL_TIM_Base_Stop_IT(&htim6);
    
76.                     OneNet_SendData(HTTP_TYPE3, dataStreamLen);                                                //数据发送
    
77.                     HAL_TIM_Base_Start_IT(&htim6);
    
78.                 }
    
79. 
    
80.                 sendFlag = !sendFlag;
    
81.             }
    
82. 
    
83.             /******************************************************************************
    
84.                                     发送结果解析
    
85.             ******************************************************************************/
    
86.             if(oneNetInfo.netWork && NET_DEVICE_Get_DataMode() == DEVICE_DATA_MODE)        //当有网络 且 在命令接收模式时
    
87.             {
    
88.                 dataPtr = NET_DEVICE_GetIPD(0);                                                                                //不等待，获取平台下发的数据
    
89.                 if(dataPtr != NULL)                                                                                                        //如果数据指针不为空，则代表收到了数据
    
90.                 {
    
91.                     OneNet_Event(dataPtr);                                                                                        //集中处理
    
92.                 }
    
93.             }
    
94. 
    
95.             /******************************************************************************
    
96.                                     传感器
    
97.             ******************************************************************************/
    
98.             if(checkInfo.ADXL345_OK == DEV_OK)                                                                                 //只有设备存在时，才会读取值和显示
    
99.             {
    
100.                 Angle_test( );            //采集传感器数据
     
101.                 Gravity_test( );
     
102.                 //        Lcd1602_DisString(0x80, "X%0.1f,Y%0.1f,Z%0.1f", adxlInfo.incidence_Xf, adxlInfo.incidence_Yf, adxlInfo.incidence_Zf);
     
103.                 //        OLED_DisString6x8(1, 40, "X%0.1f,Y%0.1f,Z%0.1f", adxlInfo.incidence_Xf, adxlInfo.incidence_Yf, adxlInfo.incidence_Zf);
     
104.             }
     
105.             if(checkInfo.SHT20_OK == DEV_OK)                                                                                 //只有设备存在时，才会读取值和显示
     
106.             {                                                               
     
107.                 SHT20_test();               //采集传感器数据
     
108.                 //        Lcd1602_DisString(0xC0, "%0.1fC,%0.1f%%", sht20Info.tempreture, sht20Info.humidity);
     
109.                 //        OLED_DisString6x8(3, 56, "%0.1fC,%0.1f%%", sht20Info.tempreture, sht20Info.humidity);
     
110.             }
     
111. 
     
112.             /******************************************************************************
     
113.                                     错误处理
     
114.             ******************************************************************************/
     
115.             if(faultType != FAULT_NONE)                                                                                                //如果错误标志被设置
     
116.             {
     
117.                 printf("WARN:        Fault Processrn");
     
118.                 Fault_Process();                                                                                                        //进入错误处理函数
     
119.             }
     
120. 
     
121.             /******************************************************************************
     
122.                                     数据反馈
     
123.             ******************************************************************************/
     
124.             if(oneNetInfo.sendData)
     
125.             {
     
126.                 oneNetInfo.sendData = OneNet_SendData(HTTP_TYPE3, dataStreamLen);
     
127.             }
     
128.         }
     
129.         else
     
130.         {
     
131.             /******************************************************************************
     
132.                                     初始化网络设备、接入平台
     
133.             ******************************************************************************/
     
134.             if(!oneNetInfo.netWork && (checkInfo.NET_DEVICE_OK == DEV_OK))                        //当没有网络 且 网络模块检测到时
     
135.             {
     
136.                 NET_DEVICE_Set_DataMode(DEVICE_CMD_MODE);                                                        //设置为命令收发模式
     
137. 
     
138.                 if(!NET_DEVICE_Init())                                                                                                //初始化网络设备，能连入网络
     
139.                 {
     
140.                     printf( "Tips:        NetWork OKrn");
     
141. 
     
142.                     oneNetInfo.netWork = 1;
     
143. 
     
144.                     NET_DEVICE_Set_DataMode(DEVICE_DATA_MODE);                                                //网络设备指令模式
     
145. 
     
146.                     //  Beep_Set(BEEP_ON);
     
147.                     //  HAL_Delay(200);
     
148.                     //  Beep_Set(BEEP_OFF);
     
149. 
     
150.                     runTime = timInfo.timer6Out;
     
151.                 }
     
152.             }
     
153.             /******************************************************************************
     
154.                                     网络设备检测
     
155.             ******************************************************************************/
     
156.             if(checkInfo.NET_DEVICE_OK == DEV_ERR)                                                                         //当网络设备未做检测
     
157.             {
     
158.                 NET_DEVICE_Set_DataMode(DEVICE_CMD_MODE);                                                        //设置为命令收发模式
     
159. 
     
160.                 if(timerCount >= NET_TIME)                                                                                         //如果网络连接超时
     
161.                 {
     
162.                     printf( "Tips:                Timer Check Errrn");
     
163. 
     
164.                     NET_DEVICE_Reset();                                                                                                //复位网络设备
     
165.                     timerCount = 0;                                                                                                        //清零连接超时计数
     
166.                     faultType = FAULT_NONE;                                                                                        //清除错误标志
     
167.                 }
     
168. 
     
169.                 if(!NET_DEVICE_SendCmd("ATrn", "OK"))                                                                //网络设备检测
     
170.                 {
     
171. 
     
172.                     printf( "NET Device :Okrn");
     
173.                     checkInfo.NET_DEVICE_OK = DEV_OK;                                                                //检测到网络设备，标记
     
174.                     NET_DEVICE_Set_DataMode(DEVICE_DATA_MODE);                                                //设置为数据收发模式
     
175.                 }
     
176.                 else
     
177.                     printf( "NET Device :Errorrn");
     
178.             }
     
179.         }
     
180.     }
     
181.     /* USER CODE END 3 */
     
182. 
     
183. }

复制代码

至此，主要的程序编写与移植就差不多了，吸她的更多细节可以参看例程。

3.OneNet云端数据及应用

1、首先登陆中移动物联网网站，找到右上角开发者中心，注册登陆等省略。
之后选择公开协议创建产品，然后再添加设备：

之后就添加APIkey,这里略过，很简单，另外说下移动那个网页应用真是简单粗暴。

2、创建自己的应用

来摆摆玩吧，太简略了。

选择数据流，如果有数据上传成功，这里是会自己添加创建进来的，当然你也可以提前自己手动添加好，

创建完成后，我们就要准备运行下程序看看结果。当然少不了很多次的烧录修改了调试了，这里略过。

4、结果验证

1、这里贴上程序运行时候的log，比截图好看点：

1. Device SHT20 :Ok
   
2. Device ADXL345 :Ok
   
3. Device EEPROM :Ok
   
4. ADXL345 init ok !
   
5. KEY PRESSED!
   
6. interrupt over!
   
7. KEY PRESSED!
   
8. interrupt over!
   
9. xval2: -88.660004 yval2: -77.050003 zval2: -89.699997
   
10. xval2: 22.165001 yval2: 19.262501 zval2: 86.425003
    
11. ADXL345 self test ok !
    
12. Connect->> SSID: test24GHz,   PSWD: test0000
    
13. DEVID: ******,     APIKEY: ***********************
    
14. NET Device :Ok
    
15. STA Tips:        AT+CWMODE=1
    
16. STA Tips:        AT+CIPMODE=0
    
17. STA Tips:        AT+CWJAP="test24GHz","test0000"
    
18. STA Tips:        AT+CIPSTART="TCP","183.230.40.33",80
    
19. Tips:        ESP8266 STA OK
    
20. Tips:        NetWork OK
    
21. Tips:        OneNet_SendData-HTTP_TYPE3
    
22. "IPD" not found
    
23. Tips: Send OK
    
24. ESP8266 Connect OK
    
25. Tips:        OneNet_SendData-HTTP_TYPE3
    
26. Tips: Send OK
    
27. ESP8266 Connect OK
    
28. Tips:        OneNet_SendData-HTTP_TYPE3
    
29. Tips: Send OK
    
30. ESP8266 Connect OK
    
31. Tips:        OneNet_SendData-HTTP_TYPE3
    
32. Tips: Send OK
    
33. ESP8266 Connect OK
    
34. 
    

复制代码

主要调试就是需要出现如下信息才算上传成功数据：
Tips:        OneNet_SendData-HTTP_TYPE3
Tips: Send OK

2、wifi模块端数据收发情况：
AT串口TX：

1. AT
   
2. AT+CWMODE=1
   
3. AT+CIPMODE=0
   
4. AT+CWJAP="test24GHz","test0000"
   
5. AT+CWJAP="test24GHz","test0000"
   
6. AT+CWJAP="test24GHz","test0000"
   
7. AT+CIPSTART="TCP","183.230.40.33",80
   
8. AT+CIPSTART="TCP","183.230.40.33",80
   
9. AT+CIPSEND=278
   
10. POST /devices/******/datapoints?type=3 HTTP/1.1
    
11. api-key: ***********************
    
12. Host:api.heclouds.com
    
13. Content-Length:145
    
14. 
    
15. {"Red_Led":0,"Green_Led":0,"Yellow_Led":0,"Blue_Led":0,"beep":0,"temperature":28.60,"humidity":64.83,"Xg":-0.01,"Yg":-0.01,"Zg":1.14,"errType":0}
    
16. AT+CIPSTATUS
    
17. AT+CIPSEND=278
    
18. POST /devices/******/datapoints?type=3 HTTP/1.1
    
19. api-key: ***********************
    
20. Host:api.heclouds.com
    
21. Content-Length:145
    
22. 
    
23. {"Red_Led":0,"Green_Led":0,"Yellow_Led":0,"Blue_Led":0,"beep":0,"temperature":28.64,"humidity":64.85,"Xg":-0.00,"Yg":-0.01,"Zg":1.14,"errType":0}
    
24. AT+CIPSTATUS
    
25. AT+CIPSEND=278
    
26. POST /devices/******/datapoints?type=3 HTTP/1.1
    
27. api-key: ***********************
    
28. Host:api.heclouds.com
    
29. Content-Length:145
    

复制代码

AT串口RX：

1. AT
   
2. 
   
3. OK
   
4. AT+CWMODE=1
   
5. 
   
6. OK
   
7. AT+CIPMODE=0
   
8. 
   
9. OK
   
10. AT+CWJAP="*****","********"
    
11. WIFI DISCONNECT
    
12. AT+CWJAP="******","********"
    
13. busy p...
    
14. WIFI CONNECTED
    
15. WIFI GOT IP
    
16. AT+CIPSTART="TCP","183.230.40.33",80
    
17. busy p...
    
18. 
    
19. OK
    
20. AT+CIPSTART="TCP","183.230.40.33",80
    
21. CONNECT
    
22. 
    
23. OK
    
24. AT+CIPSEND=278
    
25. 
    
26. OK
    
27. >
    
28. Recv 278 bytes
    
29. 
    
30. SEND OK
    
31. 
    
32. +IPD,203:HTTP/1.1 200 OK
    
33. Date: Thu, 04 May 2017 07:23:36 GMT
    
34. Content-Type: application/json
    
35. Content-Length: 26
    
36. Connection: keep-alive
    
37. Server: Apache-Coyote/1.1
    
38. Pragma: no-cache
    
39. 
    
40. {"errno":0,"error":"succ"}
    
41. AT+CIPSTATUS
    
42. STATUS:3
    
43. +CIPSTATUS:0,"TCP","183.230.40.33",80,16784,0
    
44. 
    
45. OK
    
46. AT+CIPSEND=278
    
47. 
    
48. OK
    
49. >
    
50. Recv 278 bytes
    
51. 
    
52. SEND OK
    
53. 
    
54. +IPD,203:HTTP/1.1 200 OK
    
55. Date: Thu, 04 May 2017 07:24:16 GMT
    
56. Content-Type: application/json
    
57. Content-Length: 26
    
58. Connection: keep-alive
    
59. Server: Apache-Coyote/1.1
    
60. Pragma: no-cache
    
61. 
    
62. {"errno":0,"error":"succ"}

复制代码

一切看起来运行良好，网页端也能成功接收到数据

3、网页端应用显示结果：

数据上传显示OK.

程序备份：

test04-3.rar (708.57 KB, 下载次数: 3 )

下载看一下，谢谢楼主