使用RL-TCPnet V7.X的函数netTCP_Connect反复重连服务器端，可以在前面调用下netTCP_Abort，保证每次都可以正常重连

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. #define IP1            192
    
57. #define IP2            168
    
58. #define IP3            28
    
59. #define IP4            146
    
60. 
    
61. #define PORT_NUM         1001
    
62. 
    
63. /* 这个是本地端口 */
    
64. #define LocalPort_NUM    1024
    
65. 
    
66. /*
    
67. *********************************************************************************************************
    
68. *                                             变量
    
69. *********************************************************************************************************
    
70. */
    
71. NET_ADDR4 addr = { NET_ADDR_IP4, PORT_NUM, IP1,IP2,IP3,IP4};
    
72. int32_t tcp_sock;
    
73. 
    
74. 
    
75. /* TCPnet API的返回值 */
    
76. static const char * ReVal_Table[]=
    
77. {
    
78.         "netOK: Operation succeeded",
    
79.         "netBusy: Process is busy",
    
80.         "netError: Unspecified error",
    
81.         "netInvalidParameter: Invalid parameter specified",
    
82.         "netWrongState: Wrong state error",
    
83.         "netDriverError: Driver error",
    
84.         "netServerError: Server error",
    
85.         "netAuthenticationFailed: User authentication failed",
    
86.         "netDnsResolverError: DNS host resolver failed",
    
87.         "netFileError: File not found or file r/w error",
    
88.         "netTimeout: Operation timeout",
    
89. };
    
90. 
    
91. /*
    
92. *********************************************************************************************************
    
93. *        函 数 名: tcp_cb_client
    
94. *        功能说明: TCP Socket的回调函数
    
95. *        形    参: socket  句柄
    
96. *             event   事件类型
    
97. *             addr    NET_ADDR类型变量，记录IP地址，端口号。
    
98. *             buf     ptr指向的缓冲区记录着接收到的TCP数据。
    
99. *             len     记录接收到的数据个数。
    
100. *        返 回 值:
     
101. *********************************************************************************************************
     
102. */
     
103. extern osThreadId_t ThreadIdTaskMsgPro;
     
104. uint32_t tcp_cb_client (int32_t socket, netTCP_Event event,
     
105.                         const NET_ADDR *addr, const uint8_t *buf, uint32_t len)
     
106. {
     
107.         switch (event)
     
108.         {
     
109.                 /*
     
110.                         远程客户端连接消息
     
111.                     1、数组ptr存储远程设备的IP地址，par中存储端口号。
     
112.                     2、返回数值1允许连接，返回数值0禁止连接。
     
113.                 */
     
114.                 case netTCP_EventConnect:
     
115.                         return (1);
     
116. 
     
117.                 /* Socket远程连接已经建立 */
     
118.                 case netTCP_EventEstablished:
     
119.                         printf_debug("Socket is connected to remote peer\r\n");
     
120.                         break;
     
121. 
     
122.                 /* 连接断开 */
     
123.                 case netTCP_EventClosed:
     
124.                         osThreadFlagsSet(ThreadIdTaskMsgPro, KEY4_BIT3);
     
125.                         printf_debug("Connection has been closed\r\n");
     
126.                         break;
     
127. 
     
128.                 /* 连接终止 */
     
129.                 case netTCP_EventAborted:
     
130.                         break;
     
131. 
     
132.                 /* 发送的数据收到远程设备应答 */
     
133.                 case netTCP_EventACK:
     
134.                         break;
     
135. 
     
136.                 /* 接收到TCP数据帧，ptr指向数据地址，par记录数据长度，单位字节 */
     
137.                 case netTCP_EventData:
     
138.                         printf_debug("Data length = %d\r\n", len);
     
139.                         printf ("%.*s\r\n",len, buf);
     
140.                         break;
     
141.         }
     
142.         return (0);
     
143. }
     
144. 
     
145. /*
     
146. *********************************************************************************************************
     
147. *        函 数 名: TCPnetTest
     
148. *        功能说明: TCPnet应用
     
149. *        形    参: 无
     
150. *        返 回 值: 无
     
151. *********************************************************************************************************
     
152. */   
     
153. void TCPnetTest(void)
     
154. {
     
155.         int32_t iCount;
     
156.         uint8_t *sendbuf;
     
157.         uint32_t maxlen;
     
158.         netStatus res;
     
159.         const uint16_t usMaxBlockTime = 2; /* 延迟周期 */
     
160.         uint32_t EvtFlag;
     
161. 
     
162.         tcp_sock = netTCP_GetSocket (tcp_cb_client);
     
163.        
     
164.         if (tcp_sock > 0)
     
165.         {
     
166.                 /* 使能TCP_TYPE_KEEP_ALIVE，会一直保持连接 */
     
167.                 netTCP_SetOption (tcp_sock, netTCP_OptionKeepAlive, 1);               
     
168.         }
     
169. 
     
170.         while (1)
     
171.         {
     
172.                
     
173.                 EvtFlag = osThreadFlagsWait(0x0000000FU, osFlagsWaitAny, usMaxBlockTime);
     
174.                
     
175.                 /* 按键消息的处理 */
     
176.                 switch (EvtFlag)
     
177.                 {
     
178.                         /* 接收到K1键按下，给远程TCP客户端发送8字节数据 */
     
179.                         case KEY1_BIT0:                          
     
180.                                 iCount = 8;
     
181.                                 if(netTCP_GetState(tcp_sock) == netTCP_StateESTABLISHED)
     
182.                                 {
     
183.                                         do
     
184.                                         {
     
185.                                                 if(netTCP_SendReady(tcp_sock) == true )
     
186.                                                 {
     
187.                                                         maxlen  = netTCP_GetMaxSegmentSize (tcp_sock);
     
188. 
     
189.                                                         iCount -= maxlen;
     
190.                                                        
     
191.                                                         if(iCount < 0)
     
192.                                                         {
     
193.                                                                 /* 这么计算没问题的 */
     
194.                                                                 maxlen = iCount + maxlen;
     
195.                                                         }
     
196.                                                        
     
197.                                                         sendbuf = netTCP_GetBuffer (maxlen);
     
198.                                                         sendbuf[0] = '1';
     
199.                                                         sendbuf[1] = '2';
     
200.                                                         sendbuf[2] = '3';
     
201.                                                         sendbuf[3] = '4';
     
202.                                                         sendbuf[4] = '5';
     
203.                                                         sendbuf[5] = '6';
     
204.                                                         sendbuf[6] = '7';
     
205.                                                         sendbuf[7] = '8';
     
206.                                                        
     
207.                                                         /* 必须使用申请的内存空间 */
     
208.                                                         netTCP_Send (tcp_sock, sendbuf, maxlen);
     
209.                                                 }
     
210.                                                
     
211.                                         }while(iCount > 0);
     
212.                                 }
     
213.                                 break;
     
214. 
     
215.                         /* 接收到K2键按下，给远程TCP客户端发送1024字节的数据 */
     
216.                         case KEY2_BIT1:       
     
217.                                 iCount = 1024;
     
218.                                 if(netTCP_GetState(tcp_sock) == netTCP_StateESTABLISHED)
     
219.                                 {
     
220.                                         do
     
221.                                         {
     
222.                                                 if(netTCP_SendReady(tcp_sock) == true )
     
223.                                                 {
     
224.                                                         maxlen  = netTCP_GetMaxSegmentSize (tcp_sock);
     
225. 
     
226.                                                         iCount -= maxlen;
     
227.                                                        
     
228.                                                         if(iCount < 0)
     
229.                                                         {
     
230.                                                                 /* 这么计算没问题的 */
     
231.                                                                 maxlen = iCount + maxlen;
     
232.                                                         }
     
233.                                                        
     
234.                                                         sendbuf = netTCP_GetBuffer (maxlen);
     
235.                                                         sendbuf[0] = '1';
     
236.                                                         sendbuf[1] = '2';
     
237.                                                         sendbuf[2] = '3';
     
238.                                                         sendbuf[3] = '4';
     
239.                                                         sendbuf[4] = '5';
     
240.                                                         sendbuf[5] = '6';
     
241.                                                         sendbuf[6] = '7';
     
242.                                                         sendbuf[7] = '8';
     
243.                                                        
     
244.                                                         /* 必须使用申请的内存空间 */
     
245.                                                         netTCP_Send (tcp_sock, sendbuf, maxlen);
     
246.                                                 }
     
247.                                                
     
248.                                         }while(iCount > 0);
     
249.                                 }
     
250.                                 break;                                       
     
251.                                
     
252.                                
     
253.                         /* 接收到K3键按下，给远程TCP客户端发送5MB数据 */
     
254.                         case KEY3_BIT2:                          
     
255.                                 iCount = 5*1024*1024;       
     
256.                                 if(netTCP_GetState(tcp_sock) == netTCP_StateESTABLISHED)
     
257.                                 {
     
258.                                         do
     
259.                                         {
     
260.                                                 if(netTCP_SendReady(tcp_sock) == true )
     
261.                                                 {
     
262.                                                         maxlen  = netTCP_GetMaxSegmentSize (tcp_sock);
     
263. 
     
264.                                                         iCount -= maxlen;
     
265.                                                        
     
266.                                                         if(iCount < 0)
     
267.                                                         {
     
268.                                                                 /* 这么计算没问题的 */
     
269.                                                                 maxlen = iCount + maxlen;
     
270.                                                         }
     
271.                                                        
     
272.                                                         sendbuf = netTCP_GetBuffer (maxlen);
     
273.                                                         sendbuf[0] = '1';
     
274.                                                         sendbuf[1] = '2';
     
275.                                                         sendbuf[2] = '3';
     
276.                                                         sendbuf[3] = '4';
     
277.                                                         sendbuf[4] = '5';
     
278.                                                         sendbuf[5] = '6';
     
279.                                                         sendbuf[6] = '7';
     
280.                                                         sendbuf[7] = '8';
     
281.                                                        
     
282.                                                         /* 必须使用申请的内存空间 */
     
283.                                                         netTCP_Send (tcp_sock, sendbuf, maxlen);
     
284.                                                 }
     
285.                                                
     
286.                                         }while(iCount > 0);
     
287.                                 }
     
288.                                 break;
     
289.                        
     
290.                         /* 接收到摇杆OK键按下，连接远程服务器 */
     
291.                         case KEY4_BIT3:                          
     
292.                                 if (tcp_sock > 0)
     
293.                                 {
     
294.                                         if(netTCP_GetState(tcp_sock) != netTCP_StateESTABLISHED)
     
295.                                         {
     
296.                                             netTCP_Abort(tcp_sock);
     
297.                                                 res = netTCP_Connect (tcp_sock, (NET_ADDR *)&addr, LocalPort_NUM);
     
298.                                                 printf_debug("%s\r\n", ReVal_Table[res]);
     
299.                                         }
     
300.                                 }
     
301.                                 break;
     
302.                                
     
303.                          /* 其他的键值不处理 */
     
304.                         default:                     
     
305.                                 break;
     
306.                 }
     
307.         }
     
308. }
     
309. 
     
310. /***************************** 安富莱电子 www.armfly.com (END OF FILE) *********************************/
     

复制代码

BruceWang

硬汉哥，电脑端删除连接，或者断开客户端连接，板子端如果为Abort，复位马上能连接上，如果为Closed，复位也连接不上，这两个有啥不同吗？

eric2013

BruceWang 发表于 2022-11-7 01:19
硬汉哥，电脑端删除连接，或者断开客户端连接，板子端如果为Abort，复位马上能连接上，如果为Closed，复位 ...

就是要abort，不能close，这个精髓测试，我花了半天才测试出来的api

gallop020142

请问硬汉 abort 之后应该怎么处理呢？删除本任务、清理网络再initialize吗？

BruceWang

eric2013 发表于 2022-11-7 17:00
就是要abort，不能close，这个精髓测试，我花了半天才测试出来的api

硬汉哥，可能是我表述不清晰，您那边理解有偏差；
1，想问一下硬汉哥测试环境是怎样子？电脑<----网线---->板子，是这样子吗？
2、我的测试环境是，电脑<---网线-----交换机-----网线---->板子。
3、操作：我每次在电脑端，不管是《删除客户端连接》，还是《断开客户端连接》，板子端串口都会打印：TCP   connection Closed，而不是TCP connection Abort;即每次板子端都会进入netTCP_EventClosed事件，而不是进入netTCP_EventAborted;
4、以上就是我和硬汉个测试出现的不同之处，不知是啥原因导致，可能是接了交换机的原因（但没有验证过）
5、如果串口打印Abort，板子能立马连接上，如果打印Closed，则需要很久
6、针对Closed这种情况，硬汉哥有没有什么好的办法解决，大家可以讨论一下

eric2013

gallop020142 发表于 2022-11-7 22:33
请问硬汉 abort 之后应该怎么处理呢？删除本任务、清理网络再initialize吗？

重连就行了。

eric2013

BruceWang 发表于 2022-11-8 01:36
硬汉哥，可能是我表述不清晰，您那边理解有偏差；
1，想问一下硬汉哥测试环境是怎样子？电脑板子，是这 ...

楼主位的是通过路由器或者交换机接外网服务器的实际应用案例，

实际应用中，服务器端有个连接时间限制，超过后自动断开。

断开后，客户端直接下abort后，然后重连就可以及时连接上，如果不加会比较随机，有时候时间很长。

BruceWang

eric2013 发表于 2022-11-8 09:49
楼主位的是通过路由器或者交换机接外网服务器的实际应用案例，

实际应用中，服务器端有个连接时间限制 ...

硬汉哥，问题找到了，只要不重新申请Socket，就没有问题了，一直判断当前连接状态即可

[C] 纯文本查看 复制代码

while(1)
		{
			if(netTCP_GetState(SSEI_TCP_Socket) != netTCP_StateESTABLISHED)
			{
				netTCP_Abort(SSEI_TCP_Socket);
				
				ret = netTCP_Connect (SSEI_TCP_Socket, (NET_ADDR *)&ServerAddr, LOCAL_PORT_NUM);
				
				Printf_task("%s\r\n", errSSEI_NetRetVal_Table[ret]);
			}

			osDelay(50);
		}

eric2013

BruceWang 发表于 2022-11-8 12:30
硬汉哥，问题找到了，只要不重新申请Socket，就没有问题了，一直判断当前连接状态即可
[mw_shl_code=c,t ...

好的。