细说linux IPC（一）：基于socket的进程间通讯（上）

    【版权声明：尊重原创。转载请保留出处：blog.csdn.net/shallnet 或 .../gentleliu，文章仅供学习交流，请勿用于商业用途】
    在一个较大的project其中。通常都会有多个进程构成，各个功能是一个独立的进程在执行。

既然多个进程构成一个project，那么多个进程之间确定会存在一些信息交换或共享数据，这就涉及到进程间通讯。进程间通道有很是多种。比方有最熟悉网络编程中的socket、还有共享内存、消息队列、信号、管道等很是多方式。每一种方式都有本身的适用状况，在本系列文章中笔者将会对多种进程间通讯方式进行具体解释，一是对本身工做多年在这方面的经验作一个积累，二是将其分享给各位民工。也许还能从你们的拍砖其中获得意外收获。
 
socket网络编程可能使用得最多，经常常使用在网络上不一样主机之间的通讯。

事实上在同一主机内通讯也可以使用socket来完毕。socket进程通讯与网络通讯使用的是统一套接口，不过地址结构与某些參数不一样。在使用socket建立套接字时经过指定參数domain是af_inet（ipv4因特网域）或af_inet6（ipv6因特网域）或af_unix（unix域）来实现。
在笔者这一篇文章中曾有具体介绍建立socket通讯流程及基础知识。

http://blog.csdn.net/shallnet/article/details/17734919。
 
首先来看一下使用af_inet域以及本地环回地址来实现本地主机进程间通讯。
服务进程建立监听套接字：

int ser_afinet_listen(int port)
{
    int                 listenfd, on;
    struct sockaddr_in  seraddr;
 
    listenfd = socket(af_inet, sock_stream, 0);
    if (listenfd < 0) {
        fprintf(stderr, "socket: %s\n", strerror(errno));
        return -1;
    }
 
    on = 1;
    setsockopt(listenfd, sol_socket, so_reuseaddr, &on, sizeof(on));
 
    seraddr.sin_family = af_inet;
    seraddr.sin_port = port;
    seraddr.sin_addr.s_addr = htonl(inaddr_any);
 
    if (bind(listenfd, (struct sockaddr *)&seraddr, sizeof(struct sockaddr_in)) < 0) {
        fprintf(stderr, "bind: %s\n", strerror(errno));
        return -1;
    }
 
    if (listen(listenfd, sock_ipc_max_conn) < 0) {
        fprintf(stderr, "listen: %s\n", strerror(errno));
        return -1;
    }
 
    return listenfd;
}

服务进程处理链接请求例如如下：

int ser_accept(int listenfd)
{
    int                 connfd;
    struct sockaddr_un  cltaddr;
    ssize_t             recvlen, sendlen;
    char                buf[sock_ipc_max_buf];
    socklen_t           addrlen;
 
    addrlen = sizeof(cltaddr);
    for (;;) {
        connfd = accept(listenfd, (struct sockaddr *)&cltaddr, &addrlen);
        if (connfd < 0) {
            fprintf(stderr, "accept: %s\n", strerror(errno));
            return -1;
        }
 
        if (recvlen = ipc_recv(connfd, buf, sizeof(buf)) < 0) {
            continue;
        }
 
        printf("recv: %s\n", buf);
        snprintf(buf, sizeof(buf), "hello, ipc client!");
        if (ipc_send(connfd, buf, strlen(buf)) < 0) {
            continue;
        }
 
        close(connfd);
    }
}

客户进程初始化例如如下：
指定要链接的服务器地址为本地换回地址，这样发送的链接就会回到本地服务进程。

int clt_afinet_conn_init(int port)
{
    int                 fd;
 
    fd = socket(af_inet, sock_stream, 0);
    if (fd < 0) {
        fprintf(stderr, "socket: %s\n", strerror(errno));
        return -1;
    }
 
    seraddr.sin_family = af_inet;
    seraddr.sin_port = port;
    if (inet_pton(af_inet, "127.0.0.1", &seraddr.sin_addr) < 0) {//环回地址
        fprintf(stderr, "inet_pton: %s\n", strerror(errno));
        return -1;
    }
 
    return fd;
}

    客户进程向服务进程发送接收请求例如如下：

if (connect(fd, (struct sockaddr *)&seraddr, sizeof(struct sockaddr_in)) < 0) {
        fprintf(stderr,  "connect: %s\n", strerror(errno));
        return -1;
    }
 
    if ((sendlen = ipc_send(fd, buf, strlen(buf))) < 0) {
        return -1;
    }
 
    if ((recvlen = ipc_recv(fd, buf, sizeof(buf))) < 0) {
        return -1;
    }

服务进程先执行，客户进程执行：
# ./client
recv: hello, ipc client!
# ./server
recv: hello ipc server!
通讯过程完毕。

建立类型为af_unix（或af_local）的socket，表示用于进程通讯。

socket进程通讯与网络通讯使用的是统一套接口：

#include<sys/socket.h>
int socket(int domain, int type, int protocol);

其中，domain 參数指定协议族，对于本地套接字来讲，其值被置为 af_unix 枚举值，随便说一下，af_unix和af_local是同一个值，看如下linux/socket.h头文件部分例如如下，两个宏的值都同样为1。

……
/* supported address families. */
#define af_unspec       0
#define af_unix         1       /* unix domain sockets          */
#define af_local        1       /* posix name for af_unix       */
#define af_inet         2       /* internet ip protocol         */
#define af_ax25         3       /* amateur radio ax.25          */
……

以af_xx开头和pf_xx开头的域都是同样的。继续看头文件部份内容就一切都明确了：

……
#define pf_unspec       af_unspec
#define pf_unix         af_unix
#define pf_local        af_local
#define pf_inet         af_inet
#define pf_ax25         af_ax25
……

因此咱们在指定socket的类型时这四个域可以随便用啦，笔者这里统一使用af_unix了。

type 參数可被设置为 sock_stream（流式套接字）或 sock_dgram（数据报式套接字），对于本地套接字来讲，流式套接字（sock_stream）是一个有顺序的、可靠的双向字节流，至关于在本地进程之间创建起一条数据通道。数据报式套接字（sock_dgram）至关于单纯的发送消息。在进程通讯过程当中。理论上可能会有信息丢失、复制或者不按前后次序到达的状况，但由于其在本地通讯，不经过外界网络，这些状况出现的几率很是小。
本地套接字的通讯两方均需要具备本地地址，地址类型为 struct sockaddr_un结构体（位于linux/un.h）：

#ifndef _linux_un_h
#define _linux_un_h
 
#define unix_path_max   108
 
struct sockaddr_un {
        sa_family_t sun_family; /* af_unix */
        char sun_path[unix_path_max];   /* pathname */
};
 #endif /* _linux_un_h */

建立监听套接字：

int ser_afunix_listen(const char *pathname)
{
    int                 listenfd, on;
    struct sockaddr_un  seraddr;
 
    listenfd = socket(af_unix, sock_stream, 0);
    if (listenfd < 0) {
        fprintf(stderr, "socket: %s\n", strerror(errno));
        return -1;
    }
 
    unlink(pathname);
    seraddr.sun_family = af_unix;
    snprintf(seraddr.sun_path, sizeof(seraddr.sun_path), "%s", pathname);
 
    if (bind(listenfd, (struct sockaddr *)&seraddr, sizeof(struct sockaddr_un)) < 0) {
        fprintf(stderr, "bind: %s\n", strerror(errno));
        return -1;
    }
 
    if (listen(listenfd, sock_ipc_max_conn) < 0) {
        fprintf(stderr, "listen: %s\n", strerror(errno));
        return -1;
    }
 
    return listenfd;
}

服务进程处理链接请求类似上面网络通讯。
 
客户进程初始化套接字过程为：

int clt_afunix_conn_init(const char *pathname)
{
    int                 fd;
    struct sockaddr_un  localaddr;
 
    fd = socket(af_unix, sock_stream, 0);
    if (fd < 0) {
        fprintf(stderr, "socket: %s\n", strerror(errno));
        return -1;
    }
 
    localaddr.sun_family = af_unix;
    snprintf(localaddr.sun_path, sizeof(localaddr.sun_path), "%s-cltid%d", pathname, getpid());
 
    if (bind(fd, (struct sockaddr *)&localaddr, sizeof(struct sockaddr_un)) < 0) {
        fprintf(stderr, "bind: %s\n", strerror(errno));
        return -1;
    }
 
    seraddr.sun_family = af_unix;
    snprintf(seraddr.sun_path, sizeof(seraddr.sun_path), "%s", pathname);
 
    return fd;
}

客户进程向服务进程发送接收请求类似上面网络通讯。
执行结果同网络通讯部分。
本节只给出了一个很是easy的通讯程序，只简单实现了客户进程和服务进程之间的通讯。在下一节笔者将会在本节演示样例的基础上作改动，写一个在实际应用中可以使用的代码。
本节演示样例代码下载连接：
 http://download.csdn.net/detail/gentleliu/8140459