简单测试BSP Socket HTTP Post百度服务器，测试相关时间

eric2013

1. /*
   
2. *********************************************************************************************************
   
3. *
   
4. *        模块名称 : TCPnet网络协议栈测试
   
5. *        文件名称 : app_tcpnet_lib.c
   
6. *        版    本 : V1.0
   
7. *        说    明 : 测试的功能说明
   
8. *              1. 强烈推荐将网线接到路由器或者交换机上面测试，因为已经使能了DHCP，可以自动获取IP地址。
   
9. *              2. 客户端的例子相比服务器的例子稍麻烦些，因为客户端的例子需要用户知道电脑端IP和端口号。
   
10. *                 并根据实际情况设置IP和端口号的宏定义，这个配置在文件app_tcpnet_lib.c开头，测试的时
    
11. *                 候板子要连接这个IP和端口（下面是默认配置，一定要根据实际情况重新配置，如果不会配置，
    
12. *                 看本例程对应的教程即可）：
    
13. *                 #define IP1            192
    
14. *                 #define IP2            168
    
15. *                 #define IP3            1
    
16. *                 #define IP4            2                 
    
17. *                 #define PORT_NUM       1001
    
18. *              3. 创建了一个TCP Client，而且使能了局域网域名NetBIOS，用户只需在电脑端ping armfly
    
19. *                 就可以获得板子的IP地址，本地端口被设置为1024。
    
20. *              4. 用户可以在电脑端用网络调试软件创建TCP Server连接此客户端。
    
21. *              5. 按键K1按下，发送8字节的数据给TCP Server。
    
22. *              6. 按键K2按下，发送1024字节的数据给TCP Server。
    
23. *              7. 按键K3按下，发送5MB字节的数据给TCP Server。
    
24. *              8、摇杆OK键按下，连接远程服务器。
    
25. *
    
26. *        修改记录 :
    
27. *                版本号   日期         作者        说明
    
28. *                V1.0    2020-01-09   Eric2013     首发
    
29. *
    
30. *        Copyright (C), 2019-2030, 安富莱电子 www.armfly.com
    
31. *
    
32. *********************************************************************************************************
    
33. */        
    
34. #include "includes.h"        
    
35. 
    
36. 
    
37. 
    
38. /*
    
39. *********************************************************************************************************
    
40. *                                          用于本文件的调试
    
41. *********************************************************************************************************
    
42. */
    
43. #if 1
    
44.         #define printf_debug printf
    
45. #else
    
46.         #define printf_debug(...)
    
47. #endif
    
48. 
    
49. 
    
50. /*
    
51. *********************************************************************************************************
    
52. *                                  宏定义，远程服务器的IP和端口
    
53. *********************************************************************************************************
    
54. */
    
55. /* 要访问的远程服务器IP和端口配置，也就是电脑端调试助手设置的IP和端口号 */
    
56. 
    
57. 
    
58. #define IP1            220
    
59. #define IP2            181
    
60. #define IP3            38
    
61. #define IP4            149
    
62. 
    
63. #define PORT_NUM         80
    
64. 
    
65. /* 这个是本地端口 */
    
66. #define LocalPort_NUM    1024
    
67. 
    
68. /*
    
69. *********************************************************************************************************
    
70. *                                             变量
    
71. *********************************************************************************************************
    
72. */
    
73. NET_ADDR4 addr = { NET_ADDR_IP4, PORT_NUM, IP1,IP2,IP3,IP4};
    
74. 
    
75. 
    
76. uint8_t sendbuf[1024];
    
77. 
    
78. 
    
79. /*
    
80. *********************************************************************************************************
    
81. *        函 数 名: TCPnetTest
    
82. *        功能说明: TCPnet应用
    
83. *        形    参: 无
    
84. *        返 回 值: 无
    
85. *********************************************************************************************************
    
86. */
    
87. #include "rl_net_lib.h"
    
88. void TCPnetTest_socket(void)
    
89. {  
    
90.         static char dbuf[1024]={0};
    
91.         static char http_data[1024]={0};
    
92.         static char cmdjson[1024]="{ "cmd":5,  "sn":1,"companyID":"mmmm" ,"deviceID":"kkk"}";
    
93.         
    
94.         int cnt=0;
    
95.         int len;
    
96.         int sock, res;
    
97.         unsigned long sck_mode = 0;
    
98.         SOCKADDR_IN addr;
    
99.     int i=0;
    
100.     HOSTENT *host;
     
101.     IN_ADDR *addr1;
     
102.     int err;
     
103.         
     
104.         int errcnt=0;
     
105.         
     
106. //        sprintf(http_data,"POST /api/v3/mcu HTTP/1.1\r\n");
     
107. //  sprintf(http_data,"GET /index.html HTTP/1.1\r\n");
     
108.     sprintf(http_data,"POST /index.html HTTP/1.1\r\n");
     
109. //        
     
110. //        sprintf(dbuf, "Content-Length: %d\r\n",strlen( cmdjson) );
     
111. //        strcat(http_data,dbuf  );
     
112. //        
     
113. //        strcat(http_data,"User_Agent: Mozilla/4.0\r\n"  );
     
114. //        strcat(http_data,"Connection: close\r\n"  );
     
115. //        strcat(http_data,"Content-Type: application/json\r\n"  );
     
116. //        
     
117.         strcat(http_data,"\r\n" );
     
118.         
     
119. //        strcat(http_data,cmdjson );
     
120. 
     
121.         uint32_t tick1;
     
122.         uint32_t tick2;
     
123.         
     
124.         while (1)
     
125.         {
     
126.                                 tick1 = osKernelGetTickCount();
     
127.                
     
128.                                 /* 创建一个socket
     
129.                                          第1个参数AF_INET：当前仅支持这个类型的地址族。
     
130.                                          第2个参数SOCK_STREAM：表示数据流通信类型，即使用的TCP。
     
131.                                          第3个参数0 ：配置为0的话，自动跟第2个参数进行协议匹配，这里就是TCP协议。
     
132.                                 */
     
133.                                 sock = socket (AF_INET, SOCK_STREAM, 0);
     
134.                                 if (sock <= 0) //出错了
     
135.                                 {
     
136.                                                 printf_debug("socket 出错 res = %d. \r\n", res );
     
137.                                                 //osDelay(6000);
     
138.                                                 continue;
     
139.                                 }
     
140.                                 
     
141.                                 /* 端口号设置为1001 */
     
142.                                 addr.sin_port = htons(PORT_NUM);
     
143.                                 
     
144.                                 /* 与函数socket中的AF_INET作用一样 */
     
145.                                 addr.sin_family = PF_INET;
     
146.                                 
     
147.                                 addr.sin_addr.s_b1 = IP1;
     
148.                                 addr.sin_addr.s_b2 = IP2;
     
149.                                 addr.sin_addr.s_b3 = IP3;
     
150.                                 addr.sin_addr.s_b4 = IP4;
     
151.                
     
152. //                host = gethostbyname ("www.baidu.com", &err);
     
153. //                addr1 = (IN_ADDR *)host->h_addr_list[0];
     
154. //               
     
155. //                                addr.sin_addr.s_b1 = addr1->s_b1;
     
156. //                                addr.sin_addr.s_b2 = addr1->s_b2;
     
157. //                                addr.sin_addr.s_b3 = addr1->s_b3;
     
158. //                                addr.sin_addr.s_b4 = addr1->s_b4;
     
159. 
     
160.                                 /* 客户端连接远程服务器，如果远程服务器还未创建，此函数会立即返回 */
     
161.                                 printf("新的  connect . \r\n");
     
162.                
     
163. //               sck_mode = 0;
     
164. //                ioctlsocket (sock, FIONBIO, &sck_mode);
     
165. //               
     
166. //                                   sck_mode = 1;
     
167. //                ioctlsocket (sock, FIO_DELAY_ACK, &sck_mode);
     
168. //               
     
169. //                                                   sck_mode = 1;
     
170. //                ioctlsocket (sock, FIO_FLOW_CTRL, &sck_mode);
     
171.               
     
172.             
     
173.                 tick1 = osKernelGetTickCount();
     
174.                                 res = connect (sock, (SOCKADDR *)&addr, sizeof (addr));// BSD_ETIMEDOUT
     
175.                                 printf_debug("connect 客户端连接远程服务器状态 res = %d. \r\n", res );
     
176.                                 if( res < 0 )
     
177.                                 {
     
178.                                                 printf("000000000000000000000\r\n");
     
179.                                                 closesocket (sock);
     
180.                                                 //errcnt++;
     
181.                                                 continue;
     
182.                                 }
     
183. 
     
184.                 send(sock,  http_data, strlen(http_data),0 );
     
185.                 //printf("http_data = \r\n[%s]  \r\n", http_data );
     
186.                 res = recv (sock, dbuf, sizeof(dbuf), 0);//设置了超时
     
187.                 if (res == BSD_ETIMEDOUT ) //超时了回去接着接收
     
188.                 {
     
189.                         printf_debug("111111111111111 = %d. \r\n", res );
     
190.                         //osDelay(6000);
     
191.                         closesocket (sock);
     
192.                         errcnt++;
     
193.                         continue;
     
194.                 }
     
195.                 else if(  res < 0 )
     
196.                 {
     
197.                         printf_debug("2222222222222222222 = %d. \r\n", res );
     
198.                         closesocket (sock);
     
199.                         errcnt++;
     
200.                         //osDelay(6000);
     
201.                         continue;
     
202.                 }
     
203.                 else
     
204.                 {
     
205.                     //printf("HTTP 读取成功 . \r\n");
     
206.                     cnt++;
     
207.                     dbuf[ res ]= 0;
     
208.                     //printf("Receive Data Length = %d ,cnt = %d,  dbuf = [%s].  \r\n ", res ,cnt,dbuf );
     
209.                     tick2 = osKernelGetTickCount();
     
210.                     tick2 =  tick2  - tick1;
     
211.                     printf("#########################= %d ms \r\n",  tick2 );
     
212.                     tick1 = osKernelGetTickCount();
     
213.                     
     
214.                     closesocket (sock);
     
215.                     tick2 = osKernelGetTickCount();
     
216.                     tick2 =  tick2  - tick1;
     
217.                     printf("------%d---------------- = %d ms\r\n", i++, tick2 );        
     
218.                 }
     
219.                 printf("结束一次cnt = %d, errcnt = %d \r\n",cnt , errcnt );
     
220. //              tick2 = osKernelGetTickCount();         
     
221. //              tick2 =  tick2  - tick1;      
     
222.         }
     
223. }
     
224. 
     
225. /***************************** 安富莱电子 www.armfly.com (END OF FILE) *********************************/
     

复制代码

eric2013

不同地区的百度地址略有不同。
简单省事些，没有使用gethostbyname做解析。

eric2013

eric2013

快6万包了，无错误

eric2013

改成不断创建新的Socket，然后统一Close，效果不错。