如何实现在客户端中用select监听有无数据读

kangear

总体思想是这样的，从client往server来发东西是可确定的，但是我client接收数据有很大的随机性，我就想在不改变整体框架的情况下。在client端用select来监听，如果有数据就自动读出来，而不是有手动读。功能就是判断读的，写自己实现，目前的程序如下：

1. #include <stdio.h>
   
2. #include <sys/types.h>
   
3. #include <sys/socket.h>
   
4. #include <sys/un.h>
   
5. #include <netdb.h>
   
6. #include <unistd.h>
   
7. 
   
8. int main(int argc,char *argv[])
   
9. {
   
10.     int connect_fd;
    
11.         int ret;
    
12.         char snd_buf[1024];
    
13.         int i;
    
14.         int port;
    
15.         int len;
    
16. 
    
17.         static struct sockaddr_in srv_addr;
    
18. 
    
19.         //客户端运行需要给出具体的连接地址和端口
    
20.         if(argc!=3)
    
21.         {
    
22.             printf("Usage: %s server_ip_address port\n",argv[0]);
    
23.                 return 1;
    
24.         }
    
25. 
    
26.         //获得输入的端口
    
27.         port=atoi(argv[2]);
    
28. 
    
29.         //创建套节字用于客户端的连接
    
30.         connect_fd=socket(PF_INET,SOCK_STREAM,0);
    
31.         if(connect_fd<0)
    
32.         {
    
33.             perror("cannot create communication socket");
    
34.                 return 1;
    
35.         }
    
36. 
    
37.         //填充关于服务器的套节字信息
    
38.         memset(&srv_addr,0,sizeof(srv_addr));
    
39.         srv_addr.sin_family=AF_INET;
    
40.         srv_addr.sin_addr.s_addr=inet_addr(argv[1]);
    
41.         srv_addr.sin_port=htons(port);
    
42. 
    
43.         //连接指定的服务器
    
44.         ret=connect(connect_fd,(struct sockaddr *)&srv_addr,sizeof(srv_addr));
    
45.         if(ret==-1)
    
46.         {
    
47.             perror("cannot connect to the server");
    
48.                 close(connect_fd);
    
49.                 return 1;
    
50.         }
    
51. 
    
52.         memset(snd_buf,0,1024);
    
53.         //用户输入信息后，程序将输入的信息通过套接字发送给服务器
    
54.         //然后调用read函数从服务器中读取发送来的信息
    
55.         //当输入“@”时，程序退出
    
56.         while(1)
    
57.         {
    
58.             write(STDOUT_FILENO,"input message:",14);
    
59.                 len=read(STDIN_FILENO,snd_buf,1024);
    
60.                 if(len>0)
    
61.                         write(connect_fd,snd_buf,len);
    
62.                 len=read(connect_fd,snd_buf,len);
    
63.                 if(len>0)
    
64.                         printf("Message form server: %s\n",snd_buf);
    
65.                 if(snd_buf[0]=='@')
    
66.                         break;
    
67.         }
    
68.         close(connect_fd);
    
69.         return 0;
    
70. }

复制代码

当我在服务器端连发两个信息时，client就傻了，就想改为select，但是我在网上找时都在讲如何有服务器端实现这个。我目前不想去动服务器端的程序。

kangear

不能select也就解决了。用while read就OK了。。

kangear

这个程序的原因在于读完一次就堵在第一个read处了。所以就不会再读了。

crazyhadoop

回复 3# kangear


    read 如果不设置非阻塞，就会阻塞知道读取到数据为止

kangear

crazyhadoop 发表于 2013-01-22 17:10
回复 3# kangear

哦，这样呀。