單線程客戶端處理多個(gè)socket連接的問題

microsunshine

程序要實(shí)現(xiàn)的功能：現(xiàn)在由n個(gè)DNS權(quán)威服務(wù)器，我依次向這些服務(wù)器發(fā)送同一個(gè)DNS查詢請求，每次發(fā)送完用select監(jiān)聽描述符集，獲取最先給出的DNS應(yīng)答，但是程序目前每次輪詢到的給出應(yīng)答的連接都是最后一個(gè)建立的描述符，但是通過wireshark抓包，在這之前已經(jīng)有服務(wù)器給出應(yīng)答了，為什么select沒有監(jiān)聽到？

1. int s, maxfd;
   
2.         int tries, ns, i;
   
3.         int n, sendlen, resplen;
   
4.         struct sockaddr_in nsap, from;
   
5.         socklen_t nsaplen, fromlen;
   
6.         struct timeval timeout;
   
7.         fd_set rset;
   
8. 
   
9.         FD_ZERO(&rset);
   
10.         maxfd = -1;
    
11. 
    
12.         /* No name servers or res_init() failure */
    
13.         if (statp->nscount == 0 ) {
    
14.                 goto fail;
    
15.         }
    
16. 
    
17.         /*
    
18.          * Send request, RETRY times, or until successful.
    
19.          */
    
20. 
    
21.         for (tries = 0; tries < statp->retry; tries++) {
    
22. 
    
23.             for (ns = 0; ns < statp->nscount; ns++) {
    
24.                         /* Use datagrams. */
    
25.                         if(statp->socks[ns] == -1)
    
26.                         {
    
27.                                 statp->socks[ns] = socket(PF_INET,SOCK_DGRAM,0);
    
28.                                 setnonblocking(statp->socks[ns]);
    
29. 
    
30.                         }
    
31.                         s = statp->socks[ns];
    
32.                         printf("fd %d\n",s);
    
33.                        
    
34.                         nsap = statp->nsaddr_list[ns];
    
35.                         nsaplen = sizeof(struct sockaddr_in);
    
36.                 /*        if(connect(s,(struct sockaddr *)&nsap,nsaplen) == -1)
    
37.                         {
    
38.                                 fprintf(stderr,"connect error\n");
    
39.                                 goto fail;
    
40.                         }*/
    
41.                                
    
42.                         sendlen = sendto(s,(const char *)buf,buflen,0,(struct sockaddr *)&nsap,nsaplen);
    
43.                         if(sendlen <= 0)
    
44.                         {
    
45.                                 printf("send to failed\n");
    
46.                                 goto fail;
    
47.                         }
    
48. 
    
49.                         if(sendlen != buflen)
    
50.                         {
    
51.                                 printf("send to error\n");
    
52.                                 goto fail;
    
53.                         }
    
54. 
    
55.                         FD_SET(s, &rset);
    
56.                         if(s > maxfd)
    
57.                                 maxfd = s;
    
58.                         timeout.tv_sec = 0;
    
59.                         timeout.tv_usec = 90000;
    
60.                         n = select(maxfd+1, &rset, NULL, NULL, &timeout);
    
61.                
    
62.                         if (n == 0) {
    
63.                                 printf("select timeout\n");
    
64.                                 continue;
    
65.                         }
    
66.                         if (n < 0) {
    
67.                
    
68.                                 printf("select error\n");
    
69. //                                res_nclose(statp);
    
70.                                 goto fail;
    
71.                         }
    
72.                         for(i=0;i<=ns;i++)
    
73.                         {       
    
74.                                 if(FD_ISSET(statp->socks[i],&rset))
    
75.                                 {
    
76.                                         printf("active fd %d\n",statp->socks[i]);
    
77.                                         fromlen = sizeof(from);
    
78.                                         resplen = recvfrom(statp->socks[i], (char*)ans, anssiz,0,
    
79.                                                    (struct sockaddr *)&from, &fromlen);
    
80.                                         if (resplen <= 0) {
    
81.                                                 printf("recvfrom error\n");
    
82. //                                                res_nclose(statp);
    
83.                                                 goto fail;       
    
84.                                         }
    
85.                                         return resplen;
    
86.                                 }
    
87.                                
    
88.                         }
    
89.                 } /*foreach ns*/
    
90.         } /*foreach retry*/
    
91.         res_nclose(statp);
    
92.         return -1;
    
93. fail:
    
94.     res_nclose(statp);
    
95.         return -1;

復(fù)制代碼