【Linux进程间通信】匿名管道

【Linux进程间通信】匿名管道

目录

  • 【Linux进程间通信】匿名管道
      • 进程间通信介绍
        • 进程间通信目的
        • 进程间通信发展
        • 进程间通信分类
    • 管道
        • 用fork来共享管道原理
        • 站在文件描述符角度——深度理解管道
        • 站在内核角度——管道本质
      • 匿名管道
        • 在myshell中添加管道的实现：
        • 管道读写规则
        • 管道特点

作者：爱写代码的刚子

时间：2023.11.21

前言：本篇博客将会介绍匿名管道的运用

进程间通信介绍

前言：因为进程独立性的存在，导致进程通信的成本比较高。为什么要进行进程间通信？基本数据，发送命令，某种协同，通知。

进程间通信目的

  • 数据传输：一个进程需要将它的数据发送给另一个进程

  • 资源共享：多个进程之间共享同样的资源。

  • 通知事件：一个进程需要向另一个或一组进程发送消息，通知它（它们）发生了某种事件（如进程终止时要通知父进程）。

  • 进程控制：有些进程希望完全控制另一个进程的执行（如Debug进程），此时控制进程希望能够拦截另一个进程的所有陷入和异常，并能够及时知道它的状态改变。

a. 进程间通信的本质：必须让不同的进程看到同一份“资源”

b. “资源”？特定形式的内存空间

c. 这个“资源”由操作系统提供，为什么不是我们两个进程中的一个呢？假设一个由一个进程提供，这个资源被这个进程独有，破坏进程独立性。

d. 我们进程访问这个空间，进行通信，本质就是访问操作系统！进程代表的就是用户，“资源”从创建，使用（一般），释放，都是调用系统调用接口！从底层设计，从接口设计，都要由操作系统独立设计。一般操作系统会有一个独立的通信模块——隶属于文件系统——IPC通信模块定制标准（进程间通信是有标准的）——System V &&posix

进程间通信发展

  • 管道

  • System V进程间通信

  • POSIX进程间通信

进程间通信分类

管道

  • 匿名管道pipe
  • 命名管道

System V IPC

  • System V 消息队列

  • System V 共享内存

  • System V 信号量

POSIX IPC

  • 消息队列

  • 共享内存

  • 信号量

  • 互斥量

  • 条件变量

  • 读写锁

管道

  • 管道是Unix中最古老的进程间通信的形式。

  • 我们把从一个进程连接到另一个进程的一个数据流称为一个“管道“

在这里插入图片描述

  • who | wc -l统计在云端服务器中的用户个数。

管道打开的是内存级文件（管道就是文件），每个文件有着对应的缓冲区，不同进程打开同一个文件时存在引用计数来进行控制。

管道并不支持同时读写！

回顾文件系统：
在这里插入图片描述

无论对文件怎么读写，首先都需要将文件加载到内存中。既然如此，我们也可以创建一个内存级文件（技术上可行）。

注意！！！！！，如果该进程创建了子进程，子进程中的struct file*fd_arry数组中存放相同的指针，但是指向的文件相同！！！！

在这里插入图片描述

  • 所以存在引用计数解决父进程关闭子进程仍然在读取文件的情况。
用fork来共享管道原理

在这里插入图片描述

站在文件描述符角度——深度理解管道

在这里插入图片描述

  • 注意，如果两个进程间没有关系（看不到同一份资源），就不能用上述方法进行通信，如果要通信，则需要采用下面匿名管道的方法。

  • 所以要想进行上述通信，进程间必须是父子关系，兄弟关系，爷孙关系…（血缘关系，常用于父子关系）

站在内核角度——管道本质

在这里插入图片描述

  • 【问题】：管道只能单向通信，如果我们需要进行双向通信呢？（建立多个管道）

  • 至此进程间通信了吗？没有，只是建立了通信信道——为什么怎么费劲？？——进程具有独立性，通信是有成本的！！！

匿名管道

#include <unistd.h>

功能:创建一无名管道

原型

int pipe(int fd[2]);int fd[2]为输出型参数，将文件的文件描述符数字带出来，让用户使用！！（pipefd[0]:读下标，pipefd[1]:写下标）

参数

fd：文件描述符数组,其中fd[0]表示读端, fd[1]表示写端

返回值：成功返回0，失败返回错误代码

在这里插入图片描述

  • 简单的代码示例：

示例一：查看pipefd数组的值

在这里插入图片描述

一般来说==pipefd[0]为读，pipefd[1]为写==。

示例二：子进程打印数据父进程读取数据：

示例代码：

#include <iostream>
#include <unistd.h>
#include <cstdlib>
#include <string>
#include <cstdio>
#include <sys/wait.h>
#include <string.h>
#define N 2
#define NUM 1024using namespace std;void Writer(int wfd)
{string s = "hello";pid_t self = getpid();int number = 0;char buffer[NUM];while(true){buffer[0]=0;//字符串清空，将这个数组当作字符串snprintf(buffer,sizeof(buffer),"%s-%d-%d",s.c_str(),self,number++);write(wfd,buffer,strlen(buffer));//strlen(buffer)不需要加1，c语言规定的‘\0’不关文件的事，只需要文件内容即可sleep(1);}
}void Reader(int rfd)
{char buffer[NUM];while(true){buffer[0] = 0;ssize_t n = read(rfd,buffer,sizeof(buffer));//注意 sizeof != strlen，管道满了怎么办？管道有面向字节流概念，之后学习网络会提到（定协议去区分）。if(n > 0){buffer[n] = 0;// 0 == '\0'当作字符串cout<< "父进程得到了一个消息："<< getpid() << "]#" << buffer <<endl;}}
}int main()
{int pipefd[N] = {0};int n = pipe(pipefd);if(n<0)return 1;cout << "pipefd[0]:" << pipefd[0] << ", pipefd[1]:  "<<pipefd[1] << endl;pid_t id = fork();if(id < 0) return 2;if(id == 0){//子进程close(pipefd[0]);//关闭读//IPC codeWriter(pipefd[1]);close(pipefd[1]);exit(0);}//父进程close(pipefd[1]);//关闭写//IPC codeReader(pipefd[0]);pid_t rid = waitpid(id,nullptr,0);if(rid < 0) return 3;close(pipefd[0]);  return 0;
}

结果：

在这里插入图片描述

  • 父子进程在对同一份数据进行访问时，这份资源是多执行流共享的，难免会出现访问冲突的问题。（临界资源竞争的问题）但是父子进程会进行协同。对于管道文件会发生同步与互斥————保护管道文件的数据安全。

  • 同时子进程向管道中写入的都是字符，父进程进行读取时也是字符，所以不会出换行的情况。（忽视分隔符等特殊符号，就相当于字节）（管道是面向字节流的）

总结：

管道的特征：

  1. 具有血缘关系的进程进行进程间通信
  2. 管道只能单向通信
  3. 父子进程是会进程协同的，同步与互斥——保护管道文件的数据安全（多线程）
  4. 管道是有固定大小的（会被写满，但是在不同的内核里大小不同）
  5. 管道是面向字节流的（网络）
  6. 管道是基于文件的，而文件的生命周期是随进程的
  • ulimit -a查看相关的限制（open files表示单个进程最多打开文件的个数 ）

在这里插入图片描述

  • man 7 pipe查看管道大小

在这里插入图片描述

  • 官方文档中说了，如果读取的数据小于PIPE_BUF，读取操作就必须是原子的
在myshell中添加管道的实现：

思路：

  • 分析输入的命令行字符串，获取有多少个|, 命令打散多个子命令字符串

  • malloc申请空间，pipe先申请多个管道

  • 循环创建多个子进程，每一个子进程的重定向情况。最开始. 输出重定向, 1->指定的一个管道的写端

  • 中间：输入输出重定向， 0标准输入重定向到上一个管道的读端 1标准输出重定向到下一个管道的写端

  • 最后一个：输入重定向，将标准输入重定向到最后一个管道的读端

  • 分别让不同的子进程执行不同的命令— exec* — exec*不会影响该进程曾经打开的文件，不会影响预先设置好的管道重定向

管道读写规则

管道的4中情况：

  1. 读写端正常，管道如果为空，读端就要阻塞
  2. 读写端正常，管道如果被写满，写端就要阻塞
  3. 读端正常读，写端关闭，读端就会读到0，表明读到了文件（pipe）结尾，不会被阻塞
  4. 写端是正常写入，读端关闭了。操作系统就要杀掉正在写入的进程。（通过信号干掉）

  • 当没有数据可读时

    • O_NONBLOCK disable：read调用阻塞，即进程暂停执行，一直等到有数据来到为止。
    • O_NONBLOCK enable：read调用返回-1，errno值为EAGAIN。

  • 当管道满的时候

    • O_NONBLOCK disable： write调用阻塞，直到有进程读走数据
    • O_NONBLOCK enable：调用返回-1，errno值为EAGAIN

  • 如果所有管道写端对应的文件描述符被关闭，则read返回0

  • 如果所有管道读端对应的文件描述符被关闭，则write操作会产生信号SIGPIPE,进而可能导致write进程退出

  • 当要写入的数据量不大于PIPE_BUF时，linux将保证写入的原子性。

  • 当要写入的数据量大于PIPE_BUF时，linux将不再保证写入的原子性。

管道特点

只能用于具有共同祖先的进程（具有亲缘关系的进程）之间进行通信；通常，一个管道由一个进程创

建，然后该进程调用fork，此后父、子进程之间就可应用该管道。

管道提供流式服务

一般而言，进程退出，管道释放，所以管道的生命周期随进程

一般而言，内核会对管道操作进行同步与互斥

管道是半双工的，数据只能向一个方向流动；需要双方通信时，需要建立起两个管道

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

jss/css/html 相关的技术栈有哪些？

jss/css/html 相关的技术栈有哪些？

js 的技术组件有哪些&#xff1f;比如 jQuery vue 等 常见的JavaScript技术组件&#xff1a; jQuery&#xff1a; jQuery是一个快速、小巧且功能丰富的JavaScript库&#xff0c;用于简化DOM操作、事件处理、动画效果等任务。 React&#xff1a; React是由Facebook开发的用于构…
阅读更多...
STM32--HAL库定时器学习记录（易懂）--持续学习

STM32--HAL库定时器学习记录（易懂）--持续学习

一、什么是定时器 定时器就是计数器&#xff0c;通过计数完成一系列功能。 二、定时器的分类 定时器分为基本定时器、通用定时器、高级定时器。级别不同&#xff0c;功能不同。级别越高&#xff0c;功能越强。 三、定时器&#xff08;计数器&#xff09;三个重要寄存器 预分…
阅读更多...
问题：金属电化学反应的实质是氧化还原反应，被腐蚀金属发生还原反应( ) #知识分享#知识分享#媒体

问题：金属电化学反应的实质是氧化还原反应，被腐蚀金属发生还原反应( ) #知识分享#知识分享#媒体

问题&#xff1a;金属电化学反应的实质是氧化还原反应&#xff0c;被腐蚀金属发生还原反应(　　) A、正确 B、错误 参考答案如图所示
阅读更多...
Ainx框架实现 一

Ainx框架实现 一

&#x1f4d5;作者简介&#xff1a; 过去日记&#xff0c;致力于Java、GoLang,Rust等多种编程语言&#xff0c;热爱技术&#xff0c;喜欢游戏的博主。 &#x1f4d7;本文收录于Ainx系列&#xff0c;大家有兴趣的可以看一看 &#x1f4d8;相关专栏Rust初阶教程、go语言基础系列…
阅读更多...
Powershell Install 一键部署Prometheus

Powershell Install 一键部署Prometheus

前言 Prometheus是一个开源的系统监控和报警系统，现在已经加入到CNCF基金会，成为继k8s之后第二个在CNCF托管的项目，在kubernetes容器管理系统中，通常会搭配prometheus进行监控，同时也支持多种exporter采集数据，还支持pushgateway进行数据上报，Prometheus性能足够支撑上…
阅读更多...
计算机毕业设计 | vue+SpringBoot图书借阅管理系统(附源码)

计算机毕业设计 | vue+SpringBoot图书借阅管理系统(附源码)

1&#xff0c; 概述 1.1 课题背景 随着现在科学技术的进步&#xff0c;人类社会正逐渐走向信息化&#xff0c;图书馆拥有丰富的文献信息资源&#xff0c;是社会系统的重要组成部分&#xff0c;在信息社会中作用越来越重要&#xff0c;在我国图书馆计算机等 信息技术的应用起步…
阅读更多...
docker安装-centos

docker安装-centos

Docker CE 支持 64 位版本 CentOS 7&#xff0c;并且要求内核版本不低于 3.10 卸载旧版本Docker sudo yum remove docker \ docker-common \ docker-selinux \ docker-engine使用yum安装 yum 更新到最新版本: sudo yum update执行以下命令安装依赖包&#xff1a; sudo yum…
阅读更多...
PyTorch 2.2 中文官方教程（十五）

PyTorch 2.2 中文官方教程（十五）

&#xff08;beta&#xff09;计算机视觉的量化迁移学习教程 原文&#xff1a;pytorch.org/tutorials/intermediate/quantized_transfer_learning_tutorial.html 译者&#xff1a;飞龙 协议&#xff1a;CC BY-NC-SA 4.0 提示 为了充分利用本教程&#xff0c;我们建议使用这个C…
阅读更多...
vue中使用html2canvas配合jspdf导出pdf（以及在导出时遇到的导出样式问题）

vue中使用html2canvas配合jspdf导出pdf（以及在导出时遇到的导出样式问题）

指定页面中导出为pdf格式并打包&#xff0c;使用html2canvas先转为图片格式&#xff0c;在利用jspdf转为pdf&#xff0c;最后下载打包为本地压缩包 yarn add html2canvas yarn add jspdf1. 注册一个插件并挂载 import html2Canvas from html2canvas import JsPDF from jspdf …
阅读更多...
记一次生产系统每隔10小时（36000000毫秒）固定进行一次Full GC排查思路

记一次生产系统每隔10小时（36000000毫秒）固定进行一次Full GC排查思路

一、 背景描述 某个应用在生产环境通过系统监控发现&#xff0c;应用每隔10小时就会触发一次Full GC&#xff0c;该系统当时承接的业务量并不大&#xff0c;而且固定10小时就会进行Full GC&#xff0c;通过监控时间轴发现Full GC频率很规律&#xff0c;直觉告诉我这不是JVM自身…
阅读更多...
寒假 day1

寒假 day1

1、请简述栈区和堆区的区别? 2、有一个整形数组:int arr[](数组的值由外部输入决定)&#xff0c;一个整型变量: x(也 由外部输入决定)。要求: 1)删除数组中与x的值相等的元素 2)不得创建新的数组 3)最多只允许使用单层循环 4)无需考虑超出新数组长度后面的元素&#xff0c;所以…
阅读更多...
【lesson40】理解文件系统

【lesson40】理解文件系统

文章目录 问题磁盘结构&#xff08;物理&#xff09;磁盘的存储结构磁盘的抽象结构 问题 1.有没有没有被打开的文件&#xff1f;当然有 在哪里呢&#xff1f;磁盘中也叫磁盘级文件 2.学习磁盘级别文件的侧重点在哪&#xff1f; 站在单个文件角度: 这个文件在哪里&#xff1f…
阅读更多...
【Linux】权限管理

【Linux】权限管理

&#x1f525;博客主页&#xff1a; 小羊失眠啦. &#x1f3a5;系列专栏&#xff1a;《C语言》 《数据结构》 《C》 《Linux》 《Cpolar》 ❤️感谢大家点赞&#x1f44d;收藏⭐评论✍️ 文章目录 一 、Linux中的用户1.1 Linux用户分类1.2 用户转换1.3 指令提权 二、Linux权限管…
阅读更多...
企业网络采用SD-WAN的优势

企业网络采用SD-WAN的优势

近年来&#xff0c;SD-WAN成为企业网络领域的一项热门技术&#xff0c;为传统网络带来了新的变革。SD-WAN&#xff08;Software Defined Wide Area Network&#xff0c;软件定义广域网&#xff09;以其灵活性、可管理性和低成本而备受青睐。它不仅能够创建成熟的专用网络&#…
阅读更多...
MySQL 教程 2.3

MySQL 教程 2.3

MySQL DELETE 语句 你可以使用 DELETE FROM 命令来删除 MySQL 数据表中的记录。 你可以在 mysql> 命令提示符或 PHP 脚本中执行该命令。 语法 以下是 DELETE 语句从 MySQL 数据表中删除数据的通用语法&#xff1a; DELETE FROM table_name WHERE condition; 参数说明&…
阅读更多...
IP风险画像在企业网络安全中应用

IP风险画像在企业网络安全中应用

随着企业数字化的不断深入&#xff0c;网络安全问题日益突显。IP风险画像作为一种综合性的网络安全工具&#xff0c;为企业提供了更全面的风险评估和防范手段。本文将结合一个实际案例&#xff0c;深入探讨IP风险画像在企业网络安全中的成功应用。 案例背景 一家大型金融机构…
阅读更多...
IP数据云识别真实IP与虚假流量案例

IP数据云识别真实IP与虚假流量案例

随着互联网的普及&#xff0c;企业在数字领域面临着越来越复杂的网络威胁。为了保护网站免受虚假流量和恶意攻击的影响&#xff0c;许多企业正在采用IP数据云。本文将结合一个真实案例&#xff0c;深入探讨IP数据云如何成功准确地识别真实用户IP和虚假流量IP&#xff0c;提高网…
阅读更多...
Oracle 面试题 | 09.精选Oracle高频面试题

Oracle 面试题 | 09.精选Oracle高频面试题

&#x1f90d; 前端开发工程师、技术日更博主、已过CET6 &#x1f368; 阿珊和她的猫_CSDN博客专家、23年度博客之星前端领域TOP1 &#x1f560; 牛客高级专题作者、打造专栏《前端面试必备》 、《2024面试高频手撕题》 &#x1f35a; 蓝桥云课签约作者、上架课程《Vue.js 和 E…
阅读更多...
vue3 之 组合式API—reactive和ref函数

vue3 之 组合式API—reactive和ref函数

ref&#xff08;&#xff09; 作用&#xff1a;接收简单类型或者对象类型的数据传入并返回一个响应式的对象 核心步骤&#xff1a; 1️⃣ 从 vue 包中导入 ref 函数 2️⃣在 <script setup>// 导入import { ref } from vue// 执行函数 传入参数 变量接收const count …
阅读更多...
【Python】【完整代码】解析Excel 文件中的内容并检查是否包含某字符串，并返回判断结果

【Python】【完整代码】解析Excel 文件中的内容并检查是否包含某字符串，并返回判断结果

示例&#xff1a; 开发需求&#xff1a;解析Excel 文件中的内容并检查是否包含 "Fail" 字符&#xff0c;若没有则返回True&#xff0c;若有则返回False 实现代码&#xff1a; #!/usr/bin/env python3 # -*- encoding: utf-8 -*-File : check_excel_for_fail.py Ti…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023