Linux下的进程通信之管道通信

news2024/11/24 23:20:48

目录

进程间通信的背景

为什么要进行进程间通信?

管道

什么是管道?

匿名管道

匿名管道原理

如何创建匿名管道?

命名管道


进程间通信的背景

进程间通信就是在不同的进程之间进行的数据的交换,进程间通信又称为Interprocess communication,简称IPC,Linux下的IPC有多种方式,比如,管道,System V IPC,POSIX IPC。

POSIX的全称是 "Portable Operating System Interface",POSIX不仅仅是一个单一标准,而且是IEEE(Institute for Electrical and Electronics Engineers, Inc. IEEE)指定的一个标准族。POSIX IPC一共有三个,就是Message Queue(消息队列),semaphores(信号量),Shared Memory(共享内存)

为什么要进行进程间通信?

进程具有独立性,进程之间交互数据的成本比较高,通信的目的主要是为了进行数据传输、资源共享、通知事件,进程控制。

通信本质:让不同的进程看到同一个资源(比如文件,内存块,队列,网络...),不同资源决定不同种类的通信方式。

管道

什么是管道?


管道是Unix最古老的通信方式,比如 在命令行上启动who程序和wc程序:

who程序是查看当前登录的用户个数:

wc则是打印文件的相关信息,-l选项是打印文件有多少行

 使用命令who | wc -l就可以知道有多少个用户正在登录了:

 这个|就是管道,who进程把文件内容写入管道当中,wc进程再从管道当中读取内容,最终输出到用户客户端上,这个管道是内存级文件,管道文件也是一样的,因为内存级文件读取写入速度远大于磁盘文件,底层是将磁盘文件打开对应的内存上的文件缓冲区作为管道。

画图理解如下:

匿名管道

匿名管道原理

Linux中的文件描述符_且随疾风前行->的博客-CSDN博客

由Linux文件描述符篇,进程控制块PCB中是有文件指针指向被打开的文件的。

所以父进程打开文件,创建子进程, 子进程拷贝了父进程的文件指针数组,而文件指针指向的文件内部有缓冲区,于是父子进程就可以通过看到的同一个文件的缓冲区进行通信,画图理解创建进程过程如下:

在内核代码中看内核管道的数据结构也可以看见管道的缓冲区:

这个缓冲区就在内存中,可以看到缓冲区中的页指针:

 

如何创建匿名管道?

        父进程创建管道文件,并打开管道文件的读写端,子进程继承父进程的管道文件,然后关闭父进程或子进程对应的读写端,完成管道的单向通信。之所以让父进程同时打开文件的读写端,是为了方便子进程继承父进程的读写端不用再读写打开文件。关闭读写端是因为这是管道的特性,管道在内核的底层实现就是单向通信,即一方读取一方写入的单向通信,谁关闭写端谁关闭读端由需求决定。

比如:要实现管道通信,让父进程做写端,子进程做读端,就是下面的图解,

前面提到在命令行上的管道通信本质上是我们的父进程,创建了管道文件,然后又创建了两个子进程继承了管道文件,然后两个子进程之间进行进程间通信。

使用系统调用pipe创建管道文件系统调用会将文件描述符写入pipefd数组,零号下标表示读端,一号下标表示写端。(联想记忆:0-嘴巴-读书-读端,1-笔-写字-写端)

测试代码:

 输出:

可见打开的是3号文件和4号文件 

创建管道文件代码示例:

#include <fcntl.h>
#include <unistd.h>
#include <iostream>
#include <stdlib.h>
using namespace std;
int main()
{
  int pipefd[2] = {0};
  if (pipe(pipefd) != 0)
  {
    cerr << "pipe error!" << endl;
    return 1;
  }

  pid_t id = fork();
  if (id == 0)
  {
    sleep(1);
    // child,read,close write
    close(pipefd[1]);
    char buff[1024];
    while (1)
    {
      ssize_t s = read(pipefd[0], (void *)buff, sizeof buff);
      if (s > 0)
      {
        cout << "child process echo:" << buff << endl;
      }
      else if (s == 0) // 表示读取结束,因为写端关闭
      {
        cout << "read end" << endl;
        exit(0);
      }
      else
      {
        cout << "read error" << endl;
        exit(-1);
      }
    }
  }

  close(pipefd[0]);
  // parent,write,close read
  while (1)
  {
    char buff[1024] = "message from parent process---";
    write(pipefd[1], buff, sizeof buff);
    sleep(2);
  }
  return 0;
}

注意read函数使用:read函数读取文件读取成功,返回读取的字节数,读取失败返回负一,读取结束返回零,为何能知道读取结束呢?因为文件当中有类似引用计数的文件计数,记录了文件被打开的次数,当写端关闭的时候,计数减一,所以读端文件能够感知到,所以能够结束读取返回0,运行程序时也可以验证,比如杀死父进程,子进程会读取结束:

当代码运行时,父进程每隔两秒写入管道一次,而每隔两秒子进程输出一次,这说明当管道中没有数据的时候,子进程读端会堵塞式地等待读取。而且可以验证当写端写满的时候,写端将会阻塞,不再写入,这说明读写端管道文件是具有访问控制和同步机制的。阻塞等待的本质是将进程PCB放入等待队列中,这个等待队列就在管道文件的内部维护着。

匿名管道的特征总结:

管道只能用于具有血缘关系的进程之间的通信,常用于父子之间的通信。

管道只能进行单向通信,也即一方写入一方读取,这是半双工的一种特殊情况。(半双工指的是一方读取,一方写入,但不固定哪一方读取或者哪一方写入。)

管道是面向字节流的,先写入的先被读取,没有格式边界。

管道本质是文件,文件的生命周期是随进程的。

命名管道

命名管道可以用于让两个没有血缘关系的进程之间实现通信,在命令行上可以使用mkfifo创建管道文件,比如用mkfifo实现cat和echo进程之间的管道通信:

管道通信本质上是让这两个进程都看到了同一份的管道文件,注意是单向通信,而且管道文件在内存中是内存级文件,不需要刷新到内存中,也可以使用系统调用函数mkfifo创建管道文件。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/170128.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

Python SciPy 空间数据

SciPy 空间数据空间数据又称几何数据&#xff0c;它用来表示物体的位置、形态、大小分布等各方面的信息&#xff0c;比如坐标上的点。SciPy 通过 scipy.spatial 模块处理空间数据&#xff0c;比如判断一个点是否在边界内、计算给定点周围距离最近点以及给定距离内的所有点。三角…

【学Vue就跟玩一样】组件的自定义事件和全局事件总线

一&#xff0c;自定义事件1.自定义事件是什么自定义事件一种组件间通信的方式&#xff0c;适用于 子组件 ——> 父组件传输数据等2.要在什么地方使用若App是父组件&#xff0c;School是子组件&#xff0c;School想给App传数据&#xff0c;那么就要在App中给School绑定自定义…

使用k8s实现灰度发布,金丝雀,蓝绿发布

介绍#Ingress-Nginx 是一个K8S ingress工具&#xff0c;支持配置 Ingress Annotations 来实现不同场景下的灰度发布和测试。 Nginx Annotations 支持以下 4 种 Canary 规则&#xff1a;nginx.ingress.kubernetes.io/canary-by-header&#xff1a;基于 Request Header 的流量切分…

ThreadLocal底层原理

ThreadLocal底层原理一&#xff1a;什么是ThreadLocal二&#xff1a;理解ThreadLocal中的内存泄漏问题三&#xff1a;ThreadLocalMap中的Hash冲突处理四&#xff1a;可以被继承的ThreadLocal——InheritableThreadLocal一&#xff1a;什么是ThreadLocal ThreadLocal是一个创建…

【电脑故障】PIN无效,显示无用户配置文件

【电脑故障】PIN无效。显示无用户配置文件1. 电脑情况&#xff1a;2. 解决方法&#xff08;个人&#xff09;&#xff1a;2.1 解决登录问题2.2 解决PIN可用设置1. 电脑情况&#xff1a; 电脑品牌&#xff1a;联想小新pro13操作系统&#xff1a;win10 2. 解决方法&#xff08;…

C++初阶--stack和queue

目录 stack介绍 stack的使用 stack的模拟实现 queue的介绍 queue的使用 queue的模拟实现 deque priority_queue priority_queue的使用 仿函数 priority_queue的模拟实现 stack介绍&#xff1a; stack是一种容器适配器&#xff0c;专门用在具有后进先出操作的上下文环…

Nginx使用(三)配置实例

一、反向代理示例一效果&#xff1a;打开浏览器&#xff0c;在浏览器地址栏输入地址www.123.com&#xff0c;跳转到linux系统tomcat主页面中具体实现&#xff1a;&#xff08;1&#xff09; 准备&#xff1a;安装nginx在linux系统安装tomcat,使用默认端口8080解压之后进入到tom…

一篇文章读懂mybatis-plus原理和CRUD接口

Myabtis-Plus配置 MybatisPlus官网 官方文档上有详细的spring boot配置mybatis-plus的教程&#xff0c;此处就不在详细赘述。 mybatis-plus是基于spring完成的只能再spring相关应用上实现。 引入父工程 注意mybatis-plus和spring boot的版本匹配不然会出现 推荐版本 <pa…

自媒体神器 Previs Shot 使用指南

Previs Shot 是一款影视创作的项目管理工具&#xff0c;更高效的方式开始您的影视创作历程。分镜表分镜表可高效绘制画面、编写景别、运镜、内容、台词等&#xff0c;甚至可以填写摄影器材、灯光等信息。分镜结构场景&#xff1a;电影里比如过生日、开party都是不同的场景&…

【程序员陪你过大年】html+css+js 实现动态新年烟花特效及服务器部署

前言 不知不觉又到了年底&#xff0c;这一年是值得庆贺的一年&#xff0c;疫情过去&#xff0c;经济好转。我们急需在春节这个特殊的日志释放下自己的情绪。但是大部分地区都不让放炮&#xff0c;于是乎我为大家带来一套十分炫酷应景的春节烟花动画代码实现。效果如下图所示 :…

【如何在Linux下使用Git命令在Gitee上创建项目】

目录 1 创建仓库 2 Git提交三板斧 2.1 add 2.2 commit 2.3 push 1 创建仓库 首先我们可以使用命令&#xff1a;git --version 来查看是否下在了git,没有下载的可以使用下面的命令安装&#xff1a; sudo yum install -y git 成功后就可以查看了&#xff1a; [grmVM-8-12-…

深度学习目标检测_YOLOV3超详细解读

文章目录YOLO V3概述网络结构backbone&#xff1a;darknet-53特征细化&#xff08;多scale&#xff09;残差连接残差网络的发家史先验框softmax改进YOLO V3概述 yolo v3论文地址&#xff1a;https://pjreddie.com/media/files/papers/YOLOv3.pdf 先说说yolo v3的效果&#xff…

字节青训营Go语言学习第二天-Go语言进阶与依赖管理

文章目录并行VS并发GoroutineCSPChannel并发安全LockWithGroupGo依赖管理GoPathGo VendorGo Module依赖分发-回源并行VS并发 并发指的是多线程在一个CPU上运行&#xff0c;而并行是直利用多核来实现多线程。 内核是系统里比较昂贵的系统资源&#xff0c;它的创建、切换停止都是…

K8s可视化界面Kubernetes DashboardKuboard

目录一、简介二、Kubernetes Dashboard2.1 部署dashboard2.2 访问UI2.3 创建访问账号三、Kuboard3.1 部署2.2 访问UI一、简介 本文给大家介绍两个K8s集群的可视化工具 Kubernetes Dashboard 和 Kuboard 二、Kubernetes Dashboard 2.1 部署dashboard dashboard Github地址&a…

【算法基础(2)】二分查找和斐波那契数列

二分查找 二分查找高效的前提是数据结构是有序的 思路&#xff1a; 1.排序 2.将数组折半&#xff0c;分成左右两个数组。 3.判断要查找的数和中间位置数值的大小&#xff0c;来判断要查找的数实在哪一半。 4.之后继续折半查找&#xff0c;直至找到这个数。 图解&#xff1a; 首…

SpringMVC看这一篇文章就够了

第一章 SpringMVC的简介 Spring框架版本 4.3.29.RELEASE SpringMVC是什么 1 2 3 4 5 61. Spring家族的一个部分 2. 是JavaWeb三层架构中控制器层的解决方案 3. 是基于MVC思想的框架-- Model-- View-- ControllerSpringMVC知识点大纲SpringMVC功能简述 1 2 3 4 5 6 7 8 9 101. 作…

WEB前端有必要学会docker吗?0基础-45分钟带你学会(包含视频笔记案例源代码)

文章目录一、为什么要使用docker二、Windows10/11系统安装Docker Desktop三、如何判断电脑已经安装好docker四、docker前端应用实战&#xff1a;将vue项目打包为docker镜像运行1、将vue的项目进行构建&#xff0c;输出dist2、准备镜像内容3、制作镜像4、启动镜像五、如何发布镜…

【Leetcode】面试题 01.02. 判定是否互为字符重排、面试题 01.04. 回文排列

作者&#xff1a;一个喜欢猫咪的的程序员 专栏&#xff1a;《Leetcode》 喜欢的话&#xff1a;世间因为少年的挺身而出&#xff0c;而更加瑰丽。 ——《人民日报》 目录 面试题 01.02. 判定是否互为字符重排 面试题 01.04. 回文排列 面试题 …

水果店做微信活动推荐_分享水果店微信小程序制作步骤

试试做个小程序拯救你的店&#xff01;让你做出有效果的活动&#xff0c;每笔钱都花在刀刃上&#xff01;编辑第一&#xff0c;提升水果销量&#xff0c;降低损耗用水果店小程序做拼团、砍价、秒杀活动&#xff0c;并讲原本卖不完的水果&#xff0c;做成果盘吸引客人注册会员。…

点成分享|关于Grant水浴的一些FAQ

1、关于稳定性和均匀性 1&#xff09;稳定性&#xff0c;是水浴中任何一点在达到恒温时不同时间下的温度规律性波动程度的描述&#xff0c;是通过浴槽中心点测定的&#xff0c;并表示为测量值的正负一半。系同点不同时的温度特性描述。 例如&#xff1a;SAP恒温水浴设定温度为…