Linux -- 进程间通信、初识匿名管道

进程间通信

什么是进程间通信

进程间通信的一般规律

前言：

管道

代码预准备：

如何创建管道 -- pipe 函数

参数：

返回值：

wait 函数

参数：

验证管道的运行：

源文件 test.c ：

makefile 文件：

运行结果：

进程间通信

什么是进程间通信

进程间通信（Inter-Process Communication, IPC）是操作系统中非常重要的一个概念，它指的是不同进程之间进行数据交换或者传递消息的机制。

进程间通信的主要原因和目的是：

资源共享：不同的进程可能需要访问相同的资源或数据，例如文件、数据库等。通过IPC，可以实现对这些共享资源的有效管理和同步访问。

任务协作：在很多情况下，一个复杂的任务可能被分解为多个子任务，由不同的进程来执行。为了完成整个任务，这些进程之间需要相互通信，以协调它们的工作流程。

提高效率：对于一些计算密集型的任务，可以通过将工作分配给多个进程来并行处理，从而加速任务的完成。这时就需要有效的通信机制来保证各部分工作的正确性与一致性。

模块化设计：软件开发时采用模块化的设计思想，即将程序划分为相对独立但又能相互作用的功能单元（即进程）。这样做不仅有利于维护，而且也使得系统更加灵活可扩展。良好的IPC支持能够促进这种架构模式的应用。

跨网络服务调用：随着分布式系统的普及，在不同主机上的进程也需要能够互相通信。这涉及到更高级别的IPC形式，如RPC (Remote Procedure Call) 等技术。

进程间通信的一般规律

让不同的进程看到同一份资源！！！

前言：

假设现在有A、B进程，在A进程中开辟一块空间并写入数据，让 B 进程去 A 进程的这块空间读取数据，虽然确实让不同的进程看到了同一份资源，但是破坏了进程的独立性。

所以进程间通信需要有交换数据的空间，且这块空间不能由通信双方任何一个提供，那么这块空间只能由操作系统提供。

我们回顾一下父子进程，假设父进程对同一个文件分别用读方式和写方式打开，父进程将会得到两个文件描述符对象。

为什么对同一个文件分别用读方式打开和写方式打开，会创建两个文件描述符对象?

当你使用读取模式（例如 open("file.txt", "r")）和写入模式（例如 open("file.txt", "w")）分别打开同一个文件时，操作系统会为每次打开操作分配一个独立的文件描述符。这样做有几个原因：

独立性：每个文件描述符代表了对文件的一个独立访问路径。这意味着你可以同时从一个文件描述符读取数据，而从另一个文件描述符写入数据，即使它们指向的是同一个物理文件。这种独立性允许更灵活地处理文件。

位置指针：每个文件描述符都有自己的文件偏移量或位置指针。当你通过不同的文件描述符读写文件时，每个描述符的位置指针可以独立移动。这样，在进行多线程或多进程操作时，各个进程/线程可以安全地在不同位置上工作而不互相干扰。

权限控制：以不同模式打开文件提供了对文件的不同级别的访问权限。比如，只读模式下你只能读取文件内容，而在写入模式下还可以修改文件。拥有两个文件描述符意味着可以根据需要选择适当的访问级别，同时也增加了安全性，因为不需要给所有操作都赋予完全相同的权限。

性能与资源管理：尽管是同一份文件，但根据具体的操作需求（如顺序读取、随机写入等），操作系统可能采取不同的策略来优化I/O性能。此外，维护多个文件描述符也便于系统更好地跟踪哪些程序正在使用该文件，并且有助于实现诸如引用计数这样的机制，从而有效地管理文件相关的系统资源。

总之，虽然这两个文件描述符对应于同一物理文件，但是它们各自保持了自己的状态信息，这使得在同一时间内能够执行更加复杂的并发操作，同时也增强了系统的灵活性和安全性。

父进程得到两个文件描述符对象之后，我们创建子进程，子进程继承父进程的文件描述符表，父子进程指向同一个文件和缓冲区！这也就实现了父子进程看到同一份资源，就可以实现进程间通信！

管道

从前言中就可以看出，管道的本质是文件！

在 Linux 中，管道（pipe）是一种进程间通信（IPC, Inter-Process Communication）的机制，它允许一个进程的输出直接作为另一个进程的输入。

管道可以看作是连接两个或多个命令的数据流通道，它使得数据可以在不同的程序之间流动而不需要通过临时文件。

标准的管道是单向的，即数据只能从写端流向读端。

匿名管道：

在前言中，父进程和子进程的文件的读端和写端都是打开的，为了符合管道是单向的，我们可以选择让父进程作为写端，子进程作为读端或者父进程作为读端、子进程作为写端！

如下图，我们让父进程作为写端，子进程作为读端：

代码预准备：

如何创建管道 -- pipe 函数

#include <unistd.h>int pipe(int pipefd[2]);

该函数用于创建一个匿名管道。

参数：

pipefd：这是一个指向两个整数的指针。pipe() 成功后，这两个整数会被设置为新创建的管道的读端和写端的文件描述符。读端通常为 fd[0]，写端通常为 fd[1]。

返回值：

它在成功时返回 0，并且通过其参数（一个包含两个整数的数组）来传递两个文件描述符；
如果调用失败，pipe() 会返回-1，并设置全局变量 errno 来指示具体的错误原因。

wait 函数

#include <sys/types.h>
#include <sys/wait.h>pid_t wait(int *status);

wait() 函数是 Unix 和 Linux 系统中用于进程控制的一个重要函数。它允许一个进程（通常是父进程）等待其子进程结束，并获取子进程的退出状态。wait() 函数会阻塞调用者，直到至少有一个子进程终止或接收到一个信号。

参数：

status：这是一个指向整数的指针，用来存储子进程的退出状态信息。如果不需要这个信息，可以传递 NULL。

返回值:

如果有子进程成功终止，则返回该子进程的 PID；
如果没有子进程或者所有子进程都还在运行，wait() 将一直阻塞，直到至少有一个子进程终止。
如果发生错误（如被信号中断），则返回-1，并设置 errno。

验证管道的运行：

源文件 test.c ：

#include<stdio.h>
#include<stdlib.h>
#include<string.h>
#include<unistd.h>
#include<sys/types.h>
#include<sys/wait.h>void writer(int wfd)
{const char *str="hello father,I am child";char buffer[128];int cnt=0;pid_t pid=getpid();//获得进程pidwhile(1){//向缓冲区里写入内容snprintf(buffer,sizeof(buffer),"message:%s,pid:%d,count:%d\n",str,pid,cnt);//把缓冲区里的内容写入到管道write(wfd,buffer,sizeof(buffer));cnt++;sleep(1);}
}void reader(int rfd)
{char buffer[128];while(1){//读取管道里的内容ssize_t n=read(rfd,buffer,sizeof(buffer)-1);printf("father get a message: %s",buffer);}
}int main()
{int pipefd[2];int n=pipe(pipefd);if(n<0){return 1;}printf("%d %d\n",pipefd[0],pipefd[1]);pid_t id=fork();if(id==0){//子进程创建成功//关闭读端close(pipefd[0]);writer(pipefd[1]);//写exit(0);}//父进程关闭写端close(pipefd[1]);reader(pipefd[0]);//读wait(NULL);return 0;
}

makefile 文件：

testpipe:test.cgcc -o $@ $^.PHONY:clean
clean:rm -f testpipe

运行结果：

从下面的运行结果可以看出，父进程接收到了子进程写的数据：