理解unix域套接字.doc_咨信网zixin.com.cn

资源描述

unix域套接字 UNIX 域套接字以 UNIX 路径命名。例如，可以将套接字命名为 /tmp/foo。UNIX 域套接字只在一台主机上的进程之间通信。UNIX 域中的套接字不会被视为网络协议的一部分，因为它们只用于在一台主机上的进程之间通信。套接字类型定义用户可见的通信属性。Internet 域套接字提供对 TCP/IP 传输协议的访问。Internet 域由值 AF_INET 标识。套接字仅与同一域中的套接字交换数据。创建套接字 socket(3SOCKET) 调用创建指定系列和指定类型的套接字。 s = socket(family, type, protocol); 如果未指定协议（值 0），则系统将选择支持所需套接字类型的协议。将返回套接字句柄（文件描述符）。系列由 sys/socket.h 中定义的一个常量指定。名为 AF_suite 的常量指定要在解释名称时使用的地址格式。下面创建在同一计算机内部使用的数据报套接字： s = socket(AF_UNIX, SOCK_DGRAM, 0); 在大多数情况下，请将 protocol 参数设置为 0（即缺省协议）。本地名称绑定创建套接字时不带名称。只有在套接字绑定到地址之后，远程进程才能引用此套接字。通信进程通过地址连接。在 UNIX 系列中，连接通常包括一个或两个路径名。UNIX 系列套接字无需始终绑定到名称。如果它们绑定到名称，则从不会存在绑定的重复排序组（如 local pathname 或 foreign pathname）。路径名不能涉及现有文件。通过 bind(3SOCKET) 调用，进程可以指定套接字的本地地址。这样会创建 local pathname 排序组，而 connect(3SOCKET) 和 accept(3SOCKET) 通过添加地址的远程部分来完成套接字的关联。可以按如下方式使用 bind(3SOCKET)： bind (s, name, namelen); 套接字句柄为 s。绑定名称是由支持协议解释的字节字符串。UNIX 系列名称包含一个路径名和一个系列。本示例说明将名称 /tmp/foo 绑定到 UNIX 系列套接字。 #include <sys/un.h> ... struct sockaddr_un addr; ... strcpy(addr.sun_path, "/tmp/foo"); addr.sun_family = AF_UNIX; bind (s, (struct sockaddr *) &addr, strlen(addr.sun_path) + sizeof (addr.sun_family)); 确定 AF_UNIX 套接字的大小时不计空字节，因此可以使用 strlen(3C)。 addr.sun_path 中引用的文件名在系统文件名称空间中创建为套接字。调用方必须对创建 addr.sun_path 的目录具有写权限。不再需要文件时，调用方应将其删除。可以使用 unlink(1M) 删除 AF_UNIX 套接字。建立连接通常以非对称形式建立连接。一个进程用作客户机，而另一个进程则用作服务器。服务器将套接字绑定到与服务关联的已知地址，并阻塞在套接字上等待连接请求。然后，不相关的进程便可连接到此服务器。客户机通过启动到服务器套接字的连接，向服务器请求服务。在客户端，connect(3SOCKET) 调用启动连接。在 UNIX 系列中，此连接可能如下所示： struct sockaddr_un server; server.sun.family = AF_UNIX; ... connect(s, (struct sockaddr *)&server, strlen(server.sun_path) + sizeof (server.sun_family)); 有关连接错误的信息，请参见连接错误。数据传送介绍如何传送数据。关闭套接字介绍如何关闭套接字。 UNIX域流套接字例子： ----------------------------------------------------------------------------------- UNIX域面向连接 ----------------------------------------------------------------------------------- UNIX域面向连接的服务器端程序 #include<sys/types.h> #include<sys/socket.h> #include<sys/un.h> ...... #define NAME "my_sock" main() { int orig_sock, //服务器端原来套接字描述符 new_sock, //新的套接字描述符 clnt_len, //客户端地址长度 i; //循环计数器 static struct sockaddr_un clnt_adr, //客户-服务器的UNIX地址 serv_adr; static char buf[128]; //消息缓冲区 void clean_up(int , char *); //关闭套接字并删除例程 if((orig_sock = socket(AF_UNIX,SOCK_STREAM,0)) < 0) { peeror("generate error"); exit(1); } serv_adr.sun_family = AF_UNIX; strcpy(serv_adr.sun_path,NAME); unlink(NAME); if(bind(orig_sock, (struct sockaddr *)&serv_adr,sizeof(serv_adr.sun_family) +strlen(serv_adr.sun_path)) < 0) { peeror("bind error"); clean_up(orig_sock,NAME); exit(2); } listen(orig_sock,1); clnt_len = sizeof(clnt_adr); if((new_sock = accept (orig_sock,(struct sockaddr *)&clnt_adr,&clnt_len))<0) { peeror("accept error"); exit (3); } for(i =1;i<=10;i++) { sleep(1); read(new_sock,buf,sizeof(buf)); printf("%s\n\n",buf); } close(new_sock); clean_up(orig_sock,NAME); exit(0); } void clean_up(int sd,char * the_file) { close(sd); unlink(the_file); } UNIX域面向连接的客户端程序 #include<sys/types.h> #include<sys/socket.h> #include<sys/un.h> ...... #define NAME "my_sock" main() { int orig_sock, //客户端原来套接字描述符 i; //循环计数器 static struct sockaddr_un serv_adr; static char buf[10]; //消息缓冲区 if((orig_sock = socket(AF_UNIX,SOCK_STREAM,0)) < 0) { peeror("generate error"); exit(1); } serv_adr.sun_family = AF_UNIX; strcpy(serv_adr.sun_path,NAME); if(connect(orig_sock, (struct sockaddr *)&serv_adr,sizeof(serv_adr.sun_family) +strlen(serv_adr.sun_path)) < 0) { peeror("connect error"); exit(1); } for(i =1;i<=10;i++) { sprintf(buf,"c: %d\n\n",i); write(orig_sock,buf,sizeof(buf)); } close(orig_sock); exit(0); } Socket （UDP） ----------------------------------------------------------------------------------- UNIX域无连接 ----------------------------------------------------------------------------------- 服务器端程序 #include<stdio.h> #include<stdlib.h> #include<unistd.h> #include<string> #include<sys/types.h> #include<sys/socket.h> #include<sys/un.h> #define SERVER_FILE "server_socket" main(void) { int orig_sock, //服务器端原来套接字描述符 clnt_len, //客户端地址长度 i; //循环计数器 static struct sockaddr_un clnt_adr, //客户-服务器的UNIX地址 serv_adr; static char buf[128]; //消息缓冲区 void clean_up(int , char *); //关闭套接字并删除例程 if((orig_sock = socket(AF_UNIX,SOCK_DGRAM,0)) < 0) { peeror("generate error"); exit(1); } serv_adr.sun_family = AF_UNIX; strcpy(serv_adr.sun_path,SERVER_FLIE); //分配名字 unlink(SERVER_FLIE); if(bind(orig_sock, (struct sockaddr *)&serv_adr,sizeof(serv_adr.sun_family) +strlen(serv_adr.sun_path)) < 0) { peeror("bind error"); clean_up(orig_sock,SERVER_FLIE); exit(2); } for(i =1;i<=10;i++) { recvfrom(orig_sock,buf,sizeof(buf),0,(struct sockaddr *)&clnt_adr,&clnt_len); printf("%s\n\n",buf); } clean_up(orig_sock,SERVER_FLIE); exit(0); } void clean_up(int sd,char * the_file) { close(sd); unlink(the_file); } 客户端代码 #include<stdio.h> #include<stdlib.h> #include<unistd.h> #include<string> #include<sys/types.h> #include<sys/socket.h> #include<sys/un.h> #define SERVER_FILE "server_socket" main(void) { int orig_sock, i; static struct sockaddr_un clnt_adr, serv_adr; static char buf[128]; //消息缓冲区 client_flie[15]; void clean_up(int , char *); //关闭套接字并删除例程 serv_adr.sun_family = AF_UNIX; strcpy(serv_adr.sun_path,SERVER_FLIE); //分配名字 if((orig_sock = socket(AF_UNIX,SOCK_DGRAM,0)) < 0) { peeror("generate error"); exit(1); } sprintf(client_file,"%07d_socket",getpid()); clnt_adr.sun_family = AF_UNIX; strcpy(clnt_adr.sun_path,client_file); if(bind(orig_sock, (struct sockaddr *)&clnt_adr,sizeof(clnt_adr.sun_family) +strlen(clnt_adr.sun_path)) < 0) { peeror("bind error"); exit(2); } for(i =1;i<=10;i++) { sleep(1); sprintf(buf,"c: %d\n\n",i); sendto(orig_sock,buf,sizeof(buf),0,(struct sockaddr *)&serv_adr,sizeof(struct sockaddr)); } clean_up(orig_sock,client_file); exit(0); } void clean_up(int sd,char * the_file) { close(sd); unlink(the_file); }

展开阅读全文