基于套接字（TCP/IP）通信的 Linux 进程间通信方法
一、进程
1.进程概念
对于操作系统而言，每运行一个程序，系统会创建一个进程，在这个过程中，进行资源分配和调度。
2.进程通信
由于在操作系统内部，不同进程间相互独立运作，其内部资源独立，在特殊需求下要求进程间相互通信，而进程通信便是进程间进行信息交流和同步的机制。
3.进程通信原理
每个进程的用户地址空间都是独立的，一般而言是不能互相访问的，但内核空间是每个进程都共享的，所以进程之间要通信必须通过内核。如图1所示：
二、Socket基于TCP/IP通信模型
Socket通信不仅可以跨网络与不同主机的进程间通信，还可以在同主机上进程间通信。
1.不同主机间的通信流程。
如图2所示。
第一步：服务端和客户端各自初始化socket。
int socket(int domain, int type, int protocal)
详细介绍创建socket方法：
domain：即协议域，又称为协议族，常用的协议族有AF_INET、AF_INET6、AF_LOCAL（或称AF_UNIX，Unix域socket）、AF_ROUTE等。
协议族决定了socket的地址类型，在通信中必须采用对应的地址，如AF_INET决定了要用ipv4地址（32位的）与端口号（16位的）的组合、AF_UNIX决定了要用一个绝对路径名作为地址。
type：指定socket类型。常用的socket类型：SOCK_STREAM、SOCK_DGRAM、SOCK_RAW、SOCK_PACKET、SOCK_SEQPACKET等。
protocol：指定协议。常用的协议：IPPROTO_TCP、IPPTOTO_UDP、IPPROTO_SCTP、IPPROTO_TIPC等，它们分别对应TCP传输协议、UDP传输协议、STCP传输协议、TIPC传输协议。
根据type和protocol组合的不同又分为SOCK_STREAM和SOCK_SEQPACKET是面向链接的类型，因此protocol也应该选择面向链接的tcp协议。当protocol为0时，会自动选择type对应的默认协议。
第二步骤：服务端绑定IP地址和端口。
int bind(int socket, const struct sockaddr *address, socklen_t address_len)
sockfd：是通过socket()函数创建的唯一标识一个socket。bind()函数就是给这个描述字绑定一个名字。
addr：指向要绑定给sockfd的协议地址。这个地址结构根据地址创建socket时的地址协议族的不同而不同，如ipv4对应的是：
struct sockaddr_in {
sa_family_t sin_family; /* address family: AF_INET */
in_port_t sin_port; /* port in network byte order */
struct in_addr sin_addr; /* internet address */
};
/* Internet address. */
struct in_addr {
uint32_t s_addr; /* address in network byte order */
};
第三步：服务端进行监听；
int listen(int sockfd, int backlog)
第四步：服务端调用accept，客户端调用 connect，建立链接。
int accept(int sockfd,struct sockaddr *addr,socklen_t *addrlen)
int connect (int sockfd,struct sockaddr * serv_addr,int addrlen);
第五步：客户端调用send写入数据；服务端调用 recv读取数据。
int connect (int sockfd,struct sockaddr * serv_addr,int addrlen);
int recv( SOCKET s, char FAR *buf, int len, int flags);
2.同主机内部进程间的通信
UNIX Domain Socket是在socket的框架上发展出一种IPC机制，尽管网络socket只要将lookback地址设置为127.0.0.1，便能进行同一台主机的进程间通讯，但是UNIX Domain Socket用于IPC更有效率：不需要经过网络协议栈，不需要打包拆包、计算校验和、维护序号和应答等，只是将应用层数据从一个进程拷贝到另一个进程。UNIX Domain Socket在通信流程上与socket流程保持一致，但是部分有所区别。
SOCK_STREAM 式本地套接字的通信双方均需要具有本地地址，其中服务器端的本地地址需要明确指定，指定方法是使用 struct sockaddr_un 类型的变量。
#define UNIX_PATH_MAX 108
struct sockaddr_un {
sa_family_t sun_family; /* AF_UNIX */
char sun_path[UNIX_PATH_MAX]; /* pathname */
};
需要注意的是其socket进程通信命名方式有两种：
第一种是普通的命名：
//name the server socket
server_addr.sun_family = AF_UNIX;
strcpy(server_addr.sun_path,"/tmp/UNIX.domain");
server_len = sizeof(struct sockaddr_un);
client_len = server_len;1
第二种是抽象命名空间：
#define SERVER_NAME @socket_server
//name the socket
server_addr.sun_family = AF_UNIX;
strcpy(server_addr.sun_path, SERVER_NAME);
server_addr.sun_path[0]=0;
//server_len = sizeof(server_addr);
server_len = strlen(SERVER_NAME) + offsetof(struct sockaddr_un, sun_path);
二、代码采用同主机的进程通信方式，即UNIX Domain Socket方式。
以下部分主要代码：
客户端源文件：
#include "mainwindow.h"
#include "ui_mainwindow.h"
#include<qdebug.h>
extern "C"
{
#include <sys/types.h>
#include <sys/un.h>
#include <sys/socket.h>
#include <stdio.h>
#include <unistd.h>
#include <errno.h>
}
MainWindow::MainWindow()
{
}
void MainWindow::thread_run()
{
while(1)
{
sleep(1);
if(_need_to_connect)// 需要重连接
{
qDebug()<<"client thread";
_deconstruct_socket();
_construct_socket();
}
else
{
senddata();
}
}
}
void MainWindow::senddata()
{
char snd_buf[1024];
qDebug()<<"client connect sucessful!";
memset(snd_buf,0,1024);
strcpy(snd_buf,"the message sended 户!");
//send info server
ssize_t len=write(_sockfd,snd_buf,sizeof(snd_buf));
if(len<=0)
{
perror("send data error!");
_need_to_connect=true;
}
}
int MainWindow::_construct_socket()
{
if(-1 != _sockfd)
{
return FORK_CTRL_RET_SOCK_ERR;
}
struct sockaddr_un addr;
socklen_t addr_len(sizeof(addr));
int ret(-1);
// 设置阻塞方式send的超时
struct timeval send_timeout = {1, 0}; //1秒
// 设置阻塞方式connect的超时
struct timeval connect_timeout = {5, 0}; // 5秒
// socket
_sockfd = socket(AF_UNIX, SOCK_STREAM, 0);
if(-1 == _sockfd)
{
return FORK_CTRL_RET_SOCK_ERR;
}
addr.sun_family = AF_UNIX;
strncpy(addr.sun_path, SOCK_PROTECT, sizeof(addr.sun_path));
// 设置阻塞方式下的connect超时
setsockopt(_sockfd, SOL_SOCKET, SO_SNDTIMEO,
(char *)&connect_timeout, sizeof(struct timeval));
// send是在Mx主线程中执行的，设置阻塞方式下的send超时
setsockopt(_sockfd, SOL_SOCKET, SO_SNDTIMEO,
(char *)&send_timeout, sizeof(struct timeval));
// connect
ret = connect(_sockfd, (struct sockaddr *)&addr, addr_len);
if(-1 == ret)
{
return FORK_CTRL_RET_SOCK_ERR;
}
qDebug()<<"client connect succes!";
// 设置为非阻塞工作模式，必须等到connect返回以后再设置。
//fcntl(_sockfd, F_SETFL, O_NONBLOCK);
_need_to_connect = false;
return FORK_CTRL_RET_SUCCESS;
}
/******************************************************************************
释放和守护进程通信的socket及相关资源
******************************************************************************/
void MainWindow::_deconstruct_socket()
{
::close(_sockfd);
// 即使sockfd为-1也没关系。
_sockfd = -1;
sleep(3);
// 关闭socket后需要休眠，以确保网络资源的释放
return;
}
MainWindow::~MainWindow()
{
}
服务端源文件：
#include "mainwindow.h"
#include "ui_mainwindow.h"
#include<qdebug.h>
extern "C"
{
#include <sys/types.h>
#include <sys/un.h>
#include <sys/socket.h>
#include <stdio.h>
#include <unistd.h>
#include <errno.h>
}
MainWindow::MainWindow()
{
_need_to_connect=true;
_accept_fd=-1;
_sockfd=-1;
}
void MainWindow::thread_run()
{
while(1)
{
sleep(1);
if(_need_to_connect) //需要重连接
{
//QDebug("1111111111111111");
qDebug()<<"sever";
_deconstruct_socket();
_construct_socket();
}
else
{
getdata();
senddata();
}
}
}
void MainWindow::senddata()
{
char snd_buf[1024];
memset(snd_buf,0,1024);
strcpy(snd_buf,"it's ddddddddd!");
//send info server
qDebug()<<"dddddddd";
ssize_t len=write(_accept_fd,snd_buf,sizeof(snd_buf));
qDebug()<<"sever fd="<<_accept_fd;
//debug("client is sending data !\n");
}
void MainWindow::getdata()
{
char recv_buf[1024];
memset(recv_buf,0,1024);
int num=read(_accept_fd,recv_buf,sizeof(recv_buf));
//printf("Message from client (%d)) :%s/n",num,recv_buf);
qDebug()<<"receive data len="<<num;
if(num<=0)
{
unlink(SOCK_PROTECT);
_need_to_connect=true;
return;
}
qDebug()<<"see:"<<recv_buf;
}
int MainWindow::_construct_socket()
{
if(-1 != _sockfd)
{
return FORK_CTRL_RET_SOCK_ERR;
}
struct sockaddr_un addr;
socklen_t addr_len(sizeof(addr));
struct sockaddr_un clt_addr;
socklen_t clt_addr_len(sizeof(clt_addr));
int ret(-1);
//设置阻塞方式send的超时
struct timeval send_timeout = {1, 0}; //1秒
//设置阻塞方式connect的超时
struct timeval connect_timeout = {5, 0}; // 5秒
// socket
_sockfd = socket(AF_UNIX, SOCK_STREAM, 0);
if(-1 == _sockfd)
{
return FORK_CTRL_RET_SOCK_ERR;
}
unlink(SOCK_PROTECT);
addr.sun_family = AF_UNIX;
strncpy(addr.sun_path, SOCK_PROTECT, sizeof(addr.sun_path));
qDebug()<<"sever connecting!";
#if 1
ret=bind(_sockfd,(struct sockaddr*)&addr,sizeof(addr));
if(ret==-1)
{
unlink(SOCK_PROTECT);
return FORK_CTRL_RET_SOCK_ERR;
}
//listen sockfd
ret=listen(_sockfd,1);
if(ret==-1)
{
unlink(SOCK_PROTECT);
return FORK_CTRL_RET_SOCK_ERR;
}
qDebug()<<"server waiting!";
//have connect request use accept
_accept_fd=accept(_sockfd,(struct sockaddr*)&clt_addr,&clt_addr_len);
qDebug()<<"server connect succes!";
if(_accept_fd<0)
{
unlink(SOCK_PROTECT);
return FORK_CTRL_RET_SOCK_ERR;
}
#endif
qDebug()<<"sever connect sucessful!";
//设置为非阻塞工作模式，必须等到connect返回以后再设置。
//fcntl(_sockfd, F_SETFL, O_NONBLOCK);
_need_to_connect = false;
return FORK_CTRL_RET_SUCCESS;
}
/******************************************************************************
释放和守护进程通信的socket及相关资源
******************************************************************************/
void MainWindow::_deconstruct_socket()
{
::close(_sockfd);//即使sockfd为-1也没关系。
_sockfd = -1;
::close(_accept_fd);//即使sockfd为-1也没关系。
_accept_fd = -1;
sleep(3);//关闭socket后需要休眠，以确保网络资源的释放
return;
}
MainWindow::~MainWindow()
{
}
下一篇： 使用命名管道进行进程间通信
推荐阅读
-
Linux 进程间通信 - 使用流套接字
-
Linux 编程中常用的进程间通信方法：互斥锁和条件变量、共享内存和信号。
-
基于套接字（TCP/IP）通信的 Linux 进程间通信方法
-
windows下进程间通信的（13种方法）-摘 要 本文讨论了进程间通信与应用程序间通信的含义及相应的实现技术，并对这些技术的原理、特性等进行了深入的分析和比较。 ---- 关键词 信号 管道 消息队列 共享存储段 信号灯 远程过程调用 Socket套接字 MQSeries 1 引言 ---- 进程间通信的主要目的是实现同一计算机系统内部的相互协作的进程之间的数据共享与信息交换，由于这些进程处于同一软件和硬件环境下，利用操作系统提供的的编程接口，用户可以方便地在程序中实现这种通信；应用程序间通信的主要目的是实现不同计算机系统中的相互协作的应用程序之间的数据共享与信息交换，由于应用程序分别运行在不同计算机系统中，它们之间要通过网络之间的协议才能实现数据共享与信息交换。进程间通信和应用程序间通信及相应的实现技术有许多相同之处，也各有自己的特色。即使是同一类型的通信也有多种的实现方法，以适应不同情况的需要。 ---- 为了充分认识和掌握这两种通信及相应的实现技术，本文将就以下几个方面对这两种通信进行深入的讨论：问题的由来、解决问题的策略和方法、每种方法的工作原理和实现、每种实现方法的特点和适用的范围等。 2 进程间的通信及其实现技术 ---- 用户提交给计算机的任务最终都是通过一个个的进程来完成的。在一组并发进程中的任何两个进程之间，如果都不存在公共变量，则称该组进程为不相交的。在不相交的进程组中，每个进程都独立于其它进程，它的运行环境与顺序程序一样，而且它的运行环境也不为别的进程所改变。运行的结果是确定的，不会发生与时间相关的错误。 ---- 但是，在实际中，并发进程的各个进程之间并不是完全互相独立的，它们之间往往存在着相互制约的关系。进程之间的相互制约关系表现为两种方式： ---- （1） 间接相互制约：共享CPU ---- （2） 直接相互制约：竞争和协作 ---- 竞争——进程对共享资源的竞争。为保证进程互斥地访问共享资源，各进程必须互斥地进入各自的临界段。 ---- 协作——进程之间交换数据。为完成一个共同任务而同时运行的一组进程称为同组进程，它们之间必须交换数据，以达到协作完成任务的目的，交换数据可以通知对方可以做某事或者委托对方做某事。 ---- 共享CPU问题由操作系统的进程调度来实现，进程间的竞争和协作由进程间的通信来完成。进程间的通信一般由操作系统提供编程接口，由程序员在程序中实现。UNIX在这个方面可以说最具特色，它提供了一整套进程间的数据共享与信息交换的处理方法——进程通信机制（IPC）。因此，我们就以UNIX为例来分析进程间通信的各种实现技术。 ---- 在UNIX中，文件（File）、信号（Signal）、无名管道（Unnamed Pipes）、有名管道（FIFOs）是传统IPC功能；新的IPC功能包括消息队列（Message queues）、共享存储段（Shared memory segment）和信号灯（Semapores）。 ---- （1） 信号 ---- 信号机制是UNIX为进程中断处理而设置的。它只是一组预定义的值，因此不能用于信息交换，仅用于进程中断控制。例如在发生浮点错、非法内存访问、执行无效指令、某些按键（如ctrl-c、del等）等都会产生一个信号，操作系统就会调用有关的系统调用或用户定义的处理过程来处理。 ---- 信号处理的系统调用是signal，调用形式是： ---- signal(signalno,action) ---- 其中，signalno是规定信号编号的值，action指明当特定的信号发生时所执行的动作。 ---- （2） 无名管道和有名管道 ---- 无名管道实际上是内存中的一个临时存储区，它由系统安全控制，并且独立于创建它的进程的内存区。管道对数据采用先进先出方式管理，并严格按顺序操作，例如不能对管道进行搜索，管道中的信息只能读一次。 ---- 无名管道只能用于两个相互协作的进程之间的通信，并且访问无名管道的进程必须有共同的祖先。 ---- 系统提供了许多标准管道库函数，如： pipe——打开一个可以读写的管道； close——关闭相应的管道； read——从管道中读取字符； write——向管道中写入字符； ---- 有名管道的操作和无名管道类似，不同的地方在于使用有名管道的进程不需要具有共同的祖先，其它进程，只要知道该管道的名字，就可以访问它。管道非常适合进程之间快速交换信息。 ---- （3） 消息队列（MQ） ---- 消息队列是内存中独立于生成它的进程的一段存储区，一旦创建消息队列，任何进程，只要具有正确的的访问权限，都可以访问消息队列，消息队列非常适合于在进程间交换短信息。 ---- 消息队列的每条消息由类型编号来分类，这样接收进程可以选择读取特定的消息类型——这一点与管道不同。消息队列在创建后将一直存在，直到使用msgctl系统调用或iqcrm -q命令删除它为止。 ---- 系统提供了许多有关创建、使用和管理消息队列的系统调用，如： ---- int msgget(key,flag)——创建一个具有flag权限的MQ及其相应的结构，并返回一个唯一的正整数msqid（MQ的标识符）； ---- int msgsnd(msqid,msgp,msgsz,msgtyp,flag)——向队列中发送信息； ---- int msgrcv(msqid,cmd,buf)——从队列中接收信息； ---- int msgctl(msqid,cmd,buf)——对MQ的控制操作； ---- （4） 共享存储段（SM） ---- 共享存储段是主存的一部分，它由一个或多个独立的进程共享。各进程的数据段与共享存储段相关联，对每个进程来说，共享存储段有不同的虚拟地址。系统提供的有关SM的系统调用有： ---- int shmget(key,size,flag)——创建大小为size的SM段，其相应的数据结构名为key，并返回共享内存区的标识符shmid； ---- char shmat(shmid,address,flag)——将当前进程数据段的地址赋给shmget所返回的名为shmid的SM段； ---- int shmdr(address)——从进程地址空间删除SM段； ---- int shmctl (shmid,cmd,buf)——对SM的控制操作； ---- SM的大小只受主存限制，SM段的访问及进程间的信息交换可以通过同步读写来完成。同步通常由信号灯来实现。SM非常适合进程之间大量数据的共享。 ---- （5） 信号灯 ---- 在UNIX中，信号灯是一组进程共享的数据结构，当几个进程竞争同一资源时（文件、共享内存或消息队列等），它们的操作便由信号灯来同步，以防止互相干扰。 ---- 信号灯保证了某一时刻只有一个进程访问某一临界资源，所有请求该资源的其它进程都将被挂起，一旦该资源得到释放，系统才允许其它进程访问该资源。信号灯通常配对使用，以便实现资源的加锁和解锁。 ---- 进程间通信的实现技术的特点是：操作系统提供实现机制和编程接口，由用户在程序中实现，保证进程间可以进行快速的信息交换和大量数据的共享。但是，上述方式主要适合在同一台计算机系统内部的进程之间的通信。 3 应用程序间的通信及其实现技术 ---- 同进程之间的相互制约一样，不同的应用程序之间也存在竞争和协作的关系。UNIX操作系统也提供一些可用于应用程序之间实现数据共享与信息交换的编程接口，程序员可以通过自己编程来实现。如远程过程调用和基于TCP/IP协议的套接字（Socket）编程。但是，相对普通程序员来说，它们涉及的技术比较深，编程也比较复杂，实现起来困难较大。 ---- 于是，一种新的技术应运而生——通过将有关通信的细节完全掩盖在某个独立软件内部，即底层的通讯工作和相应的维护管理工作由该软件内部来实现，用户只需要将通信任务提交给该软件去完成，而不必理会它的具体工作过程——这就是所谓的中间件技术。 ---- 我们在这里分别讨论这三种常用的应用程序间通信的实现技术——远程过程调用、会话编程技术和MQSeries消息队列技术。其中远程过程调用和会话编程属于比较低级的方式，程序员参与的程度较深，而MQSeries消息队列则属于比较高级的方式，即中间件方式，程序员参与的程度较浅。 ---- 4．1 远程过程调用（RPC）
-
Linux进程间通信的几种方法总结--Linux内核剖析（七）
-
Linux] Linux 下的进程间通信方法Linux 下的进程间通信方法
-
Linux进程间通信（六）：共享内存的使用方法shmget、shmat、shmdt、shmctl