【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.hqwc.cn/news/484024.html

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

相关文章

机器视觉缺陷检测目前面临着哪些挑战？

机器视觉缺陷检测目前面临着哪些挑战？

机器视觉缺陷检测是工业自动化领域的一项关键技术&#xff0c;能够大幅提高生产效率和产品质量。然而&#xff0c;在实际应用中&#xff0c;机器视觉缺陷检测面临着诸多挑战。以下是对这些挑战的详细分析&#xff1a; 1、数据量大、处理速度慢&#xff1a;在实际生产线中&#…
阅读更多...
JAMA Neurology（IF: 29）：神经源性细胞外囊泡α-Synuclein作为患帕金森病风险个体的血清生物标志物

JAMA Neurology（IF: 29）：神经源性细胞外囊泡α-Synuclein作为患帕金森病风险个体的血清生物标志物

帕金森病 (Parkinson disease, PD) 是最常见的运动障碍疾病&#xff0c;其特点是前驱期较长&#xff0c;在出现典型运动症状的临床表型前几年就开始了。许多非运动症状可能在前驱期表现出来&#xff0c;如快速动眼睡眠行为障碍 (rapid eye movement sleep behavior disorder, R…
阅读更多...
一分钟学会MobaXterm当Linux客户端使用

一分钟学会MobaXterm当Linux客户端使用

一、介绍 MobaXterm是一款功能强大的远程计算机管理工具&#xff0c;它集成了各种网络工具和远程连接协议&#xff0c;可以帮助用户在Windows系统上轻松管理远程计算机。MobaXterm支持SSH、Telnet、RDP、VNC等多种远程连接协议&#xff0c;同时还集成了X11服务器&#xff0c;可…
阅读更多...
Pormise---如何解决javascript中回调的信任问题？【详解】

Pormise---如何解决javascript中回调的信任问题？【详解】

如果阅读有疑问的话&#xff0c;欢迎评论或私信&#xff01;&#xff01; 本人会很热心的阐述自己的想法&#xff01;谢谢&#xff01;&#xff01;&#xff01; 文章目录 回调中的信任问题回调给我们带来的烦恼&#xff1f;调用过早调用过晚调用的次数太少或太多调用回调时未能…
阅读更多...
【在python中import包】解决方案：使用脚本中sys.path.append(到当前路径的str)，将包的父目录添加到sys目录中

【在python中import包】解决方案：使用脚本中sys.path.append(到当前路径的str)，将包的父目录添加到sys目录中

python脚本中的sys.path.append("…")详解 前言 当我们导入一个模块时&#xff1a; import xxx &#xff0c;默认情况下python解释器会搜索当前目录、已安装的内置模块和第三方模块。 搜索路径存放在sys模块的path中。【即默认搜索路径可以通过sys.path打印查看】 sy…
阅读更多...
YOLOv9来咧！

YOLOv9来咧！

文章目录 论文:主要内容一、提出使用PGI&#xff08;Programmable Gradient Information&#xff0c;可编程梯度信息&#xff09;来解决信息瓶颈问题和深度监督机制不适合轻量级神经网络的问题。二、设计了GELAN&#xff08;Generalized ELAN &#xff0c;广义ELAN&#xff09;…
阅读更多...
Android 仿信号格子强度动画效果实现

Android 仿信号格子强度动画效果实现

效果图 在 Android 中&#xff0c;如果你想要绘制一个圆角矩形并使其居中显示&#xff0c;你可以使用 Canvas 类 drawRoundRect 方法。要使圆角矩形居中&#xff0c;你需要计算矩形的位置&#xff0c;这通常涉及到确定矩形左上角的位置&#xff08;x, y&#xff09;&#xff0…
阅读更多...
性能全面提升！探索ONLYOFFICE最新8.0版：更快速、更强大，PDF表单编辑轻松搞定！

性能全面提升！探索ONLYOFFICE最新8.0版：更快速、更强大，PDF表单编辑轻松搞定！

文章目录 PDF表单功能表单模板 屏幕朗读器功能EXCEL新增功能单变量求解图表向导数字排序 PPT 新增功能新增语言区域设置和优化插件界面 ONLYOFFICE 是由 Ascensio System SIA 推出的一款功能强大的办公套件&#xff0c;其中提供了适用于文本文档、表格以及演示文稿的在线编辑软…
阅读更多...
如何使用Docker部署MongoDB并结合内网穿透实现远程访问本地数据库

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

文章目录 前言1. 安装Docker2. 使用Docker拉取MongoDB镜像3. 创建并启动MongoDB容器4. 本地连接测试5. 公网远程访问本地MongoDB容器5.1 内网穿透工具安装5.2 创建远程连接公网地址5.3 使用固定TCP地址远程访问 正文开始前给大家推荐个网站&#xff0c;前些天发现了一个巨牛的 …
阅读更多...
C++ Primer 笔记（总结，摘要，概括）——第5章 语句

C++ Primer 笔记（总结，摘要，概括）——第5章 语句

目录 5.1 简单语句 5.2 语句作用域 5.3 条件语句 5.3.1 if语句 5.3.2 switch语句 5.4 迭代语句 5.4.1 while语句 5.4.2 传统的for语句 5.4.3 范围for语句 5.4.4 do while语句 5.5 跳转语句 5.5.1 break语句 5.5.2 continue语句 5.5.3 goto语句 5.6 try语句块和异常处理 5…
阅读更多...
OpenWRT部署web站点并结合内网穿透实现无公网ip远程访问

OpenWRT部署web站点并结合内网穿透实现无公网ip远程访问

文章目录 前言1. 检查uhttpd安装2. 部署web站点3. 安装cpolar内网穿透4. 配置远程访问地址5. 配置固定远程地址 前言 uhttpd 是 OpenWrt/LuCI 开发者从零开始编写的 Web 服务器&#xff0c;目的是成为优秀稳定的、适合嵌入式设备的轻量级任务的 HTTP 服务器&#xff0c;并且和…
阅读更多...
APP被针对攻击了，要怎么解决

APP被针对攻击了，要怎么解决

随着APP行业的兴起&#xff0c;游戏公司异军突起&#xff0c;不管是在控证还是攻击方面都是属于最复杂的一个场面&#xff0c;游戏APP逐渐成为DDOS流量攻击的“重灾区”。没有提前做好了解就盲目进军游戏APP行业&#xff0c;一旦被攻击就会让公司束手无策。那么&#xff0c;刚上…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023