socket在主机间和进程间使用，方法类似，主要区别是进程间通信使用的是sockaddr_un，而主机间的通信使用的是sockadd_in。

每个套接字都有其自己的地址格式，对于AF_UNIX域套接字来说，它的地址由结构sockaddr_un来描述，该结构定义在头文件sys/un.h中，它的定义如下：

struct sockaddr_un {

__kernel_sa_family_t sun_family; /* AF_UNIX */

char sun_path[UNIX_PATH_MAX]; /* pathname */

};

对于AF_INET域套接字来说，它的地址结构由sockaddr_in来描述，它至少包括以下几个成员：

struct sockaddr_in {

__kernel_sa_family_t sin_family; /* Address family */

__be16 sin_port; /* Port number */

struct in_addr sin_addr; /* Internet address */

/* Pad to size of `struct sockaddr'. */

unsigned char __pad[__SOCK_SIZE__ - sizeof(short int) -

sizeof(unsigned short int) - sizeof(struct in_addr)];

};

使用socket作为进程间通信方式，有什么注意事项?

(1) Server

a. 创建一个server socket

创建的socket是AF_UNIX域的。

b. 设置Server的地址

利用bind函数。

注意：地址一般通过一个字符串来标识，一般的做法是通过一个Linux路径来实现;注意使用之前必须要把该路径unlink掉，否则可能出现bind失败的情况。

c. 开始监听

利用listen函数。

注意：最大监听的长度为128.

d. 接收连接

利用accept函数。

注意：accept函数默认为阻塞模式。有一个可以设置非阻塞的为accept4函数;

在accept函数阻塞的过程中，一些信号对打断accept的阻塞，这是正常现象。因此如果要设置一直阻塞，需要考虑这种情况。

e. 接收数据

利用recv()函数

注意：recv函数是在accept新生成的socket上接收消息。recv()函数可以工作在阻塞模式，也可以工作在非阻塞模式。一般都是阻塞模式。新生成的socket注意要关闭。

(2) client

a. 创建

注意域为AF_UNIX。

b. 连接服务器:connect调用

注意：connect为非阻塞模式，需要增加重试机制保证可靠性。

c. 发送数据：send

注意：该调用可以是阻塞的，也可以是非阻塞的，最好设置为非阻塞模式，默认为阻塞模式。另外，可以调用setsockopt()来设置阻塞时长。level:SOL_SOCKET,SO_SNDTIMEO。

例子如下：

server

#include

#include

#include

#include

#include

#include

#include

#include

#include

typedef struct sockaddr SA;

int main(int argc, const char *argv[])

{

//1.定义变量

int sockfd, clientfd;

socklen_t addrlen = sizeof(SA);

struct sockaddr_un addr;

ssize_t nbytes;

char buf[32] = {0};

//2.创建本地套接字接口

sockfd = socket(AF_UNIX, SOCK_STREAM, 0);

if(sockfd < 0){

perror("socket err");

exit(-1);

}

//3.填充本地地址信息

bzero(&addr, addrlen);

addr.sun_family = AF_UNIX;

strcpy(addr.sun_path, "unix_sock");

//4.绑定本地套接字

remove("unix_sock");

if(bind(sockfd, (struct sockaddr *)&addr, addrlen) < 0){

perror("bind err");

exit(-1);

}

//5.监听套接字

if(listen(sockfd, 5) < 0){

perror("listen err");

exit(-1);

}

//6.接收连接

clientfd = accept(sockfd, NULL, NULL);

while(1)

{

//7.接收客户端数据

nbytes = recv(clientfd, buf, 32, 0);

if(nbytes < 0){

perror("recv err");

exit(-1);

}else if (nbytes == 0) {

printf("peer exit\n");

break;

}else{

printf("recv data = %s\n", buf);

}

}

//8.关闭套接字

close(clientfd);

close(sockfd);

}

client

#include

#include

#include

#include

#include

#include

#include

#include

#include

typedef struct sockaddr SA;

int main(int argc, const char *argv[])

{

//1.定义变量

int sockfd;

socklen_t addrlen = sizeof(SA);

struct sockaddr_un addr;

char buf[32] = {0};

//2.创建本地套接字接口

sockfd = socket(AF_UNIX, SOCK_STREAM, 0);

if(sockfd < 0){

perror("socket err");

exit(-1);

}

//3.填充服务器的地址信息

bzero(&addr, addrlen);

addr.sun_family = AF_UNIX;

strcpy(addr.sun_path, "unix_sock");

//4.连接服务器

if(connect(sockfd, (struct sockaddr *)&addr, addrlen) < 0){

perror("connect err");

exit(-1);

}

//5.收发数据

while (1) {

gets(buf);

send(sockfd, buf, 32, 0);

}

//6.关闭套接字

close(sockfd);

}