网络编程，单线程select，客户端连接几次后,服务器就不返回数据

setsuna

server端运行在linux下，使用单线程+ select多路复用模型。client运行在win下。client发送命令来通知server，server返回数据给client。
遇到的问题： 比如server端listen的backlog为5，那么client在连接4次之后就会出现：可以连接server，但是客户端发送数据给server，server端select总是返回0并且不会返回数据给client。
请问是代码哪里出了错？万分感谢！
代码大致如下：

1.     //创建侦听Socket
   
2.     if ((sock_fd = socket(AF_INET, SOCK_STREAM, 0)) == -1)
   
3.     {
   
4.         perror("Create listening socket error!");
   
5.         exit(1);
   
6.     }
   
7.    
   
8.         int flags;
   
9.         if(flags= fcntl(sock_fd, F_GETFL, 0) <0)
   
10.         {
    
11.                 printf("F_GETFL errors, %s\n", strerror(errno));
    
12.                 return -1;
    
13.         }
    
14.         flags |= O_NONBLOCK;
    
15.         if(flags= fcntl(sock_fd, F_SETFL, 0) <0)
    
16.         {
    
17.                 printf("F_SETFL O_NONBLOCK errors, %s\n", strerror(errno));
    
18.                 return -1;
    
19.         }
    
20.         //配置侦听Socket
    
21.     //SO_REUSEADDR BOOL 允许套接口和一个已在使用中的地址捆绑。
    
22.     if (setsockopt(sock_fd, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(int)) == -1)
    
23.     {
    
24.         perror("setsockopt error!");
    
25.         exit(1);
    
26.     }
    
27.    
    
28.     server_addr.sin_family = AF_INET;         // host byte order
    
29.     server_addr.sin_port = htons(MYPORT);     // short, network byte order
    
30.     server_addr.sin_addr.s_addr = INADDR_ANY; // automatically fill with my IP
    
31.     memset(server_addr.sin_zero, '\0', sizeof(server_addr.sin_zero));
    
32. 
    
33.     //绑定新创建的Socket到指定的IP和端口
    
34.     if (bind(sock_fd, (struct sockaddr *)&server_addr, sizeof(server_addr)) == -1)
    
35.     {
    
36.         perror("bind error!");
    
37.         exit(1);
    
38.     }
    
39.     //开始侦听，最大连接数为BACKLOG
    
40.     if (listen(sock_fd, BACKLOG) == -1)
    
41.     {
    
42.         perror("listen error!");
    
43.         exit(1);
    
44.     }
    
45.    
    
46.     //监控文件描述符集合
    
47.     fd_set fdsr;
    
48.     //监控文件描述符集合中最大的文件号
    
49.     int maxsock;
    
50.     //Select超时返回的时间。
    
51.     struct timeval  tv;
    
52. 
    
53.     conn_amount = 0;
    
54.     sin_size = sizeof(client_addr);
    
55.     maxsock = sock_fd;
    
56.         for(i = 0; i< BACKLOG; i++)
    
57.         {
    
58.                 fd_A[i] = -1;
    
59.         }
    
60.         // 初始化文件描述符集合 initialize file descriptor set
    
61.         FD_ZERO(&fdsr);
    
62.         // 把Sock_fd加入到文件描述符集合
    
63.         FD_SET(sock_fd, &fdsr);
    
64. 
    
65.     while (1)
    
66.     {
    
67. 
    
68.         // 超时设置30秒
    
69.         tv.tv_sec = 30;
    
70.         tv.tv_usec = 0;
    
71. 
    
72.         int nready = select(maxsock + 1, &fdsr, NULL, NULL, &tv);
    
73. 
    
74.         if (nready < 0)
    
75.         {
    
76.             perror("select error!");
    
77.             break;
    
78.         }
    
79.         else if (nready == 0)
    
80.         {
    
81.             printf("timeout\n");
    
82.             continue;
    
83.         }
    
84.                 // 检查是否有新连接进来，如果有新连接进来，接收连接，生成新socket，
    
85. 
    
86.         //并加入到监控文件描述符集合中。
    
87.         if (FD_ISSET(sock_fd, &fdsr))
    
88.         {
    
89.             //接受连接
    
90.             new_fd = accept(sock_fd, (struct sockaddr *)&client_addr, &sin_size);
    
91.             if (new_fd <= 0)
    
92.             {
    
93.                 perror("accept socket error!");
    
94.                 continue;
    
95.             }
    
96.             for (i = 0; i < BACKLOG; i++)
    
97.             {
    
98.                         if(fd_A[i] < 0)
    
99.                         {
    
100.                                 fd_A[i] = new_fd;
     
101.                                 printf("new connection client[%d] %s:%d\n", conn_amount,inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port));
     
102.                                 break;
     
103.                         }
     
104. 
     
105.             }
     
106.                 if(i == BACKLOG)
     
107.                 {
     
108.                         printf("too many clients: %d\n", i);
     
109.                         exit(0);
     
110.                 }
     
111.                 FD_SET(new_fd, &fdsr);
     
112.                 if(new_fd > maxsock)
     
113.                         maxsock = new_fd;
     
114.                 if(maxi <i)
     
115.                         maxi = i;
     
116.                 if(--nready <= 0)
     
117.                         continue;
     
118.         }
     
119.                 int tmp_sock;
     
120.         // 轮询各个文件描述符（socket）
     
121.         for (i = 0; i <= maxi; i++)
     
122.         {
     
123.              //FD_ISSET（int fd， fdset *fdset）：检查fdset联系的文件句柄fd是否可读写，
     
124.                          printf("start\n");
     
125.                         if((tmp_sock = fd_A[i]) <0)
     
126.                                 continue;
     
127.              // >0表示可读写。
     
128.             if (FD_ISSET(tmp_sock, &fdsr))
     
129.             {
     
130.                 // 接收数据
     
131.                 ret = recv(fd_A[i], buf, sizeof(buf), 0);
     
132.                 if (ret <= 0) //接收数据出错
     
133.                 {      
     
134.                     printf("client[%d] close\n", i);
     
135.                     close(fd_A[i]);
     
136.                     FD_CLR(fd_A[i], &fdsr);
     
137.                     fd_A[i] = -1;
     
138.                 }
     
139.                 else  // 数据接收成功
     
140.                 {
     
141.                         //返回数据，暂略！
     
142.                 }
     
143.                  if(--nready <= 0)
     
144.                         continue;
     
145.             }
     
146.         }
     
147.     }

复制代码

hellioncu

每次select之前fdsr要重新准备

setsuna

每次select之前fdsr要重新准备
hellioncu 发表于 2010-05-20 19:14

成功了！非常感谢！非常感谢！

rain_fish

经常犯得错误。。。