ESP32-C3-MINI socket连接

[wwwwwwww]

C3为服务端,一个设备不停的断开连接再重新连接C3,站点数也会增加,在断开连接时并不会减少站点数.导致多次以后,超过了最大站点连接数.请问有什么解决办法吗

[wwwwwwww]

Code: [Select all] [Expand/Collapse]

1.  for (;;)
2.         {
3.  
4.             // initialize file descriptor set
5.             FD_ZERO(&fdsr);
6.             FD_SET(listen_sock, &fdsr);
7.  
8.             // timeout setting
9.             tv.tv_sec = 60;
10.             tv.tv_usec = 0;
11.  
12.             // add active connection to fd set
13.             for (i = 0; i < BACKLOG; i++) {
14.                 if (fd_A[i] != 0) {
15.                     FD_SET(fd_A[i], &fdsr);
16.                 }
17.             }
18.             //block here until listen_sock can read
19.              int ret = select(maxsockfd+1, &fdsr, NULL, NULL, &tv);
20.             if (ret < 0) {
21.                 perror("select");
22.                 break;
23.             } else if (ret == 0) {
24.                 printf("timeout\n");
25.                 continue;
26.             }
27.              // check every fd in the set and handle the recv()
28.             for (i = 0; i < conn_amount; i++)
29.             {
30.  
31.                 if (FD_ISSET(fd_A[i], &fdsr))
32.                 {
33.  
34.                     ret = recv(fd_A[i], rx_buffer, sizeof(rx_buffer) - 1, 0);
35.                     ret1= ret;
36.                     station = i;
37.                     if (ret <= 0)
38.                     {        // client close
39.                          ESP_LOGE(TAG, "recv failed or connection closed: errno %d", errno);
40.                          printf("client[%d] close\n", i);
41.                         close(fd_A[i]);
42.                         FD_CLR(fd_A[i], &fdsr);
43.                         fd_A[i] = 0;
44.                        // conn_amount=0;
45.                     }
46.                     else
47.                     {        // receive data
48.                         //printf("star\n");
49.                         if (ret < BUF_SIZE)
50.                             memset(&rx_buffer[ret], '\0', 1);
51.                         printf("client[%d] send:%s\n", i, rx_buffer);
52.  
53.  
54.                         ctl_mode = rx_buffer[0];
55.                         //Uart0Recv(i,rx_buffer,ret);
56.                         /*int err = send(fd_A[i], rx_buffer, ret, 0);
57.  
58.                         if (err < 0) {
59.                             ESP_LOGE(TAG, "Error occured during sending: errno %d", errno);
60.                         continue;
61.                         }*/
62.                     }
63.                 }
64.             }
65.  
66.             // check whether a new connection comes and handler the new connection
67.             if (FD_ISSET(listen_sock, &fdsr)) {
68.                 int connect_sock = accept(listen_sock, (struct sockaddr *)&client_addr, &addrLen);
69.                 if (connect_sock <= 0) {
70.                     perror("accept");
71.                     continue;
72.                 }
73.                 ESP_LOGI(TAG, "Socket accepted");
74.  
75.                 // add to fd queue
76.                 if (conn_amount < BACKLOG)
77.                 {
78.                     fd_A[conn_amount++] = connect_sock;
79.                     printf("new connection client[%d] %s:%d\n", conn_amount,
80.                     inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port));
81.                     if (connect_sock > maxsockfd)
82.                         maxsockfd = connect_sock;
83.  
84.                 }
85.                 else {
86.                     printf("max connections arrive, exit\n");
87.                     send(connect_sock, "bye", 4, 0);
88.                     close(connect_sock);
89.                     continue;
90.                 }
91.             }
92.             //showclient();
93.         }
94.          //  when select() return error, close other connections
95.         for (i = 0; i < BACKLOG; i++) {
96.            ESP_LOGE(TAG, "Shutting down socket and restarting...");
97.             if (fd_A[i] != 0) {
98.                 shutdown(fd_A[i], 0);
99.                 close(fd_A[i]);
100.             }
101.         }

GeSHi © Codebox Plus Extension

[ESP_YJM]

你关闭 socket 的时候可以选择强制关闭 socket。 使用 SO_LINGER 选项。具体可以参考 viewtopic.php?f=13&t=20705