1.配置环境

    在这里下载unpv13e.tar.gz，其中包含了《UNIX网络编程》第一卷的源代码。假设将其移到~/Unix/Network/目录下，以下为配置过程（假设当前目录为下载目录）：

1. mv ./unpv13e.tar.gz ~/Unix/Network 
2.  
3.     cd ~/Unix/Network
4.  
5.     tar -zxvf unpv13e.tar.gz 
6.  
7.     cd unpv13e
8.  
9.     ./configure 
10.  
11.     cd lib 
12.  
13.     make 
14.  
15.     cd ../                  #back to unpv13e/ 
16.  
17.     cp libunp.a /usr/lib 
18.  
19.     cp libunp.a /usr/lib64
20.  
21.     cd ../                  #back to Network/ 
22.  
23.     cp ./unpv13e/lib/unp.h ./ 
24.  
25.     cp ./unpv13e/config.h ./ 
26.  
27.     vi unp.h #使用vi将unp.h中的 #include "../config.h"改为#include "./config.h" 
28.  
29.     mkdir timer_server 
30.  
31.     cd timer_server 

2.编写代码    

 编写服务端代码：

1. #include "../unp.h" 
2.  
3. int main(int argc,char *argv[]) 
4. { 
5.     int listenfd,connfd; 
6.     struct sockaddr_in servaddr; 
7.     char buff[MAXLINE]; 
8.     time_t ticks; 
9.     listenfd = Socket(AF_INET,SOCK_STREAM,0); 
10.     bzero(&servaddr,sizeof(servaddr)); 
11.     servaddr.sin_family = AF_INET; 
12.     servaddr.sin_addr.s_addr = htonl(INADDR_ANY); 
13.     servaddr.sin_port=htons(13); 
14.     Bind(listenfd,(SA*)&servaddr,sizeof(servaddr)); 
15.     Listen(listenfd,LISTENQ); 
16.     for(;;) 
17.     { 
18.         connfd = Accept(listenfd,(SA*)NULL,NULL); 
19.         ticks = time(NULL); 
20.         snprintf(buff,sizeof(buff),"%.24s\r\n",ctime(&ticks)); 
21.         Write(connfd,buff,strlen(buff)); 
22.         Close(connfd); 
23.     } 
24.     return 0; 
25. } 

      编写客户端代码：

1. #include "../unp.h" 
2.  
3. int main(int argc,char *argv[]) 
4. { 
5.     int socketfd,n; 
6.     char recvline[MAXLINE+1]; 
7.     struct sockaddr_in servaddr; 
8.     if(argc != 2) 
9.         err_quit("Usage:%s <IP Address>",argv[0]); 
10.     if( (socketfd = socket(AF_INET,SOCK_STREAM,0)) <0 ) 
11.         err_sys("socket error"); 
12.     bzero(&servaddr,sizeof(servaddr)); 
13.     servaddr.sin_family = AF_INET; 
14.     servaddr.sin_port = htons(13); 
15.     if( inet_pton(AF_INET,argv[1],&servaddr.sin_addr) <= 0) 
16.         err_quit("inet_pton error for %s .",argv[0]); 
17.     if(connect(socketfd,(SA*)&servaddr,sizeof(servaddr))<0) 
18.         err_sys("connecting error."); 
19.     while( (n = read(socketfd,recvline,MAXLINE))>0){ 
20.         recvline[n] = 0; 
21.         if(fputs(recvline,stdout) == EOF) 
22.             err_sys("read error"); 
23.     } 
24.     if(n<0) 
25.         err_sys("read error"); 
26.     return 0; 
27. } 

         编译运行：

1. $gcc server.c -o server -lunp 
2. $gcc client.c -o client -lunp 
3. $./server & 
4. $./client 192.168.101.71 
5. Mon Jul 16 17:37:45 2012 
6. $./client 192.168.101.71 
7. Mon Jul 16 17:37:47 2012 
8. $./client 192.168.101.71 
9. Mon Jul 16 17:37:47 2012 
10. $./client 192.168.101.71 
11. Mon Jul 16 17:37:49 2012  

      在读的时候有一个小技巧，就是使用循环的方式去读套接口中的数据而不是只读一次，这是由于需要的数据可能分成多节传过来。下面的代码将展示这一点：

1. #include "../unp.h" 
2.  
3. int main(int argc,char *argv[]) 
4. { 
5.     int socketfd,n; 
6.     char recvline[MAXLINE+1]; 
7.     struct sockaddr_in servaddr; 
8.     if(argc != 2) 
9.         err_quit("Usage:%s <IP Address>",argv[0]); 
10.     if( (socketfd = socket(AF_INET,SOCK_STREAM,0)) <0 ) 
11.         err_sys("socket error"); 
12.     bzero(&servaddr,sizeof(servaddr)); 
13.     servaddr.sin_family = AF_INET; 
14.     servaddr.sin_port = htons(13); 
15.     if( inet_pton(AF_INET,argv[1],&servaddr.sin_addr) <= 0) 
16.         err_quit("inet_pton error for %s .",argv[0]); 
17.     if(connect(socketfd,(SA*)&servaddr,sizeof(servaddr))<0) 
18.         err_sys("connecting error."); 
19.     int counter = 0; 
20.     while( (n = read(socketfd,recvline,MAXLINE))>0){ 
21.         recvline[n] = 0; 
22.         if(fputs(recvline,stdout) == EOF) 
23.             err_sys("read error"); 
24.         counter++; 
25.     } 
26.     printf("read operation :%d\n",counter); 
27.     if(n<0) 
28.         err_sys("read error"); 
29.     return 0; 
30. } 

        在循环中加入计数代码，用来统计计数的次数。然后我们将服务器端的代码改为for循环的形式：

1. #include "../unp.h" 
2.  
3. #include<string.h> 
4. int main(int argc,char *argv[]) 
5. { 
6.     int listenfd,connfd; 
7.     struct sockaddr_in servaddr; 
8.     char buff[MAXLINE]; 
9.     time_t ticks; 
10.     listenfd = Socket(AF_INET,SOCK_STREAM,0); 
11.     bzero(&servaddr,sizeof(servaddr)); 
12.     servaddr.sin_family = AF_INET; 
13.     servaddr.sin_addr.s_addr = htonl(INADDR_ANY); 
14.     servaddr.sin_port=htons(13); 
15.     Bind(listenfd,(SA*)&servaddr,sizeof(servaddr)); 
16.     Listen(listenfd,LISTENQ); 
17.     for(;;) 
18.     { 
19.         connfd = Accept(listenfd,(SA*)NULL,NULL); 
20.         ticks = time(NULL); 
21.         snprintf(buff,sizeof(buff),"%.24s\r\n",ctime(&ticks)); 
22.         int i = 0; 
23.         int len = strlen(buff); 
24.         for(i=0;i<len;i++) 
25.             Write(connfd,&buff[i],sizeof(char)); 
26.         Close(connfd); 
27.     } 
28.     return 0; 
29. } 

        下面为运行效果：

         

1. $ ./client 192.168.101.71 
2. Mon Jul 16 21:24:05 2012 
3. read operation :4 
4. $ ./client 192.168.101.71 
5. Mon Jul 16 21:24:05 2012 
6. read operation :4 
7. $ ./client 192.168.101.71 
8. Mon Jul 16 21:24:05 2012 
9. read operation :3 
10. $ ./client 192.168.101.71 
11. Mon Jul 16 21:24:06 2012 
12. read operation :4 
13. $ ./client 192.168.101.71 
14. Mon Jul 16 21:24:06 2012 
15. read operation :3 
16. $ ./client 192.168.101.71 
17. Mon Jul 16 21:24:07 2012 
18. read operation :5 

 

本文转自hipercomer 51CTO博客，原文链接:http://blog.51cto.com/hipercomer/932671