【fireprime】Socket进程通信：CS走起

caizhiwei

首先搭载一个server：

1. #include <stdio.h>  
   
2. #include <sys/types.h>  
   
3. #include <sys/socket.h>  
   
4. #include <sys/un.h>   
   
5. #include <linux/kernel.h>
   
6. #define UNIX_DOMAIN "/tmp/UNIX.domain"  
   
7. 
   
8. 
   
9. int main(void)  
   
10. {  
    
11.     socklen_t clt_addr_len;  
    
12.     int listen_fd;  
    
13.     int com_fd;  
    
14.     int ret;  
    
15.     int i;  
    
16.     static char recv_buf[1024];   
    
17.     int len;  
    
18.     struct sockaddr_un clt_addr;  
    
19.     struct sockaddr_un srv_addr;  
    
20.     listen_fd=socket(PF_UNIX,SOCK_STREAM,0);  
    
21.     if(listen_fd<0)  
    
22.     {  
    
23.         perror("cannot create communication socket");  
    
24.         return 1;  
    
25.     }   
    
26.       
    
27.     //set server addr_param  
    
28.     srv_addr.sun_family=AF_UNIX;  
    
29.     strncpy(srv_addr.sun_path,UNIX_DOMAIN,sizeof(srv_addr.sun_path)-1);  
    
30.     unlink(UNIX_DOMAIN);  
    
31.     //bind sockfd & addr  
    
32.     ret=bind(listen_fd,(struct sockaddr*)&srv_addr,sizeof(srv_addr));  
    
33.     if(ret==-1)  
    
34.     {  
    
35.         perror("cannot bind server socket");  
    
36.         close(listen_fd);  
    
37.         unlink(UNIX_DOMAIN);  
    
38.         return 1;  
    
39.     }  
    
40.     //listen sockfd   
    
41.     ret=listen(listen_fd,1);  
    
42.     if(ret==-1)  
    
43.     {  
    
44.         perror("cannot listen the client connect request");  
    
45.         close(listen_fd);  
    
46.         unlink(UNIX_DOMAIN);  
    
47.         return 1;  
    
48.     }  
    
49.     //have connect request use accept  
    
50.     len=sizeof(clt_addr);  
    
51.     com_fd=accept(listen_fd,(struct sockaddr*)&clt_addr,&len);  
    
52.        
    
53.     if(com_fd<0)  
    
54.     {  
    
55.         perror("cannot accept client connect request");  
    
56.         close(listen_fd);  
    
57.         unlink(UNIX_DOMAIN);  
    
58.         return 1;  
    
59.     }  
    
60.     //read and printf sent client info  
    
61.         printf("\n *******  print client info ****\n");
    
62.     for(; ;)  
    
63.     {  
    
64.         memset(recv_buf,0,1024);  
    
65.         int num=read(com_fd,recv_buf,sizeof(recv_buf));  
    
66.         perror("Receive Message");   
    
67.                 printf("Message from client (%d) :%s \n",num,recv_buf);   
    
68.     }  
    
69.     //close(com_fd);  
    
70.    // close(listen_fd);  
    
71.    // unlink(UNIX_DOMAIN);  
    
72.     return 0;  
    
73. }
    

复制代码

然后在搞一个client：

1. #include <stdio.h>  
   
2. #include <sys/types.h>  
   
3. #include <sys/socket.h>  
   
4. #include <sys/un.h>  
   
5. #include <linux/kernel.h>
   
6. #define UNIX_DOMAIN "/tmp/UNIX.domain"  
   
7. int main(void)  
   
8. {  
   
9.     int connect_fd;  
   
10.     int ret;  
    
11.     char snd_buf[1024];  
    
12.     int i;  
    
13.     static struct sockaddr_un srv_addr;  
    
14.        
    
15.    //creat unix socket  
    
16.     connect_fd=socket(PF_UNIX,SOCK_STREAM,0);  
    
17.     if(connect_fd<0)  
    
18.     {  
    
19.         perror("cannot create communication socket");  
    
20.         return 1;  
    
21.     }     
    
22.     srv_addr.sun_family=AF_UNIX;  
    
23.     strcpy(srv_addr.sun_path,UNIX_DOMAIN);  
    
24.        
    
25.    //connect server  
    
26.     ret=connect(connect_fd,(struct sockaddr*)&srv_addr,sizeof(srv_addr));  
    
27.     if(ret==-1)  
    
28.     {  
    
29.         perror("cannot connect to the server");  
    
30.         close(connect_fd);  
    
31.         return 1;  
    
32.     }  
    
33.     memset(snd_buf,0,1024);  
    
34.     strcpy(snd_buf,"Hello,I am client");  
    
35. //send info server  
    
36.     for(i =0;i <5; i++)
    
37.         {
    
38.                 perror("send message");
    
39.         write(connect_fd,snd_buf,sizeof(snd_buf));  
    
40.                 sleep(2);
    
41.      }
    
42.     close(connect_fd);  
    
43.     return 0;  
    
44. }  
    

复制代码

最后编译运行跑起来，哈哈，makefile走起！

1. server:server.c
   
2.         gcc -o  server server.c
   
3. client:client.c
   
4.         gcc -o client client.c
   
5. .PHONY:clean
   
6. clean:
   
7.         -rm -rf server client
   
8.        

复制代码

运行：

caizhiwei

6666，顶起来~·6666，顶起来~·

_烟酒僧_

火急火燎地赶来顶贴 ，哔了狗了   ……

chifen

路过。。。。。。。。。。。

caizhiwei

wudianjun2001 发表于 2015-12-7 15:23
路过看看。。。。。

:victory求助指点