freertos TCP Client无法连接Server

kevin0825

我在STM32F407上搭建TCP客户端，打算让它连接PC上的服务器，但每次启动时connect一直不成功。于是我就打开PC上的cmd终端，ping下客户端，发现是通的，奇怪的现象就出现了：ping完客户端后，客户端马上就能connect上服务器了。。试了几次都是这样，郁闷，请问大家知道这是啥原因导致的？

客户端IP：192.168.11.77
服务端IP：192.168.11.37

服务端软件：串口调试助手上的网络服务器功能
客户端代码：

1. #include "tcp_client.h"
   
2. 
   
3. 
   
4. #include <stdio.h>
   
5. #include <stdlib.h>
   
6. #include <string.h>
   
7. #include <memory>
   
8. 
   
9. 
   
10. #include <cmsis_os.h>
    
11. #include "FreeRTOSIPConfig.h"
    
12. #include "FreeRTOS_IP.h"
    
13. #include "FreeRTOS_Sockets.h"
    
14. 
    
15. #include "data/data.h"
    
16. #include "generate_protocol/search_protocol/search_protocol.h"
    
17. #include "protocol/message.h"
    
18. #include "protocol/protocol.h"
    
19. #include "protocol/node_id.h"
    
20. #include "package.h"
    
21. 
    
22. #define MAX_HEART_COUNT                5        //单位xReceiveTimeOut
    
23. 
    
24. 
    
25. struct freertos_sockaddr TcpServerAddress;
    
26. static const TickType_t xReceiveTimeOut = pdMS_TO_TICKS( 2000 );
    
27. static const TickType_t xSendTimeOut = pdMS_TO_TICKS( 1000 );
    
28. Socket_t xSocket;
    
29. Recivebuff recivebuffes;
    
30. TaskHandle_t TCPTest_TaskHandle;
    
31. int try_count = 0;
    
32. int heart_miss_count = 0;
    
33. 
    
34. // 连接函数
    
35. int TcpClientConnect(void)
    
36. {
    
37.         int ret = 0;
    
38.         // 每次连接之前逻辑清空接收数组
    
39.         recivebuffes.length = 0;
    
40.        
    
41.         // 填充目标端口和IP地址
    
42.         Data* data = Data::GetInstance();
    
43.         unsigned short port = data->GetPort();
    
44.         TcpServerAddress.sin_port = FreeRTOS_htons(port);
    
45.         TcpServerAddress.sin_addr = FreeRTOS_htonl(data->GetRemoteIP());
    
46.          
    
47.         // 创建套接字
    
48.         xSocket = FreeRTOS_socket( FREERTOS_AF_INET, FREERTOS_SOCK_STREAM, FREERTOS_IPPROTO_TCP );
    
49.         configASSERT( xSocket != FREERTOS_INVALID_SOCKET );
    
50. 
    
51.         // 设置超时
    
52.         FreeRTOS_setsockopt( xSocket, 0, FREERTOS_SO_RCVTIMEO, &xReceiveTimeOut, sizeof( xReceiveTimeOut ) );
    
53.         FreeRTOS_setsockopt( xSocket, 0, FREERTOS_SO_SNDTIMEO, &xSendTimeOut, sizeof( xSendTimeOut ) );
    
54.        
    
55.         // 连接
    
56.         ret = FreeRTOS_connect( xSocket, &TcpServerAddress, sizeof( TcpServerAddress ) );
    
57.        
    
58.         return ret;
    
59. }
    
60. 
    
61. // 断开连接
    
62. void TcpClientDisconnect(void)
    
63. {
    
64.         TickType_t xTimeOnEntering;
    
65.         BaseType_t xReturned;
    
66.        
    
67.         // 关闭连接
    
68.         FreeRTOS_shutdown( xSocket, FREERTOS_SHUT_RDWR );
    
69.        
    
70.         // 检查连接是否断开
    
71.         xTimeOnEntering = xTaskGetTickCount();
    
72.         do
    
73.         {
    
74.                 xReturned = FreeRTOS_recv( xSocket, recivebuffes.cRxBuffers, sizeof(recivebuffes.cRxBuffers), 0 );
    
75.                 if( xReturned < 0 )
    
76.                 {
    
77.                         break;
    
78.                 }
    
79.         }
    
80.         while( ( xTaskGetTickCount() - xTimeOnEntering ) < xReceiveTimeOut );
    
81.        
    
82.         // 关闭套接字
    
83.         FreeRTOS_closesocket( xSocket );
    
84.        
    
85. }
    
86. 
    
87. // 发送函数
    
88. int TcpClientSend(char *pSendBuff,uint32_t lBuffLen)
    
89. {       
    
90.         BaseType_t lTransmitted;
    
91.        
    
92.         // 发送数据
    
93.         lTransmitted = FreeRTOS_send(xSocket,pSendBuff,lBuffLen,0 );
    
94.         //vTaskDelay(150 / portTICK_PERIOD_MS);
    
95.        
    
96.         if(lTransmitted < 0)
    
97.         {
    
98.                 return 0;
    
99.         }
    
100.         else
     
101.         {
     
102.                 return 1;
     
103.         }
     
104. }
     
105. 
     
106. // 接收函数
     
107. void TcpClientRecive(void)
     
108. {
     
109.         BaseType_t lrecive;
     
110.        
     
111.         // 接收数据
     
112.         memset(recivebuffes.cRxBuffers, 0, sizeof(recivebuffes.cRxBuffers));
     
113.         lrecive = FreeRTOS_recv(xSocket, recivebuffes.cRxBuffers, sizeof(recivebuffes.cRxBuffers), 0);
     
114.         if(lrecive <= 0 )
     
115.                 recivebuffes.length = 0;
     
116.         else
     
117.         {
     
118.                 recivebuffes.length = lrecive;
     
119.         }
     
120. }
     
121. 
     
122. void TcpClientThread(const void *parameter)
     
123. {
     
124. 
     
125.         auto send_to_pc = [](const std::string& data) ->void
     
126.         {
     
127.                 TcpClientSend((char *)data.c_str(), data.size());
     
128.         };
     
129.        
     
130.         do{
     
131.                 if(TcpClientConnect() == 0)
     
132.                 {
     
133.                         try_count = 0;
     
134.                         while(1)
     
135.                         {
     
136.                        
     
137.                                 vTaskDelay(2000 / portTICK_RATE_MS );
     
138. 
     
139.                         }
     
140.                 }
     
141. 
     
142.                 TcpClientDisconnect();
     
143.                 vTaskDelay(3000 / portTICK_RATE_MS );
     
144.                
     
145.         }while(++try_count);
     
146.        
     
147. 
     
148.         vTaskDelete(xTaskGetCurrentTaskHandle());
     
149. }
     
150. BaseType_t xReturned;
     
151. void Heart_Handler(const void *parameter)
     
152. {
     
153. 
     
154. 
     
155.         while(1)
     
156.         {
     
157.                 if(FreeRTOS_issocketconnected(xSocket))
     
158.                 {
     
159.                         memset(recivebuffes.cRxBuffers, 0, sizeof(recivebuffes.cRxBuffers));
     
160.                         xReturned = FreeRTOS_recv(         xSocket,                                        /* The socket being received from. */
     
161.                                                                         recivebuffes.cRxBuffers,                /* The buffer into which the received data will be written. */
     
162.                                                                         sizeof(recivebuffes.cRxBuffers),                /* The size of the buffer provided to receive the data. */
     
163.                                                                         0 );
     
164. 
     
165.                                                 }
     
166.                 else
     
167.                 {
     
168.                         vTaskDelay( 1000 / portTICK_PERIOD_MS );
     
169.                 }
     
170. 
     
171.         }
     
172. 
     
173.         vTaskDelete(xTaskGetCurrentTaskHandle());
     
174. }
     
175. 
     
176. int CreateTcpThread(void)
     
177. {
     
178. 
     
179.     osThreadDef(TcpTask, TcpClientThread, osPriorityNormal, 0, 1024);
     
180.     osThreadCreate(osThread(TcpTask), (void*)0);
     
181. 
     
182.         osThreadDef(HeartTask, Heart_Handler, osPriorityNormal, 0, 700);
     
183.     osThreadCreate(osThread(HeartTask), (void*)0);
     
184. 
     
185.         return 0;
     
186. }
     

复制代码

gjs13030247996

帮顶一下。

kevin0825

客户端连不上时，错误码返回是pdFREERTOS_ERRNO_ETIMEDOUT，即连接超时。
通过抓包发现，客户端connect时第一包SYN握手都没发出来。。

hou18

把防火墙全部关闭，网络适配器只留下要连接的IP的适配器，别的适配器关闭看下

kevin0825

hou18 发表于 2021-6-30 12:29
把防火墙全部关闭，网络适配器只留下要连接的IP的适配器，别的适配器关闭看下

PC防火墙一直是关着的，适配器也有试过只留下“以太网”，但还是一样的现象。
我试过局域网内手机TCP软件连接PC上的服务端，是可以正常连接的

kevin0825

我debug发现：
/* Determine the ARP cache status for the requested IP address. */
eReturned = eARPGetCacheEntry( &( ulRemoteIP ), &( xEthAddress ) );
eReturned返回的是eARPCacheMiss，也就是说ARP缓存中没找到该服务器IP地址，当我ping客户端的时候，ARP缓存中就出现服务器IP，于是就顺利连接上了？
但是没道理呀，难道每次都要先让服务器下发数据给客户端，才能保证后面正常连接？