socket编程中的select模型问题

yacki

在socket编程时使用select模型，如何判断对方主机已经关闭？

1. 
   
2. // sockselect.cpp : Defines the entry point for the console application.
   
3. //
   
4. 
   
5. #include "stdafx.h"
   
6. 
   
7. #include <windows.h>
   
8. #include <stdio.h>
   
9. #include <tchar.h>  //for UNICODE
   
10. #include <io.h>
    
11. 
    
12. #define SERVER_PORT 2020
    
13. 
    
14. void ReadSocket(SOCKET s)
    
15. {
    
16.         char recvbuff[1024];
    
17.         int ret,
    
18.                 nLeft,
    
19.                 idx;
    
20.         nLeft = 30;
    
21.         idx = 0;
    
22.         while(nLeft>0)
    
23.         {
    
24.                 ret = recv(s, &recvbuff[idx], nLeft, 0);
    
25.                 if(ret==SOCKET_ERROR)
    
26.                 {
    
27.                 }
    
28.                 idx += ret;
    
29.                 nLeft -= ret;
    
30.         }
    
31. }
    
32. 
    
33. int main(int argc, char* argv[])
    
34. {
    
35. 
    
36.         SOCKET   s = INVALID_SOCKET;
    
37.         struct sockaddr_in ClientSAddr;
    
38.         WSADATA  WSStartData;
    
39.         fd_set fdread, fdexcept;
    
40.         int ret;
    
41.         char     DefaultIPAddr[] = "127.0.0.1";
    
42. 
    
43.         // time inteval to check sockets
    
44.         struct timeval tv;
    
45. 
    
46.         // create a socket and connect it to server
    
47.         WSAStartup(MAKEWORD(1,1), &WSStartData);
    
48.        
    
49.         // Init Socket
    
50.         s = socket(AF_INET,SOCK_STREAM,0);
    
51.        
    
52.         // Init Address
    
53.         memset (&ClientSAddr, sizeof(ClientSAddr),0);
    
54.         ClientSAddr.sin_family = AF_INET;
    
55.         ClientSAddr.sin_addr.S_un.S_addr = inet_addr(DefaultIPAddr);
    
56.         ClientSAddr.sin_port = htons(SERVER_PORT);
    
57.        
    
58.         // Connect
    
59.         connect(s, (struct sockaddr *)&ClientSAddr, sizeof(ClientSAddr));
    
60. 
    
61.         //
    
62.         tv.tv_sec = 5;
    
63.         tv.tv_usec = 0;
    
64. 
    
65.         while(TRUE)
    
66.         {
    
67.                 FD_ZERO(&fdread);
    
68.                 FD_ZERO(&fdexcept);
    
69. 
    
70.                 FD_SET(s, &fdread);
    
71.                 FD_SET(s, &fdexcept);
    
72. 
    
73.                 ret=select(0, &fdread, NULL, &fdexcept, &tv);
    
74. 
    
75.                 if(ret==SOCKET_ERROR)
    
76.                 {
    
77.                         printf("Error!");
    
78.                 }
    
79. 
    
80.                 if(ret > 0)
    
81.                 {
    
82.                         if(FD_ISSET(s, &fdexcept))
    
83.                         {
    
84.                                 printf("s in exception, quit...");
    
85.                                 break;
    
86.                         }
    
87.                         if(FD_ISSET(s, &fdread))
    
88.                         {
    
89.                                 //
    
90.                                 printf("There are %d socket(s) ready, we read it from socket...\n", ret);
    
91.                                 ReadSocket(s);
    
92.                                 //printf("FD_SET");
    
93.                         }
    
94.                 }
    
95. 
    
96. 
    
97.         }
    
98.         return 0;
    
99. }
    
100. 
     

复制代码

像这样一段代码，如果服务器正常发送数据，那么一切都很正常，一旦服务器socket关闭，客户机就会进入假死状态，CPU占用率达100%，如何判断对方关闭这一事件的发生呢？谢谢！

langue

听说有个half close什么的

告化甲头

若对端sock关闭，接收会读到0，发送会引发SIGPIPE