Chinaunix首页 | 论坛 | 博客
  • 博客访问: 122748
  • 博文数量: 25
  • 博客积分: 1465
  • 博客等级: 上尉
  • 技术积分: 270
  • 用 户 组: 普通用户
  • 注册时间: 2009-04-26 17:06
文章分类

全部博文(25)

文章存档

2011年(2)

2010年(8)

2009年(15)

我的朋友

分类: LINUX

2009-12-15 01:45:15

附录 A UNIX 域套接字

UNIX 域套接字以 UNIX 路径命名。例如,可以将套接字命名为 /tmp/foo。UNIX 域套接字只在一台主机上的进程之间通信。UNIX 域中的套接字不会被视为网络协议的一部分,因为它们只用于在一台主机上的进程之间通信。

套接字类型定义用户可见的通信属性。Internet 域套接字提供对 TCP/IP 传输协议的访问。Internet 域由值 AF_INET 标识。套接字仅与同一域中的套接字交换数据。

创建套接字

调用创建指定系列和指定类型的套接字。

s = socket(family, type, protocol);

如果未指定协议(值 0),则系统将选择支持所需套接字类型的协议。将返回套接字句柄(文件描述符)。

系列由 sys/socket.h 中定义的一个常量指定。名为 AF_suite 的常量指定要在解释名称时使用的地址格式。

下面创建在同一计算机内部使用的数据报套接字:

s = socket(AF_UNIX, SOCK_DGRAM, 0);

在大多数情况下,请将 protocol 参数设置为 0(即缺省协议)。

本地名称绑定

创建套接字时不带名称。只有在套接字绑定到地址之后,远程进程才能引用此套接字。通信进程通过地址连接。 在 UNIX 系列中,连接通常包括一个或两个路径名。UNIX 系列套接字无需始终绑定到名称。如果它们绑定到名称,则从不会存在绑定的重复排序组(如 local pathnameforeign pathname)。路径名不能涉及现有文件。

通过 调用,进程可以指定套接字的本地地址。这样会创建 local pathname 排序组,而 和 通过添加地址的远程部分来完成套接字的关联。可以按如下方式使用 :

bind (s, name, namelen);

套接字句柄为 s。绑定名称是由支持协议解释的字节字符串。UNIX 系列名称包含一个路径名和一个系列。本示例说明将名称 /tmp/foo 绑定到 UNIX 系列套接字。

#include 

 ...

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 套接字的大小时不计空字节,因此可以使用 。

addr.sun_path 中引用的文件名在系统文件名称空间中创建为套接字。调用方必须对创建 addr.sun_path 的目录具有写权限。不再需要文件时,调用方应将其删除。可以使用 删除 AF_UNIX 套接字。

建立连接

通常以非对称形式建立连接。一个进程用作客户机,而另一个进程则用作服务器。服务器将套接字绑定到与服务关联的已知地址,并阻塞在套接字上等待连接请求。然后,不相关的进程便可连接到此服务器。客户机通过启动到服务器套接字的连接,向服务器请求服务。在客户端, 调用启动连接。在 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);
}

阅读(2202) | 评论(0) | 转发(1) |
0

上一篇:tcpdump for arm .bin

下一篇:unix socket

给主人留下些什么吧!~~