【Linux系统化学习】深入理解匿名管道(pipe)和命名管道(fifo)

目录

进程间通信

进程间通信目的

进程间通信的方式

管道

System V IPC（本地通信）

POSIX IPC（网络通信）

管道

什么是管道

匿名管道

匿名管道的创建

匿名管道的使用

匿名管道的四种情况

匿名管道的五种特性

命名管道

指令级的命名管道

代码级的命名管道

读端

写端

匿名管道与命名管道的区别

进程间通信

从Linux这个专栏开始我们已经系统学习了两大块内容——进程和文件系统。但是内存中的文件离不开进程；因此可见进程的重要性，但是我们只是对单一的一个进程进行研究。可实际我们总能发现需要将一个程序的输出交给另一个程序进行处理，这就是进程间的通信；但是进程具有独立性，我们不可以将一个进程的数据拷贝给另一个进程，因此两个进程通信必须含有一个中间媒介用于音系交流。

进程间通信的本质就是：让不同的进程先看到同一份资源。

进程间通信目的

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

进程间通信的方式

管道

  • 匿名管道pipe
  • 命名管道FIFO

System V IPC（本地通信）

  • System V 消息队列
  • System V 共享内存
  • System V 信号量

POSIX IPC（网络通信）

  • 消息队列
  • 共享内存
  • 信号量
  • 互斥量
  • 条件变量
  • 读写锁

管道

什么是管道

  • 管道是Unix中最古老的进程间通信的形式。
  • 我们把从一个进程连接到另一个进程的一个数据流称为一个“管道”

注意：是因为含有一种数据的传送方式类似管道才有的管道，而不是因为管道这个名词而建立的一种数据传送方式。（注意这两种的因果关系）

 

匿名管道

匿名管道的创建

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

功能：创建一个匿名管道

参数

  • fd：文件描述符数组，其中fd[0]表示读端，fd[1]表示写端
  • 返回值：成功返回0，失败返回错误码。

匿名管道的使用

#include<iostream>
#include<cstring>
#include<unistd.h>
#include<cassert>
#include<wait.h>
using namespace  std;
#define MAX 1024int main()
{//第一步，建立管道int fd[2]={0};int n = pipe(fd);assert(n==0);(void)n;//第二步，创建子进程pid_t id = fork();if(id<0){perror("fork");return 1;}//子写父读//第三步：父子双方关闭不需要的fd，形成单行通道if(id==0){//childclose(fd[0]);char massage[MAX];int cnt =10;while(cnt){snprintf(massage,sizeof(massage),"I am a child , pid : %d ppid : %d  cnt : %d ",getpid(),getpid(),cnt--);// w - 只向管道写入write(fd[1],massage,strlen(massage));sleep(1);}exit(0);}//fatherclose(fd[1]);char buffer[MAX];while(true){// r - 只从管道读取ssize_t n = read(fd[0],buffer,sizeof(buffer)-1);if(n>0){buffer[n]={0};cout<<getpid()<<"child say:"<<buffer<<endl;}sleep(1);}pid_t rid = waitpid(id,nullptr,0);if(rid==id){cout<<"wait success"<<endl;}return 0;
}

现象的解释：

在创建子进程前，建立管道；然后创建子进程，父进程关闭写端只做读取，子进程关闭读端只做写入；通过管道子进程写入的数据通过管道被父进程读取。

匿名管道的四种情况

1. 正常情况，如果管道没有数据了，读端必须等待，直到有数据为止(写端写入数据了)

2. 正常情况，如果管道被写满了，写端必须等待，直到有空间为止(读端读走数据)

3. 写端关闭，读端一直读取, 读端会读到read返回值为0， 表示读到文件结尾

4. 读端关闭，写端一直写入，操作系统会直接杀掉写端进程，通过想目标进程发送SIGPIPE(13)信号，终止目标进程。

匿名管道的五种特性

1. 匿名管道,可以允许具有血缘关系的进程之间进行进程间通信，常用与父子,仅限于此

2. 匿名管道，默认给读写端要提供同步机制 

3. 面向字节流的

4. 管道的生命周期是随进程的

5. 管道是单向通信的，半双工通信的一种特殊情况

从文件描述符的角度来理解管道的原理

管道的原理需要结合文件系统来描述。当进程分别以读和写打开同一个文件，进程会创建PCB；PCB含有指向关于该进程打开的所有文件信息结构体（struct files_struct)的指针(struct files_struct*)，这个结构体中含有一个数组，数组的每个下标代表所打开的每个文件，数组的每个元素为一个指针(struct file* fd——array[])指向被打开的文件；读和写在内存中都会加载该内存，在内存中虽然有两个文件但是这两个文件公用一个缓冲区。当fork()创建子进程的时候，会发生浅拷贝；因此子进程中的所有数据和父进程是一样的，包括指针信息。子进程中数组元素也是指向父进程所打开的读写文件，这两个文件又公用一个缓冲区；这两个文件被连个指针所指向，使用引用计数而实现需不需要文件的关闭。关闭父进程的写文件和关闭子进程的的读文件，这样子进程将信息写到缓冲区中，父进程将数据自己读取，不加载到内存中，这样就实现了管道。

命名管道

  • 匿名管道的一个限制就是只能在具有共同祖先（具有血缘关系）的进程间通信
  • 如果我们想在不相关的进程之间交换数据，可以使用FIFO文件来做这项工作，它经常被称为命名管道。
  • 命名管道是一种特殊类型的文件

指令级的命名管道

命名管道可以在命令行上创建，使用下面指令：

mkfifo 文件名

 

现象的解释：这个过程是动态的，由于动图太大不方便演示。在一个文件夹中创建了一个管道文件。echo指令进行循环写入，在另一个端口下cat命令进行读取。通过这个管道文件实现了两个不相关进程之间的通信。这个管道文件为中间媒介是实现了两个进程间的通信。

代码级的命名管道

管道也可以在程序里创建，相关函数为：

int mkfifo(const char *filename,mode_t mode)

其实命名管道就是个文件，在一个进程中创建这个文件，进行写入/读取，或者在同时在另一个文件中进行读取和写入操作，本质就是：两个不同的进程同时对同一个文件进行文件操作。这个文件就实现了进程间的通信，这个文件就是管道。

读端

在程序的一开始，直接打开这个文件；当文件不存在时创建这个管道文件，直到创建成功为止；

然后使用系统调用文件操作读函数，对文件进行读取。

#include <iostream>
#include <cstring>
#include <cerrno>
#include <unistd.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include "RW.h"bool MakeFifo()
{int n = mkfifo(FILENAME, 0666);if(n < 0){std::cerr << "errno: " << errno << ", errstring: " << strerror(errno) << std::endl;return false;}std::cout << "mkfifo success... read" << std::endl;return true;
}int main()
{
Start:int rfd = open(FILENAME, O_RDONLY);if(rfd < 0){std::cerr << "errno: " << errno << ", errstring: " << strerror(errno) << std::endl;if(MakeFifo()) goto Start;else return 1;}std::cout << "open fifo success..." << std::endl;char buffer[1024];while(true){ssize_t s = read(rfd, buffer, sizeof(buffer)-1);if(s > 0){buffer[s] = 0;std::cout << "Client say# " << buffer << std::endl;}else if(s == 0){std::cout << "client quit, server quit too!" << std::endl;break;}}close(rfd);std::cout << "close fifo success..." << std::endl;return 0;
}

写端

也是在程序一开始直接打开指定的管道文件，判断是否打开成功；打开成功后使用你系统调用文件操作写函数对文件进行写入。

#include <iostream>
#include <cstring>
#include <cerrno>
#include <unistd.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include "RW.h"int main()
{int wfd = open(FILENAME, O_WRONLY);if (wfd < 0){std::cerr << "errno: " << errno << ", errstring: " << strerror(errno) << std::endl;return 1;}std::cout << "open fifo success... write" << std::endl;std::string message;while (true){std::cout << "Please Enter# ";std::getline(std::cin, message);ssize_t s = write(wfd, message.c_str(), message.size());if (s < 0){std::cerr << "errno: " << errno << ", errstring: " << strerror(errno) << std::endl;break;}}close(wfd);std::cout << "close fifo success..." << std::endl;return 0;
}

现象的解释：当我们同时在两个窗口运行这两个可执行程序时，在写端写入回车成功后；将数据写到管道文件中，当读端检测到管道文件中数据时会将这条消息读取。其实这个过程是同步进行的，由于这里动图太大，不方便演示。 

从底层来看命名管道的原理和匿名管道的原理基本相同这里就不过多赘述了。

匿名管道与命名管道的区别

  • 匿名管道由pipe函数创建并打开。
  • 命名管道由mkfifo函数创建，打开用open
  • FIFO（命名管道）与pipe（匿名管道）之间唯一的区别在它们创建与打开的方式不同，一但这些工作完成之后，它们具有相同的意义。

今天对Linux下管道实现进程间通信的分享到这就结束了，希望大家读完后有很大的收获，也可以在评论区点评文章中的内容和分享自己的看法；个人主页还有很多精彩的内容。您三连的支持就是我前进的动力，感谢大家的支持！！！   

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

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

相关文章

瑞_Redis_初识Redis（含安装教程）

瑞_Redis_初识Redis（含安装教程）

文章目录 1 初识Redis1.1 认识NoSQL1.1.1 结构化与非结构化1.1.2 关联和非关联1.1.3 查询方式1.1.4 事务1.1.5 总结 1.2 认识Redis1.2.1 介绍1.2.2 特征1.2.3 优势 1.3 安装Redis ★★★1.3.1 Linux安装Redis1.3.1.1 安装Redis依赖 1.3.2 Windows安装Redis1.3.2.1 安装步骤1.3.…
阅读更多...
抛弃chatgpt，使用微软的Cursor提升coding效率

抛弃chatgpt，使用微软的Cursor提升coding效率

Whats Cursor? Cursor编辑器是一个基于GPT-4的代码编辑器&#xff0c;它可以根据用户的自然语言指令或者正在编辑的代码上下文为用户提供代码建议&#xff0c;支持多种编程语言&#xff0c;如Python、Java、C/C#、go等。Cursor编辑器还可以帮助用户重构、理解和优化代码&…
阅读更多...
Code Control Process

Code Control Process

代码提交流程&#xff08;Code Control Process&#xff09; VSS&#xff0c;早前定义的版本控制&#xff0c;没有谁对不对&#xff0c;但是要根本解决冲突&#xff0c;特别人多的时候&#xff0c;50个人的时候&#xff0c;处理冲突时非常的麻烦的&#xff0c;改半天还改错了&…
阅读更多...
vulfocus靶场搭建

vulfocus靶场搭建

vulfocus靶场搭建 什么是vulfocus搭建教程靶场配置场景靶场编排靶场优化 什么是vulfocus Vulfocus 是一个漏洞集成平台&#xff0c;将漏洞环境 docker 镜像&#xff0c;放入即可使用&#xff0c;开箱即用&#xff0c;我们可以通过搭建该靶场&#xff0c;简单方便地复现一些框架…
阅读更多...
Java面试题之分布式/微服务篇

Java面试题之分布式/微服务篇

经济依旧不景气啊&#xff0c;如此大环境下Java还是这么卷&#xff0c;又是一年一次的金三银四。 兄弟们&#xff0c;你准备好了吗&#xff1f;冲冲冲&#xff01;欧里给&#xff01; 分布式/微服务相关面试题解 题一&#xff1a;CAP理论&#xff0c;BASE理论题二&#xff1a;…
阅读更多...
企业电子招投标系统源码之电子招投标系统建设的重点和未来趋势

企业电子招投标系统源码之电子招投标系统建设的重点和未来趋势

功能描述 1、门户管理&#xff1a;所有用户可在门户页面查看所有的公告信息及相关的通知信息。主要板块包含&#xff1a;招标公告、非招标公告、系统通知、政策法规。 2、立项管理&#xff1a;企业用户可对需要采购的项目进行立项申请&#xff0c;并提交审批&#xff0c;查看所…
阅读更多...
如何使用Docker部署MongoDB并结合内网穿透实现远程访问本地数据库

如何使用Docker部署MongoDB并结合内网穿透实现远程访问本地数据库

文章目录 前言1. 安装Docker2. 使用Docker拉取MongoDB镜像3. 创建并启动MongoDB容器4. 本地连接测试5. 公网远程访问本地MongoDB容器5.1 内网穿透工具安装5.2 创建远程连接公网地址5.3 使用固定TCP地址远程访问 正文开始前给大家推荐个网站&#xff0c;前些天发现了一个巨牛的 …
阅读更多...
SICTF Round#3 の WP

SICTF Round#3 の WP

Misc 签到 SICTF{1f4ce05a-0fed-42dc-9510-6e76dff8ff53} Crypto [签到]Vigenere 附件内容&#xff1a; Gn taj xirly gf Fxgjuakd, oe igywnd mt tegbs mnrxxlrivywd sngearbsw wakksre. Bs kpimj gf tank, it bx gur bslenmngn th jfdetagur mt ceei yze Ugnled Lystel t…
阅读更多...
mysql 2-22

mysql 2-22

变量 查看系统变量 修改 用户变量 赋值 定义处理程序 流程控制 IF CASE LOOP语句 WHILE循环 REPEAT leave ITERATE 游标 使用步骤 全局系统变量持久化 触发器 查看触发器 优点 MYSQL8的新特性 移除的旧特性 窗口函数 公用表表达式 JDBC 存储引擎 MYISAM存储引擎 InnoDB存储引擎…
阅读更多...
跟着pink老师前端入门教程（JavaScript）-day05

跟着pink老师前端入门教程（JavaScript）-day05

六、语句 &#xff08;一&#xff09;表达式和语句 1、表达式 表达式是可以被求值的代码&#xff0c;JavaScript 引擎会将其计算出一个结果。 2、语句 语句是一段可以执行的代码。 比如&#xff1a; prompt() 可以弹出一个输入框&#xff0c;还有 if语句 for 循环语句等…
阅读更多...
npm run serve启动报错npm ERR! Missing script: “serve“

npm run serve启动报错npm ERR! Missing script: “serve“

启动项目的时候用npm run serve发现报了以下的错误 解决方法&#xff1a; 1.一般情况下&#xff0c;这个问题是因为package.json文件里面确实没有 这里没有可能因为你的脚手架版本比较低&#xff0c;如果不想换&#xff0c;可以用 这里面有的 npm run dev去启动也是可以的 n…
阅读更多...
ubuntu20.04安装实时内核补丁PREEMPT_RT

ubuntu20.04安装实时内核补丁PREEMPT_RT

参考&#xff1a; Ubuntu 18.04安装 RT-PREEMPT 实时内核及补丁【过程记录】_ubuntu18.04 preempt rt linux 5.6.19-CSDN博客 https://github.com/UniversalRobots/Universal_Robots_ROS_Driver/blob/master/ur_robot_driver/doc/real_time.md当前内核&#xff1a;5.15.0-94-ge…
阅读更多...
前端基础自学整理｜DOM树

前端基础自学整理｜DOM树

DOM&#xff0c;文档对象模型&#xff08;Document Object Model&#xff09;&#xff0c;简单的说&#xff0c;DOM是一种理念&#xff0c;一种思想&#xff0c;一个与系统平台和编程语言无关的接口&#xff0c;一种方法, 使 Web开发人员可以访问HTML元素&#xff01;不是具体方…
阅读更多...
LLM之RAG实战（二十七）| 如何评估RAG系统

LLM之RAG实战（二十七）| 如何评估RAG系统

有没有想过今天的一些应用程序是如何看起来几乎神奇地智能的&#xff1f;这种魔力很大一部分来自于一种叫做RAG和LLM的东西。把RAG&#xff08;Retrieval Augmented Generation&#xff09;想象成人工智能世界里聪明的书呆子&#xff0c;它会挖掘大量信息&#xff0c;准确地找到…
阅读更多...
GitLab私有Git

GitLab私有Git

GitLab私有Git 1 GitLab简介 GitLab是整个DevOps生命周期的第一个单一应用程序。只有GitLab才能启用Concurrent DevOps&#xff0c;从组件链的约束中解锁组织。GitLab提供无与伦比的可见性&#xff0c;更高的效率和全面的治理。这使得软件生命周期加快了200&#xff05;&…
阅读更多...
Flutter插件开发指南01: 通道Channel的编写与实现

Flutter插件开发指南01: 通道Channel的编写与实现

Flutter插件开发指南01: 通道Channel的编写与实现 视频 https://www.bilibili.com/video/BV1ih4y1E7E3/ 前言 本文将会通过一个加法计算&#xff0c;来实现 Channel 的双向通讯&#xff0c;让大家有个一个体会。 Flutter插件 Flutter插件是Flutter应用程序与原生平台之间的桥…
阅读更多...
转转交易猫自带客服多模板全开源完整定制版源码

转转交易猫自带客服多模板全开源完整定制版源码

源码获取方式 搜一搜&#xff1a;万能工具箱合集 点击资源库直接进去获取源码即可 如果没看到就是待更新&#xff0c;会陆续更新上 或 源码软件库 软件介绍 商品发布&#xff1b;请在后台商品添加成功后&#xff0c;再点击该商品管理&#xff0c;可重新编辑当前商品的所有信息…
阅读更多...
网络安全“降本增笑”的三大帮手

网络安全“降本增笑”的三大帮手

在网络安全这个快速变化和危机四伏的领域中&#xff0c;通过使用正确的工具和方法&#xff0c;我们可以在工作中取得更高的效率&#xff0c;并降低相关成本。 雷池社区版 雷池社区版—开源Web应用防火墙。这款产品凭借强大的规则引擎&#xff0c;它允许用户自定义安全策略&…
阅读更多...
【C++精简版回顾】5.字符串

【C++精简版回顾】5.字符串

1.字符串的四种初始化方式 string str "ilove"; string str1("ilove"); string str2(str1); string str3 str1; 2.针对字符串的一些函数 &#xff08;1&#xff09;字符串长度 cout<<str.length()<<endl;&#xff08;2&#xff09;查找字…
阅读更多...
【海贼王的数据航海：利用数据结构成为数据海洋的霸主】时间复杂度 | 空间复杂度

【海贼王的数据航海：利用数据结构成为数据海洋的霸主】时间复杂度 | 空间复杂度

目录 1 -> 算法效率 1.1 -> 如何衡量一个算法的好坏&#xff1f; 1.2 -> 算法的复杂度 2 -> 时间复杂度 2.1 -> 时间复杂度的概念 2.2 -> 大O的渐进表示法 2.3 -> 常见时间复杂度计算 3 -> 空间复杂度 4 -> 常见复杂度对比 1 -> 算法效…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023