unix domain 中面向连接通信实现实例

 

使用套接字出了可以实现不同网络间主机的通信外，还可以实现同一主机的不同进程间的通信，且建立的通信时双向的通信。这里所指的使用套接字实现进程间通信，是由将通信域指定为PF_UNIX来实现的。下面是socket函数的具体消息定义，该函数的形式如下：

                            int socket(int domain, int type, int protocol);

socket函数中的domain用于指定通信域，domain参数取PF_UNIX时，表示创建UNIX域的套接字。使用PF_UNIX域的套接字可以实现同一机器上的不同进程间的通信。

调用bind函数现实了套接字与地址（这里是文件名）的绑定。bing函数的具体信息如下：

                             int bind(int sockfd, const struct sockaddr *my_addr, socklen_t addrlen);

其参数my_addr为指向结构体sockaddr_un的指针，该结构体的定义如下：

struct sockaddr_un{

          sa_family_t   sun_family; /* PF_UNIX或AF_UNIX*/

           char sun_path[108]; /*路径名*/

};

在该结构体中，sun_family 为AF_UNIX，sun_path是套接字在文件系统中的路径名。

1.1服务器端实现

程序serv.c为使用套接字在UNIX域内实现进程间通信的服务器端程序。首先，程序通过调用socket函数，建立了监听连接的套接字，然后调用bind函数，将套接字与地址信息关联起来。调用listen函数实现对该端口的监听，当有连接请求时，通过调用accept函数建立与客户端的连接，最后，通过调用read函数来读取客户机发送过来的消息，当然也可以使用recv函数实现相同的功能。serv.c具体代码如下：

//UNIX域通信代码实例，服务器端

#include

#include

#incude

#inlcude

//定义用于通信的文件名

#define UNIX_DOMAIN "/tmp/UNIX.domain"

int main()

{

int listen_fd;

int com_fd;

int ret;

int i;

static char recv_buf[1024];

int len;

struct sockaddr_un clt_addr;

socklen_t clt_addr_len;

struct sockaddr_un srv_addr;

//创建用于通信的套接字，通信域为UNIX通信域

listen_fd = socket(PF_UNIX, SOCK_STREAM, 0);

if(listen_fd<0){

perror("cannot creat listening socket");

return 1;

}

//设置服务器地址参数

srv_addr.sun_family = AF_UNIX;

strncpy(srv_addr.sun_path,UNIX_DOMAIN,sizeof(srv_addr.sun_path)-1);

unlink(UNIX_DOMAIN);

//绑定套接字与服务器地址信息

ret = bind(listen_fd,(struct sockaddr *)&srv_addr,sizeof(serv_addr));

if(ret ==-1）{

perror("cannot bind server socket");

close(listen_fd);

unlink(UNIX_DOMAIN);

return 1;

}

//对套接字进行监听

ret = listen(listen_fd,1);

if(ret == -1){

perror("cannot listen the client connect request");

close(listen_fd);

unlink(UNIX_DOMAIN);

return 1;

}

printf("begin listening");

//当有连接请求时，调用accept函数建立服务器与客户机之间的连接

len = sizeof(clt_addr);

com_fd = accept(listen_fd,(sruct sockaddr*)&clt_addr,&len);

if(com_fd < 0){

perror("cannot accept client connect request");

close(listen_fd);

unlink(UNIX_DOMAIN);

return 1;

}

//读取并输出客户端发送过来的连接信息

printf("\n========info=========\n");

for(i=0;i<4;i++){

memset(recv_buf,0 ,1024);

int num = read(com_fd,recv_buf,sizeof(recv_buf);

printf("message from client(%d)):%s\n",num,recv_buf）;

}

close(com_fd);

close(listen_fd);

unlink(UNIX_DOMAIN);

return 0;

}

1.2 客户端实现

clt.c为使用套接字在UNIX域内实现进程间通信的客户端程序。相比服务器端的程序，客户端较为简单程序首先通过调用socket函数建立通信所需的套接字，然后，调用connect函数来连接服务器，在成功建立连接后，通过调用write函数向服务器发送指定的消息，具体代码如下：

//clt.c UNIX域通信代码示例，客户端

#include

#include

#incude

#include

#define UNIX_DOMAIN "/tmp/UNIX.domain"

int main()

{

int connect_fd;

int ret;

int snd_buf[1024];

int i;

static struct sockaddr_un srv_addr;

connect_fd = socket(PF_UNIX,SOCK_STREAM, 0);

if (connect_fd <0){

perror("cannnot creat communication socket");

return 1;

}

srv_addr.sun_family = AF_UNIX;

strcpy(&srv_addr.sun_path, UNIX_DOMAIN);

ret = connect(connect_fd,(struct sockaddr*)&srv_addr,sizeof(srv_addr);

if(ret == -1){

perror("cannot connect to the server");

return 1;

}

memset(snd_buf, 0, 1024);

strcpy(snd_buf,"client");

for(i=0;i<4;i++)

write(connect_fd,snd_buf,sizeof(snd_buf);

close(connect_fd);

return 0;

}

1.3程序运行结果分析

使用gcc编译srv.c和clt.c，获得名为srv和clt的可执行文件。先执行srv程序，然后运行clt程序，具体输出如下：

[program@localhost charter13]$ gcc clt.c -o clt
[program@localhost charter13]$ gcc -o srv srv.c

[program@localhost charter13]$ ./srv &
[1] 13450
[program@localhost charter13]$ ./clt &
[2] 13451
[program@localhost charter13]$
=====info=====
Message from client (1024)) :message from client
Message from client (1024)) :message from client
Message from client (1024)) :message from client
Message from client (1024)) :message from client

[1]- Done                    ./srv
[2]+ Done                    ./clt
[program@localhost charter13]$

当运行srv程序后，该程序将处于监听状态。这时，可以通过netstat命令查看程序与你想那个情况：

netstat -an|grep /tmp