UNIX domain ( UNIX 预协议 ) 实例

winstar 2012-03-21

一般在我们自己的主机上通信的时候,前面也讲到过可以使用pipe,fifo,msg,共享内存之类,如果你想使用套接字的话,当然TCP/IP的套接字也是可以的,只要指定server的IP = 127.0.0.1 或者你的当前主机的实际接入网络的IP也是可以的!但是相对与此处的UNIX domain来说,在效率上可能会低一点点、、、

UNIX domain的实际操作和前面的TCP/IP中的实际的操作的框架流程是差不多的!只是其中的细节的变化要注意!

代码贴下:

server端:

  1. /* 
  2.     在主机之间的通信可以使用TCP/IP套接字进行通信, 
  3.     但是在实现的效率上是不如UNIX DOMAIN的,所以 
  4.     此处看看这个协议的处理! 
  5.      
  6.     其实实际操作中我们可以知道,与TCP/IP的操作流程 
  7.     是差不多的!只是在一些细节上的变化! 
  8. */  
  9.   
  10. #include <stdio.h>   
  11. #include <stdlib.h>   
  12. #include <errno.h>   
  13. #include <string.h>   
  14. #include <sys/types.h>   
  15. #include <sys/socket.h>   
  16. #include <sys/un.h>   
  17.   
  18. #define     FILE            "UNIX_DOMAIN"       //!> 有点像FIFO中的文件是吧,呵呵   
  19. #define     MAXSIZE     1024   
  20. #define     MAXBACK 100   
  21.   
  22. int main( int argc, char ** argv )  
  23. {  
  24.     int         listen_fd;  
  25.     int         conn_fd;  
  26.     int         len;  
  27.     char    recv[MAXSIZE];  
  28.     struct sockaddr_un  servaddr;  
  29.     struct sockaddr_un  childaddr;  
  30.   
  31.     unlink( FILE );         //!> 保证么有已经存在的文件   
  32.   
  33.     //!> establish the socket   
  34.         //!>    
  35.     if( ( listen_fd  = socket( AF_UNIX, SOCK_STREAM, 0 ) ) == -1 )  
  36.     {  
  37.         printf("Socket error : %d\n", errno);  
  38.         exit( EXIT_FAILURE );  
  39.     }  
  40.       
  41.     servaddr.sun_family=AF_UNIX;        //!> UNIX DOMAIN   
  42.         strncpy( servaddr.sun_path, FILEsizeof( servaddr.sun_path ) - 1 );  //!> FILE   
  43.       
  44.         //!> 绑定   
  45.         //!>   
  46.     if( bind( listen_fd, ( struct sockaddr * )&servaddr, sizeof( servaddr ) ) == -1 )  
  47.     {  
  48.         printf("Bind Error : %d\n", errno);  
  49.         close( listen_fd );  
  50.         unlink( FILE );  
  51.         exit( EXIT_FAILURE );  
  52.     }  
  53.       
  54.     //!> 监听   
  55.     //!>   
  56.     if( listen( listen_fd, MAXBACK ) == -1 )  
  57.     {  
  58.         printf("Listen error : %d\n", errno);  
  59.         close( listen_fd );  
  60.         unlink( FILE );  
  61.         exit( EXIT_FAILURE );  
  62.     }  
  63.       
  64.     len = sizeof( childaddr );  
  65.   
  66.     while( 1 )  
  67.     {  
  68.         //!> accept : 你懂得~   
  69.         if( ( conn_fd = accept( listen_fd, ( struct sockaddr *)&childaddr, &len ) ) == -1 )  
  70.         {  
  71.             printf("Accept Error : %d\n", errno);  
  72.             close( listen_fd );  
  73.             unlink( FILE );  
  74.             exit( EXIT_FAILURE );  
  75.         }  
  76.           
  77.         while( 1 )              //!> 可能连续读一个套接口上的内容!   
  78.         {  
  79.             memset( recv, 0, sizeof( recv ) );        
  80.             len = read( conn_fd, recv, sizeof( recv ) );  
  81.   
  82.             if( len == 0 )  
  83.             {  
  84.                 close( conn_fd );  
  85.                 break;  
  86.             }  
  87.             else if( len < 0 )  
  88.             {  
  89.                 printf("Read error...  : %d\n", errno);  
  90.                 unlink( FILE );  
  91.                 close( conn_fd );  
  92.                 close( listen_fd );  
  93.                 exit( EXIT_FAILURE );  
  94.             }  
  95.             else  
  96.             {  
  97.                 len = strlen( recv );  
  98.                 recv[len] = '\0';  
  99.                   
  100.                 write( conn_fd, recv, strlen( recv ) );  
  101.             }  
  102.         }  
  103.               
  104.     }  
  105.   
  106.     unlink( FILE );  
  107.     close( conn_fd );  
  108.     close( listen_fd );  
  109.   
  110.     return 0;  
  111. }  

相关推荐

ganyouxianjava / 0评论 2012-05-31