Linux系统编程之匿名管道

1.进程间通信介绍

1.1 进程通信的基本概念

在之前我们已经学习过进程地址空间。Linux 环境下,进程地址空间相互独立,每个进程各自有不同的用户地址空间。任何一个进程的全局变量在另一个进程中都看不到,所以进程和进程之间不能相互访问,要交换数据必须通过内核,在内核中开辟一块缓冲区,进程1把数据从用户空间拷到内核缓冲区,进程2再从内核缓冲区把数据读走,内核提供的这种机制称为进程间通信(IPC,Inter Process Communication)。

Linux系统编程之匿名管道

1.2 为什么要进程间通信

进程通信主要有以下目的:

  • 数据传输:一个进程需要将它的数据发送给另一个进程。
  • 资源共享:多个进程之间共享同样的资源。
  • 通知事件:一个进程需要向另一个或一组进程发送消息,通知它(它们)发生了某种事件(如进程终止时要通知父进程)。
  • 进程控制:有些进程希望完全控制另一个进程的执行(如Debug进程),此时控制进程希望能够拦截另一个进程的所有陷入和异常,并能够及时知道它的状态改变。

1.3 常见的进程通信方式

在进程间完成数据传递需要借助操作系统提供特殊的方法,如今常见的进程间通信方式有:

① 管道 (分为匿名管道与命名管道)
​ ② 信号 (开销最小)
​ ③ 共享内存

2.管道

2.1管道简介

管道是Unix中最古老的进程间通信方式,我们把从一个进程连接到另一个进程的数据流叫做管道。

在Linux中,| 符号被用来代表管道。因为在Linux中,不同的命令,如ps,ls,grep等命令的本质都是可执行程序,| 前面的命令前面的命令通常会输出大量的结果,这些结果将会交由 | 后面的命令继续处理。

如下面这个命令就是将ps axj中含有PID的结果输出:

Linux系统编程之匿名管道

2.2 管道的创建和应用

管道的本质是内核中一块供不同进程进行读写的缓冲区,而外在的操作形式是通过文件读写的方式进行。

#include <unistd.h>
&#x529F;&#x80FD;:&#x521B;&#x5EFA;&#x4E00;&#x65E0;&#x540D;&#x7BA1;&#x9053;
&#x539F;&#x578B;
int pipe(int fd[2]);
&#x53C2;&#x6570;
fd&#xFF1A;&#x6587;&#x4EF6;&#x63CF;&#x8FF0;&#x7B26;&#x6570;&#x7EC4;,&#x8FD9;&#x662F;&#x4E00;&#x4E2A;&#x8F93;&#x51FA;&#x578B;&#x53C2;&#x6570;&#xFF0C;&#x8C03;&#x7528;&#x8BE5;&#x63A5;&#x53E3;&#x540E;&#xFF0C;&#x5C06;&#x4F1A;&#x7ED9;fd[2]&#x6570;&#x7EC4;&#x5206;&#x914D;&#x4E24;&#x4E2A;&#x6587;&#x4EF6;&#x63CF;&#x8FF0;&#x7B26;&#xFF0C;&#x4E24;&#x4E2A;&#x6587;&#x4EF6;&#x63CF;&#x8FF0;&#x7B26;&#x5206;&#x522B;&#x5BF9;&#x5E94;&#x7BA1;&#x9053;&#x7684;&#x8BFB;&#x5199;&#x4E24;&#x7AEF;&#x3002;&#x5176;&#x4E2D;fd[0]&#x8868;&#x793A;&#x8BFB;&#x7AEF;, fd[1]&#x8868;&#x793A;&#x5199;&#x7AEF;
&#x8FD4;&#x56DE;&#x503C;:&#x6210;&#x529F;&#x8FD4;&#x56DE;0&#xFF0C;&#x5931;&#x8D25;&#x8FD4;&#x56DE;&#x9519;&#x8BEF;&#x4EE3;&#x7801;
</unistd.h>

我们先用一个简单的例子来看一下管道的创建:

#include<iostream>
#include<unistd.h>
int main()
{
    int fd[2];
    int ret=pipe(fd);
    if(-1==ret)
    {
        std::cout<<"管道创建失败!"<<std::endl; } std::cout<<"fd[0]:"<<fd[0]<<std::endl<<"fd[1]:"<<fd[1]<<std::endl; return 0; < code></"管道创建失败!"<<std::endl;></unistd.h></iostream>

运行后:

Linux系统编程之匿名管道

可以看到,此时fd[0]和fd[1]返回了两个文件描述符。这两个文件描述符分别分别对应管道的读写两端。

#include<string.h>
#include<unistd.h>
#include<sys wait.h>
#include<sys stat.h>
#include<stdlib.h>
#include <sys types.h>
#include <fcntl.h>
int main()
{
  int fd[2];
  pipe(fd);
  pid_t pid = fork();
  if(pid < 0)
  {
    printf("fork error!");
  }else if(pid == 0)
  {
    //child
    close(fd[0]);
    char str[100];
    while(1)
    {
      printf("child:");
      fgets(str, 100, stdin);
      ssize_t len = strlen(str);
      if(write(fd[1], str, len) != len)
      {
        perror("write to pipe");
        exit(1);
      }
      memset(str, 0, len);
      sleep(1);
    }
  }
  //father
  int count = 0;
  close(fd[1]);
  while(count < 10)
  {
    char str[100];
    ssize_t s = read(fd[0], str, 100);
    if(s < 0){
      perror("read from pipe");
      break;
    }else{
      printf("father:%s", str);
    }
    memset(str, 0, strlen(str));
  }
  return 0;
}
</fcntl.h></sys></stdlib.h></sys></sys></unistd.h></string.h>

上面这段代码实现了子进程写入管道,父进程读出的过程。

Linux系统编程之匿名管道

2.3 管道的底层机制

管道是在有血缘关系的进程之间来通信的,如父子进程,兄弟进程等。因此,应用匿名管道时一定会有fork函数的参与。

如下面这个简化图可以看到,

  1. 父进程先使用pipe函数创建管道,得到两个文件描述符 fd[0]、fd[1]指向管道的读端和写端。
  2. 父进程调用fork创建子进程,此时父子进程有相同的struct files_struct,父子进程指向的struct file又指向了同一片文件缓冲区。(注意:这个表述并不严谨,我们下面马上就会讲到)
  3. 接下来父进程关闭写端,子进程关闭读端,就可以实现子进程向管道中写,父进程读。注意: 管道的通信是单向的!!!!

Linux系统编程之匿名管道

在 Linux 中,管道的实现并没有使用专门的数据结构,而是借助了 文件系统的file结构和VFS的 索引节点inode。通过 将两个 file struct指向同一个临时的 inode,而这个 VFS 索引节点又指向一个物理页面而实现的。

Linux系统编程之匿名管道

如上图所示, 有两个 file 数据结构,但它们定义文件操作例程地址是不同的,其中一个是向管道中写入数据的例程地址,而另一个是从管道中读出数据的例程地址。
这样,用户程序的系统调用仍然是通常的文件操作,而内核却利用这种抽象机制实现了管道这一特殊操作。看待管道,就如同看待文件一样!管道的使用和文件一致,迎合了”Linux一切皆文件思想”。

2.4 管道读写规则

用阻塞的方式打开管道(即默认情况下)

  1. 如果 所有管道写端对应的文件描述符被关闭(管道写端引用计数为 0),读端在将管道中剩余数据读取后,再次 read会返回0。(写端关闭)
  2. 如果 有指向管道写端的文件描述符没关闭,且持有管道 写端的进程也没有向管道中写数据,这时有进程从管道读端读数据,那么管道中剩余的数据都被读取后,再次 read 会阻塞。(读完不写)
  3. 如果 所有指向管道读端的文件描述符都关闭了(管道读端引用计数为 0),进行write操作会产生信号SIGPIPE,进而可能导致write进程退出。(读端关闭)
  4. 如果 有指向管道读端的文件描述符没关闭(管道读端引用计数大于 0),且 读端进程并没有向管道中读进程,则当写端进程写满后,会进入阻塞。(写满不读)

2.5 管道的特点

  • 只能用于具有共同祖先的进程(具有亲缘关系的进程)之间进行通信。
  • 管道提供流式服务。
  • 管道的生命周期随进程,进程退出,管道释放。
  • 内核会对管道操作进行同步与互斥。
  • 管道是半双工的,数据只能向一个方向流动;需要双方通信时,需要建立起两个管道
  • 管道大小为65536 byte

Original: https://www.cnblogs.com/Grong/p/15630119.html
Author: 乌有先生ii
Title: Linux系统编程之匿名管道

原创文章受到原创版权保护。转载请注明出处:https://www.johngo689.com/585755/

转载文章受原作者版权保护。转载请注明原作者出处!

(0)

大家都在看

  • 关于在Rocky linux下安装dotnet sdk不成功的问题

    Rocky Linux 9,运行 dnf install -y dotnet-sdk-6.0 一切正常,运行起来非常顺利,安装完毕。但是非常诡异,运行 dotnet –list-…

    Linux 2023年6月6日
    0109
  • Redis阻塞操作实现原理(转)

    原文:https://www.jianshu.com/p/xsMzfn 作者:Haiger 最近一位朋友问到:既然Redis是单线程的工作模式,那像 _BLPOP_这样的阻塞操作又…

    Linux 2023年5月28日
    089
  • 路由黑洞和黑洞路由

    路由黑洞: 路由黑洞一般是在网络边界做汇总回程路由的时候产生的一种不太愿意出现的现象,就是汇总的时候有时会有一些网段并不在内网中存在,但是又包含在汇总后的网段中,如果在这个汇总的边…

    Linux 2023年6月14日
    099
  • JavaScript闭包

    <!doctype html> <html lang="en"> <head> <title>&#x95…

    Linux 2023年6月13日
    074
  • 使用二手 gopro 做行车记录仪

    背景 自打开了博客以后,一直在写技术说明文,今天打算写点程序以外的东西换换味口。前段时间在某鱼上以 300 元的价格入手了一套完整的 gopro3+ 运动摄像头,带一张 32G S…

    Linux 2023年6月6日
    0240
  • 3.21 Linux PATH环境变量及作用(初学者必读)

    在讲解 PATH 环境变量之前,首先介绍一下 which 命令,它用于查找某个命令所在的绝对路径。例如: [root@localhost ~]# which rm /bin/rm …

    Linux 2023年6月7日
    078
  • python_列表

    列表创建 列表类似数组,但是以一对方括号 []作为符号,同时支持-1到-n的下标访问。列表中包含的是元素值的引用 并且,列表中的元素可以不是同一类型的 列表的创建: listNew…

    Linux 2023年6月7日
    0134
  • 对比powershell,点评:《七年老运维实战中的 Shell 开发经验总结》

    前言: 《七年老运维实战中的 Shell 开发经验总结》是不错的帖子,建议shell用户搜看。 点评:《七年老运维实战中的 Shell 开发经验总结》 shell除了上述问题外,还…

    Linux 2023年6月14日
    087
  • Docker容器网络配置

    Docker容器网络配置 1、Linux内核实现名称空间的创建 1.1 ip netns命令 可以借助 ip netns命令来完成对 Network Namespace 的各种操作…

    Linux 2023年6月7日
    092
  • redis 常用命令

    批量删除redis key redis-cli -a xxx keys “prefix_tb_supplier:spl_id*” | xargs redis…

    Linux 2023年5月28日
    078
  • Mac下安装zshell

    什么是shell 大多数命令行用户接触最多的是Bash,因为Bash是各个版本操作系统(Linux&Mac)的默认shell。 查看当前使用的shell $ echo $S…

    Linux 2023年5月28日
    076
  • Docker Manager for Docker Swarm deploy

    一、Swarm概述 Swarm是Docker公司在2014年12月初发布的一套较为简单的工具,用来管理Docker集群,它将一群Docker宿主机变成一个单一的,虚拟的主机。Swa…

    Linux 2023年6月14日
    0101
  • redis用法分析

    redis也是一个内存非关系型数据库,它拥有memcache在数据存储上的全部优点,而且在memcache的基础上增加了数据持久性功能,redis用rdb和aof两种方式实现数据持…

    Linux 2023年5月28日
    077
  • 解决pip下载慢

    临时使用 可以在使用pip的时候加参数 -i https://pypi.tuna.tsinghua.edu.cn/simple 设为默认 pip install pip -U -i…

    Linux 2023年6月13日
    082
  • 使用idea操作git(ssh协议)

    问题 我们发现,使用IDEA上的git功能,当使用ssh协议出现了可以commit但无法push和pull的问题,经过测试发现原因是Could not read from rems…

    Linux 2023年6月6日
    0122
  • 最小生成树-Kruskal算法

    与 Prim算法贪心选择不同,Kruskal算法采取 每次选择权值最小的边的方法,这样,在 不构成环且最后能够连接完所有边它们的权重和一定是最小的。 和之前Prim算法的图一样,便…

    Linux 2023年6月7日
    0106
亲爱的 Coder【最近整理,可免费获取】👉 最新必读书单  | 👏 面试题下载  | 🌎 免费的AI知识星球