STM32 + W5500 + Http client

    457 views
    0 comments
    0 likes
    ORIGINAL POST
    By Mr_Johhny
    details

    20200416163607511.png

    这两天在做STM32 W5500通过HTTP GET请求的方式下载bin文件，以实现OTA在线升级，到网上查了一圈，发现并没有很多有效的信息和资料。于是我就实现了一下，把思路和实现过程分享出来。

    实现W5500文件下载的几个前提：

    1、STM32 W5500的基础配置，使得 电脑端的CMD命令窗口能够PING通W5500，《STM32F103RC驱动W5500入网，并可ping通》。

    2、STM32 W5500的TCP Client收发数据测试没有问题，《STM32F1 W5500 TCP Client 回环测试》。

    3、一个可用的文件服务器，文件的URL地址放到浏览器的地址栏后，可以正常下载文件。

    4、对HTTP协议有基本的认识。

    文件的URL地址放到浏览器的地址栏后，通过Wireshark工具，先看看文件下载的过程，都发生可一些什么

    下载请求的header信息，包括以下几个关键信息：

    1、请求方式+接口名称+协议和协议版本(GET /file/FLASH_OPER.bin_1.1.3 HTTP/1.1rn)

    2、文件服务器主机IP+端口 (举例：192.168.1.105:8888rn)

    3、连接状态（Connection: Keep-Alivern）

    4、请求端名称（User-Agent: W5500rn）

    5、请求端接收的编码（Accept-Encoding: gzip,deflatern）

    6、请求头结束标记（rn）

    以上是请求的分析，文件服务器返回的信息如下：

    从文件服务器返回来的数据分析，报文和文件内容不是一次性传输的，是流的方式多次传输的。

    返回的报文，包含以下几个关键点：

    1、返回的状态码（HTTP/1.1 200rn）

    2、接收范围 字节流（Accept-Ranges: bytesrn）

    3、内容长度（Content-Length: 3904rn）

    4、头结束标记(rn)

    5、字节流Data长度和Content-Length是相等的。

    以上是基于浏览器下载文件的过程分析的，那么STM32 W5500下载文件的过程，模拟浏览器下载文件，从理论上来讲也是会实现的。

    HTTP协议是在TCP的基础上封装的协议，W5500的TCP Client端与服务端简历连接的过程在此不描述。

    STM32 W5500下载文件有几个难点：

    1、解析文件服务器返回的报文，判断返回码是否为200，只有200才代表成功；判断是否为字节流；解析出文件的大小（长度）

    2、文件字节流和返回报文的分割，以及缓存数组的数据反复搬运（毕竟W5500 一次最多可以收2Kbytes 的数据）。

    3、判断文件下载是否完成的依据。

    STM32 W5500请求和接收的过程：

    即发送一次请求报文后，不断接收文件服务器返回的信息，结果是要么接收到文件字节流和 Content-Length的相等，文件下载成功，要么各种原因失败（连接超时，读取超时，返回码不正确，不是字节流等）。

    好像该讲的都讲了，下面给出STM32 W5500 Http GET方式下载文件的代码（我测试下载 4k/13k/67k 左右的文件都可以），例程中打印了 各个分支的log信息，将文件下载的内容通过串口DMA的方式打印出来。（工程可以看我的 基础配置文章下载，再将这个主测试函数替换）

    1. #ifndef __STM32F10X_H
    2. #define __STM32F10X_H
    3. #include “stm32f10x.h”
    4. #endif
    6. #ifndef __Z_UTIL_TIME_H
    7. #define __Z_UTIL_TIME_H
    8. #include “z_util_time.h”
    9. #endif
    11. #ifndef __Z_HARDWARE_LED_H
    12. #define __Z_HARDWARE_LED_H
    13. #include “z_hardware_led.h”
    14. #endif
    16. #ifndef __Z_HARDWARE_SPI_H
    17. #define __Z_HARDWARE_SPI_H
    18. #include “z_hardware_spi.h”
    19. #endif
    21. #ifndef __W5500_H
    22. #define __W5500_H
    23. #include “w5500.h”
    24. #endif
    26. #ifndef __SOCKET_H
    27. #define __SOCKET_H
    28. #include “socket.h”
    29. #endif
    31. #ifndef __W5500_CONF_H
    32. #define __W5500_CONF_H
    33. #include “w5500_conf.h”
    34. #endif
    36. #ifndef __DHCP_H
    37. #define __DHCP_H
    38. #include “dhcp.h”
    39. #endif
    41. #ifndef __Z_HARDWARE_USART2_H
    42. #define __Z_HARDWARE_USART2_H
    43. #include “z_hardware_usart2.h”
    44. #endif
    46. #include <stdlib.h>
    48. void log_net(char *log);
    50. void func_pack_http_get_download_header(u8* buff, u16 size_buff, u8* srv_ip, u16 srv_port, char* interface);
    51. u8 func_http_get_download_file(u8 sockno, u8* srv_ip, u16 srv_port, char* interface, u16 timeout_ms, u8* buff, u16 size_buff);
    52. u8 func_analysis_http_download_header(u8* buffer, u16 len_buf, u8 *resp_code, u8 *is_stream, u32 *cont_len);
    54. u8 buf[2048];
    55. int main(void)
    56. {
    58. u8 mac[6]={0, };
    59. DHCP_Get dhcp_get;
    61. //FIXME input your server ip to download file
    62. u8 srv_ip[] = {192, 168, 1, 105};
    63. u16 srv_port = 8888;
    66. systick_configuration();
    67. init_led();
    68. init_hardware_usart2_dma(115200);
    70. init_system_spi();
    71. func_w5500_reset();
    73. getMacByLockCode(mac);
    74. setSHAR(mac);
    76. sysinit(txsize, rxsize);
    77. setRTR(2000);
    78. setRCR(3);
    80. //USART DMA problem: 2 bytes missing
    81. func_usart2_dma_send_bytes(mac, 2);
    82. delay_ms(100);
    84. //DHCP
    85. for(;func_dhcp_get_ip_sub_gw(1, mac, &dhcp_get, 500) != 0;);
    86. if(func_dhcp_get_ip_sub_gw(1, mac, &dhcp_get, 500) == 0)
    87. {
    88. setSUBR(dhcp_get.sub);
    89. setGAR(dhcp_get.gw);
    90. setSIPR(dhcp_get.lip);
    91. close(1);
    93. log_net(“0”);
    94. }
    96. memset(buf, 0 , sizeof(buf));
    97. func_http_get_download_file(0, srv_ip, srv_port, “/file/FLASH_OPER.bin_1.1.3”, 5000, buf, sizeof(buf));
    99. for(;;)
    100. {
    101. func_led1_toggle();
    102. delay_ms(500);
    103. }
    104. }
    106. u8 func_http_get_download_file(u8 sockno, u8* srv_ip, u16 srv_port, char* interface, u16 timeout_ms, u8* buff, u16 size_buff)
    107. {
    108. u16 local_port = 60000, len = 0, cnt = 0;
    109. u8 sendok = 0, recv_start = 0;
    111. u8 cache[2048];
    112. u16 cache_cont_len;
    113. u32 cont_len, download_cont_len;
    115. func_pack_http_get_download_header(buff, size_buff, srv_ip, srv_port, interface);
    117. // setkeepalive(sockno);//auto
    118. IINCHIP_WRITE(Sn_KPALVTR(sockno),0x00);//manual
    120. memset(cache, 0 , sizeof(cache));
    121. cache_cont_len = 0;
    123. for(;;)
    124. {
    125. switch(getSn_SR(sockno))
    126. {
    127. case SOCK_INIT:
    128. connect(sockno, srv_ip, srv_port);
    129. break;
    130. case SOCK_ESTABLISHED:
    131. {
    132. if(sendok == 0)
    133. {
    134. log_net(“1”);
    136. len = strlen((char *)buff);
    137. send(sockno, buff, len);
    138. sendok ++;
    139. if(getSn_IR(sockno) & Sn_IR_CON)
    140. {
    141. setSn_IR(sockno, Sn_IR_CON);
    142. break;
    143. }
    144. }
    146. len = getSn_RX_RSR(sockno);
    147. if(len > 0)
    148. {
    149. cnt = 0;
    151. memset(buff, 0, size_buff);
    152. len = recv(sockno, buff, len);
    153. if(recv_start == 0)
    154. {
    155. u8 res, resp_code, isstream;
    157. log_net(“2”);
    159. if(cache_cont_len + len <= sizeof(cache))
    160. {
    161. log_net(“3”);
    162. memcpy(cache+cache_cont_len, buff, len);
    163. cache_cont_len += len;
    165. memset(buff, 0, size_buff);
    166. len = 0;
    167. }
    168. else
    169. {
    170. u32 len_copy;
    171. log_net(“4”);
    173. len_copy = sizeof(cache) – cache_cont_len;
    174. memcpy(cache+cache_cont_len, buff, len_copy);
    175. memcpy(buff, buff + len_copy, len – len_copy);
    176. memset(buff + (len – len_copy), 0, size_buff – (len – len_copy));
    177. len = len – len_copy;
    178. cache_cont_len = sizeof(cache);
    180. }
    182. res = func_analysis_http_download_header(cache, cache_cont_len, &resp_code, &isstream, &cont_len);
    183. if(res == 0)
    184. {
    185. if(resp_code != 200 || isstream != 1)//response code 200, must be iostream
    186. {
    187. log_net(“22”);
    188. return 3;// response not ok
    189. }
    190. recv_start++;
    192. //logic -> file size should be no more than 108 Kbytes
    193. if(cont_len > 108*1024)
    194. {
    195. log_net(“23”);
    196. return 4;
    197. }
    199. //if download file done
    200. {
    201. u32 tmp_len;
    202. u8* pos_header;
    203. pos_header = (u8*)strstr((char*)cache, “rnrn”);
    204. //remove header, save file byte to cache
    205. tmp_len = cache_cont_len – (pos_header + 4 – cache);
    206. memcpy(cache, pos_header + 4, tmp_len);
    207. memset(cache + tmp_len, 0 , sizeof(cache) – tmp_len);
    208. cache_cont_len = tmp_len;
    209. download_cont_len = cache_cont_len;
    211. if(len > 0)
    212. {
    213. if(cache_cont_len + len <= sizeof(cache))
    214. {
    215. log_net(“5”);
    216. memcpy(cache+cache_cont_len, buff, len);
    217. cache_cont_len += len;
    218. download_cont_len += len;
    220. memset(buff, 0, size_buff);
    221. len = 0;
    222. }
    223. else
    224. {
    225. u32 len_copy;
    226. log_net(“6”);
    228. len_copy = sizeof(cache) – cache_cont_len;
    229. memcpy(cache+cache_cont_len, buff, len_copy);
    230. memcpy(buff, buff + len_copy, len – len_copy);
    231. memset(buff + (len – len_copy), 0, size_buff – (len – len_copy));
    232. len = len – len_copy;
    233. cache_cont_len = sizeof(cache);
    235. //TODO write to FLASH backup
    236. func_usart2_dma_send_bytes(cache, cache_cont_len);
    237. memset(cache, 0, cache_cont_len);
    238. cache_cont_len = 0;
    239. memcpy(cache+cache_cont_len, buff, len);
    240. cache_cont_len = len;
    241. download_cont_len = sizeof(cache) + cache_cont_len;
    243. }
    244. }
    246. if(download_cont_len == cont_len)// small file download done
    247. {
    248. log_net(“7”);
    249. func_usart2_dma_send_bytes(cache, cache_cont_len);
    250. //TODO write to FLASH backup and record
    252. disconnect(sockno);
    253. return 0;//download file done
    254. }
    256. }
    257. }
    258. }
    259. else
    260. {
    261. IINCHIP_WRITE(Sn_CR(sockno),Sn_CR_SEND_KEEP);//keep-alive manual
    263. //file size is big, write to FALSH several times
    264. download_cont_len += len;
    265. if(cache_cont_len + len <= sizeof(cache))
    266. {
    267. log_net(“8”);
    268. memcpy(cache+cache_cont_len, buff, len);
    269. cache_cont_len += len;
    270. memset(buff, 0, size_buff);
    271. len = 0;
    272. }
    273. else
    274. {
    275. u32 len_copy;
    276. log_net(“9”);
    277. len_copy = sizeof(cache) – cache_cont_len;
    278. memcpy(cache+cache_cont_len, buff, len_copy);
    279. memcpy(buff, buff + len_copy, len – len_copy);
    280. memset(buff + (len – len_copy), 0, size_buff – (len – len_copy));
    281. len = len – len_copy;
    282. cache_cont_len = sizeof(cache);
    284. //TODO write to FLASH backup
    285. func_usart2_dma_send_bytes(cache, cache_cont_len);
    286. memset(cache, 0, cache_cont_len);
    287. cache_cont_len = 0;
    288. memcpy(cache+cache_cont_len, buff, len);
    289. cache_cont_len = len;
    290. }
    292. //if donwload file done
    293. if(download_cont_len == cont_len)
    294. {
    295. log_net(“10”);
    296. //TODO write to FLASH backup and record
    297. func_usart2_dma_send_bytes(cache, cache_cont_len);
    298. disconnect(sockno);
    299. return 0;//download file done
    300. }
    301. }
    302. }
    303. }
    304. break;
    305. case SOCK_CLOSE_WAIT:
    306. close(sockno);
    307. log_net(“21”);
    308. return 2;//read timeout
    309. case SOCK_CLOSED:
    310. close(sockno);
    311. sendok = 0;
    312. recv_start = 0;
    313. if(local_port > 65400)
    314. {
    315. local_port = 60000;
    316. }
    317. socket(sockno, Sn_MR_TCP, local_port++, Sn_MR_ND);
    318. break;
    319. }
    321. cnt ++;
    322. if(cnt >= timeout_ms)
    323. {
    324. log_net(“20”);
    325. return 1;//connect timeout
    326. }
    327. delay_ms(1);
    328. }
    329. }
    331. u8 func_analysis_http_download_header(u8* buffer, u16 len_buf, u8 *resp_code, u8 *is_stream, u32 *cont_len)
    332. {
    333. *resp_code = 0;
    334. *is_stream = 0;
    335. *cont_len = 0;
    336. if(strstr((char*)buffer, “rnrn”) != NULL)//response header ok
    337. {
    338. char *p1, *p2;
    340. p1 = strstr((char*)buffer, “HTTP/1.1 200”);
    341. if(p1 != NULL)// io stream
    342. {
    343. *resp_code = 200;
    344. }
    346. p1 = strstr((char*)buffer, “Accept-Ranges: bytes”);
    347. if(p1 != NULL)// io stream
    348. {
    349. *is_stream = 1;
    350. }
    352. p1 = strstr((char*)buffer, “Content-Length: “);
    353. if(p1 != NULL)
    354. {
    355. p2 = strstr(p1, “rn”);
    356. if(p2 != NULL)
    357. {
    358. char str_len[8] = {0,};
    359. memcpy(str_len, p1 + strlen(“Content-Length: “), p2 – p1 – strlen(“Content-Length: “));
    360. *cont_len = atoi(str_len);
    361. return 0;
    362. }
    363. }
    364. }
    365. return 1;
    366. }
    368. void log_net(char *log)
    369. {
    370. u8 logsrv_ip[] = {192, 168, 1, 105};
    371. socket(2, Sn_MR_UDP, 7890, 0x00);
    372. sendto(2, (u8*)log, strlen(log), logsrv_ip, 9876);
    373. }
    375. void func_pack_http_get_download_header(u8* buff, u16 size_buff, u8* srv_ip, u16 srv_port, char* interface)
    376. {
    377. u8 tmp[64];
    378. memset(buff, 0, size_buff);
    379. //header
    380. memcpy(buff, “GET “, strlen(“GET “));
    381. strcat((char *)buff, interface);
    382. strcat((char *)buff, ” HTTP/1.1rn”);
    383. memset(tmp, 0 , sizeof(tmp));
    384. sprintf((char*)tmp, “Host: %d.%d.%d.%d:%drn”, srv_ip[0], srv_ip[1], srv_ip[2], srv_ip[3], srv_port);
    385. strcat((char *)buff, (char*)tmp);
    386. strcat((char *)buff, “Connection: Keep-Alivern”);
    387. strcat((char *)buff, “User-Agent: W5500rn”);
    388. strcat((char *)buff, “Accept-Encoding: gzip,deflatern”);
    389. strcat((char *)buff, “rn”);
    390. }

    最后，附上我测试的效果图：

    串口打印的字节数和 Content-Length的长度一致，并和原bin文件做了对比，内容一致。

    20200416163607511.png

    这两天在做STM32 W5500通过HTTP GET请求的方式下载bin文件，以实现OTA在线升级，到网上查了一圈，发现并没有很多有效的信息和资料。于是我就实现了一下，把思路和实现过程分享出来。

    实现W5500文件下载的几个前提：

    1、STM32 W5500的基础配置，使得 电脑端的CMD命令窗口能够PING通W5500，《STM32F103RC驱动W5500入网，并可ping通》。

    2、STM32 W5500的TCP Client收发数据测试没有问题，《STM32F1 W5500 TCP Client 回环测试》。

    3、一个可用的文件服务器，文件的URL地址放到浏览器的地址栏后，可以正常下载文件。

    4、对HTTP协议有基本的认识。

    文件的URL地址放到浏览器的地址栏后，通过Wireshark工具，先看看文件下载的过程，都发生可一些什么

    下载请求的header信息，包括以下几个关键信息：

    1、请求方式+接口名称+协议和协议版本(GET /file/FLASH_OPER.bin_1.1.3 HTTP/1.1rn)

    2、文件服务器主机IP+端口 (举例：192.168.1.105:8888rn)

    3、连接状态（Connection: Keep-Alivern）

    4、请求端名称（User-Agent: W5500rn）

    5、请求端接收的编码（Accept-Encoding: gzip,deflatern）

    6、请求头结束标记（rn）

    以上是请求的分析，文件服务器返回的信息如下：

    从文件服务器返回来的数据分析，报文和文件内容不是一次性传输的，是流的方式多次传输的。

    返回的报文，包含以下几个关键点：

    1、返回的状态码（HTTP/1.1 200rn）

    2、接收范围 字节流（Accept-Ranges: bytesrn）

    3、内容长度（Content-Length: 3904rn）

    4、头结束标记(rn)

    5、字节流Data长度和Content-Length是相等的。

    以上是基于浏览器下载文件的过程分析的，那么STM32 W5500下载文件的过程，模拟浏览器下载文件，从理论上来讲也是会实现的。

    HTTP协议是在TCP的基础上封装的协议，W5500的TCP Client端与服务端简历连接的过程在此不描述。

    STM32 W5500下载文件有几个难点：

    1、解析文件服务器返回的报文，判断返回码是否为200，只有200才代表成功；判断是否为字节流；解析出文件的大小（长度）

    2、文件字节流和返回报文的分割，以及缓存数组的数据反复搬运（毕竟W5500 一次最多可以收2Kbytes 的数据）。

    3、判断文件下载是否完成的依据。

    STM32 W5500请求和接收的过程：

    即发送一次请求报文后，不断接收文件服务器返回的信息，结果是要么接收到文件字节流和 Content-Length的相等，文件下载成功，要么各种原因失败（连接超时，读取超时，返回码不正确，不是字节流等）。

    好像该讲的都讲了，下面给出STM32 W5500 Http GET方式下载文件的代码（我测试下载 4k/13k/67k 左右的文件都可以），例程中打印了 各个分支的log信息，将文件下载的内容通过串口DMA的方式打印出来。（工程可以看我的 基础配置文章下载，再将这个主测试函数替换）

    1. #ifndef __STM32F10X_H
    2. #define __STM32F10X_H
    3. #include “stm32f10x.h”
    4. #endif
    6. #ifndef __Z_UTIL_TIME_H
    7. #define __Z_UTIL_TIME_H
    8. #include “z_util_time.h”
    9. #endif
    11. #ifndef __Z_HARDWARE_LED_H
    12. #define __Z_HARDWARE_LED_H
    13. #include “z_hardware_led.h”
    14. #endif
    16. #ifndef __Z_HARDWARE_SPI_H
    17. #define __Z_HARDWARE_SPI_H
    18. #include “z_hardware_spi.h”
    19. #endif
    21. #ifndef __W5500_H
    22. #define __W5500_H
    23. #include “w5500.h”
    24. #endif
    26. #ifndef __SOCKET_H
    27. #define __SOCKET_H
    28. #include “socket.h”
    29. #endif
    31. #ifndef __W5500_CONF_H
    32. #define __W5500_CONF_H
    33. #include “w5500_conf.h”
    34. #endif
    36. #ifndef __DHCP_H
    37. #define __DHCP_H
    38. #include “dhcp.h”
    39. #endif
    41. #ifndef __Z_HARDWARE_USART2_H
    42. #define __Z_HARDWARE_USART2_H
    43. #include “z_hardware_usart2.h”
    44. #endif
    46. #include <stdlib.h>
    48. void log_net(char *log);
    50. void func_pack_http_get_download_header(u8* buff, u16 size_buff, u8* srv_ip, u16 srv_port, char* interface);
    51. u8 func_http_get_download_file(u8 sockno, u8* srv_ip, u16 srv_port, char* interface, u16 timeout_ms, u8* buff, u16 size_buff);
    52. u8 func_analysis_http_download_header(u8* buffer, u16 len_buf, u8 *resp_code, u8 *is_stream, u32 *cont_len);
    54. u8 buf[2048];
    55. int main(void)
    56. {
    58. u8 mac[6]={0, };
    59. DHCP_Get dhcp_get;
    61. //FIXME input your server ip to download file
    62. u8 srv_ip[] = {192, 168, 1, 105};
    63. u16 srv_port = 8888;
    66. systick_configuration();
    67. init_led();
    68. init_hardware_usart2_dma(115200);
    70. init_system_spi();
    71. func_w5500_reset();
    73. getMacByLockCode(mac);
    74. setSHAR(mac);
    76. sysinit(txsize, rxsize);
    77. setRTR(2000);
    78. setRCR(3);
    80. //USART DMA problem: 2 bytes missing
    81. func_usart2_dma_send_bytes(mac, 2);
    82. delay_ms(100);
    84. //DHCP
    85. for(;func_dhcp_get_ip_sub_gw(1, mac, &dhcp_get, 500) != 0;);
    86. if(func_dhcp_get_ip_sub_gw(1, mac, &dhcp_get, 500) == 0)
    87. {
    88. setSUBR(dhcp_get.sub);
    89. setGAR(dhcp_get.gw);
    90. setSIPR(dhcp_get.lip);
    91. close(1);
    93. log_net(“0”);
    94. }
    96. memset(buf, 0 , sizeof(buf));
    97. func_http_get_download_file(0, srv_ip, srv_port, “/file/FLASH_OPER.bin_1.1.3”, 5000, buf, sizeof(buf));
    99. for(;;)
    100. {
    101. func_led1_toggle();
    102. delay_ms(500);
    103. }
    104. }
    106. u8 func_http_get_download_file(u8 sockno, u8* srv_ip, u16 srv_port, char* interface, u16 timeout_ms, u8* buff, u16 size_buff)
    107. {
    108. u16 local_port = 60000, len = 0, cnt = 0;
    109. u8 sendok = 0, recv_start = 0;
    111. u8 cache[2048];
    112. u16 cache_cont_len;
    113. u32 cont_len, download_cont_len;
    115. func_pack_http_get_download_header(buff, size_buff, srv_ip, srv_port, interface);
    117. // setkeepalive(sockno);//auto
    118. IINCHIP_WRITE(Sn_KPALVTR(sockno),0x00);//manual
    120. memset(cache, 0 , sizeof(cache));
    121. cache_cont_len = 0;
    123. for(;;)
    124. {
    125. switch(getSn_SR(sockno))
    126. {
    127. case SOCK_INIT:
    128. connect(sockno, srv_ip, srv_port);
    129. break;
    130. case SOCK_ESTABLISHED:
    131. {
    132. if(sendok == 0)
    133. {
    134. log_net(“1”);
    136. len = strlen((char *)buff);
    137. send(sockno, buff, len);
    138. sendok ++;
    139. if(getSn_IR(sockno) & Sn_IR_CON)
    140. {
    141. setSn_IR(sockno, Sn_IR_CON);
    142. break;
    143. }
    144. }
    146. len = getSn_RX_RSR(sockno);
    147. if(len > 0)
    148. {
    149. cnt = 0;
    151. memset(buff, 0, size_buff);
    152. len = recv(sockno, buff, len);
    153. if(recv_start == 0)
    154. {
    155. u8 res, resp_code, isstream;
    157. log_net(“2”);
    159. if(cache_cont_len + len <= sizeof(cache))
    160. {
    161. log_net(“3”);
    162. memcpy(cache+cache_cont_len, buff, len);
    163. cache_cont_len += len;
    165. memset(buff, 0, size_buff);
    166. len = 0;
    167. }
    168. else
    169. {
    170. u32 len_copy;
    171. log_net(“4”);
    173. len_copy = sizeof(cache) – cache_cont_len;
    174. memcpy(cache+cache_cont_len, buff, len_copy);
    175. memcpy(buff, buff + len_copy, len – len_copy);
    176. memset(buff + (len – len_copy), 0, size_buff – (len – len_copy));
    177. len = len – len_copy;
    178. cache_cont_len = sizeof(cache);
    180. }
    182. res = func_analysis_http_download_header(cache, cache_cont_len, &resp_code, &isstream, &cont_len);
    183. if(res == 0)
    184. {
    185. if(resp_code != 200 || isstream != 1)//response code 200, must be iostream
    186. {
    187. log_net(“22”);
    188. return 3;// response not ok
    189. }
    190. recv_start++;
    192. //logic -> file size should be no more than 108 Kbytes
    193. if(cont_len > 108*1024)
    194. {
    195. log_net(“23”);
    196. return 4;
    197. }
    199. //if download file done
    200. {
    201. u32 tmp_len;
    202. u8* pos_header;
    203. pos_header = (u8*)strstr((char*)cache, “rnrn”);
    204. //remove header, save file byte to cache
    205. tmp_len = cache_cont_len – (pos_header + 4 – cache);
    206. memcpy(cache, pos_header + 4, tmp_len);
    207. memset(cache + tmp_len, 0 , sizeof(cache) – tmp_len);
    208. cache_cont_len = tmp_len;
    209. download_cont_len = cache_cont_len;
    211. if(len > 0)
    212. {
    213. if(cache_cont_len + len <= sizeof(cache))
    214. {
    215. log_net(“5”);
    216. memcpy(cache+cache_cont_len, buff, len);
    217. cache_cont_len += len;
    218. download_cont_len += len;
    220. memset(buff, 0, size_buff);
    221. len = 0;
    222. }
    223. else
    224. {
    225. u32 len_copy;
    226. log_net(“6”);
    228. len_copy = sizeof(cache) – cache_cont_len;
    229. memcpy(cache+cache_cont_len, buff, len_copy);
    230. memcpy(buff, buff + len_copy, len – len_copy);
    231. memset(buff + (len – len_copy), 0, size_buff – (len – len_copy));
    232. len = len – len_copy;
    233. cache_cont_len = sizeof(cache);
    235. //TODO write to FLASH backup
    236. func_usart2_dma_send_bytes(cache, cache_cont_len);
    237. memset(cache, 0, cache_cont_len);
    238. cache_cont_len = 0;
    239. memcpy(cache+cache_cont_len, buff, len);
    240. cache_cont_len = len;
    241. download_cont_len = sizeof(cache) + cache_cont_len;
    243. }
    244. }
    246. if(download_cont_len == cont_len)// small file download done
    247. {
    248. log_net(“7”);
    249. func_usart2_dma_send_bytes(cache, cache_cont_len);
    250. //TODO write to FLASH backup and record
    252. disconnect(sockno);
    253. return 0;//download file done
    254. }
    256. }
    257. }
    258. }
    259. else
    260. {
    261. IINCHIP_WRITE(Sn_CR(sockno),Sn_CR_SEND_KEEP);//keep-alive manual
    263. //file size is big, write to FALSH several times
    264. download_cont_len += len;
    265. if(cache_cont_len + len <= sizeof(cache))
    266. {
    267. log_net(“8”);
    268. memcpy(cache+cache_cont_len, buff, len);
    269. cache_cont_len += len;
    270. memset(buff, 0, size_buff);
    271. len = 0;
    272. }
    273. else
    274. {
    275. u32 len_copy;
    276. log_net(“9”);
    277. len_copy = sizeof(cache) – cache_cont_len;
    278. memcpy(cache+cache_cont_len, buff, len_copy);
    279. memcpy(buff, buff + len_copy, len – len_copy);
    280. memset(buff + (len – len_copy), 0, size_buff – (len – len_copy));
    281. len = len – len_copy;
    282. cache_cont_len = sizeof(cache);
    284. //TODO write to FLASH backup
    285. func_usart2_dma_send_bytes(cache, cache_cont_len);
    286. memset(cache, 0, cache_cont_len);
    287. cache_cont_len = 0;
    288. memcpy(cache+cache_cont_len, buff, len);
    289. cache_cont_len = len;
    290. }
    292. //if donwload file done
    293. if(download_cont_len == cont_len)
    294. {
    295. log_net(“10”);
    296. //TODO write to FLASH backup and record
    297. func_usart2_dma_send_bytes(cache, cache_cont_len);
    298. disconnect(sockno);
    299. return 0;//download file done
    300. }
    301. }
    302. }
    303. }
    304. break;
    305. case SOCK_CLOSE_WAIT:
    306. close(sockno);
    307. log_net(“21”);
    308. return 2;//read timeout
    309. case SOCK_CLOSED:
    310. close(sockno);
    311. sendok = 0;
    312. recv_start = 0;
    313. if(local_port > 65400)
    314. {
    315. local_port = 60000;
    316. }
    317. socket(sockno, Sn_MR_TCP, local_port++, Sn_MR_ND);
    318. break;
    319. }
    321. cnt ++;
    322. if(cnt >= timeout_ms)
    323. {
    324. log_net(“20”);
    325. return 1;//connect timeout
    326. }
    327. delay_ms(1);
    328. }
    329. }
    331. u8 func_analysis_http_download_header(u8* buffer, u16 len_buf, u8 *resp_code, u8 *is_stream, u32 *cont_len)
    332. {
    333. *resp_code = 0;
    334. *is_stream = 0;
    335. *cont_len = 0;
    336. if(strstr((char*)buffer, “rnrn”) != NULL)//response header ok
    337. {
    338. char *p1, *p2;
    340. p1 = strstr((char*)buffer, “HTTP/1.1 200”);
    341. if(p1 != NULL)// io stream
    342. {
    343. *resp_code = 200;
    344. }
    346. p1 = strstr((char*)buffer, “Accept-Ranges: bytes”);
    347. if(p1 != NULL)// io stream
    348. {
    349. *is_stream = 1;
    350. }
    352. p1 = strstr((char*)buffer, “Content-Length: “);
    353. if(p1 != NULL)
    354. {
    355. p2 = strstr(p1, “rn”);
    356. if(p2 != NULL)
    357. {
    358. char str_len[8] = {0,};
    359. memcpy(str_len, p1 + strlen(“Content-Length: “), p2 – p1 – strlen(“Content-Length: “));
    360. *cont_len = atoi(str_len);
    361. return 0;
    362. }
    363. }
    364. }
    365. return 1;
    366. }
    368. void log_net(char *log)
    369. {
    370. u8 logsrv_ip[] = {192, 168, 1, 105};
    371. socket(2, Sn_MR_UDP, 7890, 0x00);
    372. sendto(2, (u8*)log, strlen(log), logsrv_ip, 9876);
    373. }
    375. void func_pack_http_get_download_header(u8* buff, u16 size_buff, u8* srv_ip, u16 srv_port, char* interface)
    376. {
    377. u8 tmp[64];
    378. memset(buff, 0, size_buff);
    379. //header
    380. memcpy(buff, “GET “, strlen(“GET “));
    381. strcat((char *)buff, interface);
    382. strcat((char *)buff, ” HTTP/1.1rn”);
    383. memset(tmp, 0 , sizeof(tmp));
    384. sprintf((char*)tmp, “Host: %d.%d.%d.%d:%drn”, srv_ip[0], srv_ip[1], srv_ip[2], srv_ip[3], srv_port);
    385. strcat((char *)buff, (char*)tmp);
    386. strcat((char *)buff, “Connection: Keep-Alivern”);
    387. strcat((char *)buff, “User-Agent: W5500rn”);
    388. strcat((char *)buff, “Accept-Encoding: gzip,deflatern”);
    389. strcat((char *)buff, “rn”);
    390. }

    最后，附上我测试的效果图：

    串口打印的字节数和 Content-Length的长度一致，并和原bin文件做了对比，内容一致。

    COMMENTS

    Please Login to comment
      Subscribe  
    Notify of
    POSTED BY
    tonywang_