Linux | 匿名管道和命名管道：进程间通信数据流的桥梁

目录

1、进程间通信目的

2、管道——匿名管道和命名管道

匿名管道

匿名管道的示例代码：将数据写入管道、子进程从管道读取数据并将其输出到bash中

父子进程通过匿名管道建立通信

重点：管道的五个特点

命名管道（也称为FIFO）

a. 创建命名管道 - mkfifo()

b. 使用open函数打开命名管道文件

c. 读写命名管道- read() 和 write()

d. 关闭和删除命名管道

例子：使用命名管道实现进程间的通信

1、进程间通信目的

进程间通信（IPC：Inter Processes Communication）是不同进程之间进行信息交互和状态传递的机制。为什么需要进程间通信呢？

主要有以下目的：

  1. 数据传输：一个进程需要将它的数据发送给另一个进程。这可以是任何类型的数据，例如文件内容、消息、命令等。
  2. 资源共享：多个进程之间共享同样的资源。这可以是共享内存、文件、网络连接等。通过进程间通信，它们可以协调使用这些资源。
  3. 通知事件：一个进程需要向另一个或一组进程发送消息，通知它们发生了某种事件。例如，当一个进程终止时，它可以通知父进程。
  4. 进程控制：某些进程希望完全控制另一个进程的执行，例如调试进程。控制进程可以拦截另一个进程的陷入和异常，并实时了解其状态变化。

2、管道——匿名管道和命名管道

管道是一种最古老的进程间通信（IPC）机制，允许具有亲缘关系的进程（例如父子进程）之间进行通信。我们将从一个进程连接到另一个进程的数据流称为“管道”。

在Unix系统中，管道有两种类型：匿名管道和命名管道。

匿名管道
    • 匿名管道是最常见的管道形式，用于在具有父子关系的进程之间传递数据。
    • 使用pipe系统调用创建匿名管道，它返回一对文件描述符，其中fd[0]表示读端，fd[1]表示写端。
    • 数据通过写入一个端并从另一个端读取来在进程之间传递。
#include <unistd.h>
功能:创建一无名管道
原型：
int pipe(int fd[2]);
参数：
fd：文件描述符数组,其中fd[0]表示读端, fd[1]表示写端
//0是嘴巴所以是读 1是笔所以是写
返回值:成功返回0，失败返回错误代码

匿名管道的示例代码：将数据写入管道、子进程从管道读取数据并将其输出到bash中
#include<stdio.h>
#include<stdlib.h>
#include<string.h>
#include<unistd.h>
int main(void) {int fds[2];char buf[100];int len;if (pipe(fds) == -1) {perror("make pipe fail");exit(1);}// Read from stdinwhile (fgets(buf, 100, stdin)) {len = strlen(buf);// Write into the pipe// 此处体现了一切皆文件的思想(管道被当作文件描述符也可以使用系统文件接口)// 管道可以抽象为内存中的文件，不占用磁盘空间if (write(fds[1], buf, len) != len) {perror("write to pipe");break;}memset(buf, 0x00, sizeof(buf));// Read from the pipeif ((len = read(fds[0], buf, 100)) == -1) {perror("read from pipe");break;}// Write to stdoutif (write(1, buf, len) != len) {perror("write to stdout");break;}}return 0;
}
父子进程通过匿名管道建立通信

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/types.h>int main() {int pipefd[2];pid_t pid;//pipe函数创建管道if (pipe(pipefd) == -1) {perror("pipe error");exit(EXIT_FAILURE);}//fork函数创建子进程pid = fork();if (pid == -1) {perror("fork error");exit(EXIT_FAILURE);}//父子分流，子进程写、父进程读。if (pid == 0) { // 子进程close(pipefd[0]); // 关闭读端write(pipefd[1], "hello", 5); // 写入数据到管道close(pipefd[1]); // 关闭写端exit(EXIT_SUCCESS);} else { // 父进程close(pipefd[1]); // 关闭写端char buf[10] = {0};read(pipefd[0], buf, 10); // 从管道读取数据printf("buf=%s\n", buf);close(pipefd[0]); // 关闭读端}return 0;
}

重点：管道的四种情况和五个特点

管道的四种情况：

  1. 如果管道是空的，则读取端被阻塞
  2. 如果管道是满的，则写入端被阻塞
  3. 如果关闭了管道的读端，那管道没必要存在，被13号信号杀死
  4. 如果关闭了管道的写端，读取完毕后管道返回0，表示读到了文件末尾

管道的五个特点：

  1. 匿名管道只能用于有血缘关系的进程通信，常用于父子间通信。
  2. 管道内部实现了同步机制，读写具有明显的顺序性。
  3. 管道的生命周期是随进程的，随着进程使用管道而创建缓冲区, 随进程的退出而释放销毁。
  4. 管道通通信是面向字节流的，读写次数是可以不匹配的，读到的数据可能是单次残缺的，也可能是多次堆积的
  5. 管道通信是特殊的半双工模式，半双工是指支持读写，但不能同时读写，特殊在只支持信息的单向传递。

命名管道（也称为FIFO）
    • 命名管道是一个管道文件，是一种具有持久性的管道，可以由不相关的进程使用。
    • 使用$ mkfifo filename命令在命令行中创建管道或使用c语言中的系统调用接口int mkfifo(const char *filename,mode_t mode);创建命名管道。
    • 命名管道在文件系统中有一个路径名，允许不同进程通过该路径名进行通信。
a. 创建命名管道 - mkfifo()
#include <sys/types.h>
#include <sys/stat.h>int mkfifo(const char *pathname, mode_t mode);
  • pathname：要创建的命名管道的路径名。
  • mode：设置文件权限，通常使用八进制数，如 0666 表示读写权限。
#include <sys/types.h>
#include <sys/stat.h>
#include <stdio.h>int main() {if (mkfifo("/tmp/my_fifo", 0666) == -1) {perror("mkfifo error");return 1;}printf("Named pipe created successfully\n");return 0;
}

b. 使用open函数打开命名管道文件
  • open() 函数用于打开或创建文件，并返回一个文件描述符。

常用的语法格式如下：

#include<sys/types.h>
#include<sys/stat.h>
#include<fcntl.h>
int fd = open("文件路径", 模式);
  • 关于参数：
    • 文件路径：可以使用相对路径或绝对路径。例如，"test.txt" 是相对路径，"/home/user/test.txt" 是绝对路径。
    • 模式：
      • O_RDONLY：以只读方式打开文件。
      • O_WRONLY：以只写方式打开文件。
      • O_RDWR：以读写方式打开文件。
      • O_CREAT：如果文件不存在，创建新文件。
#include <fcntl.h>
#include <stdio.h>
#include <unistd.h>int main() {int fd = open("/tmp/my_fifo", O_WRONLY);if (fd == -1) {perror("open error");return 1;}printf("Named pipe opened successfully\n");close(fd);return 0;
}

c. 读写命名管道- read() 和 write()
#include <unistd.h>ssize_t read(int fd, void *buf, size_t count);
ssize_t write(int fd, const void *buf, size_t count);
  • fd：文件描述符。
  • buf：数据缓冲区。
  • count：要读写的字节数。
#include <fcntl.h>
#include <unistd.h>
#include <stdio.h>
#include <string.h>int main() {int fd = open("/tmp/my_fifo", O_WRONLY);const char *message = "Hello, World!";write(fd, message, strlen(message));close(fd);fd = open("/tmp/my_fifo", O_RDONLY);char buffer[100];read(fd, buffer, sizeof(buffer));printf("Received: %s\n", buffer);close(fd);return 0;
}

d. 关闭和删除命名管道
#include <unistd.h>
#include <stdio.h>int close(int fd);
int unlink(const char *pathname);
  • close(fd)：关闭文件描述符。
  • unlink(pathname)：删除文件或命名管道。
#include <fcntl.h>
#include <unistd.h>
#include <stdio.h>int main() {int fd = open("/tmp/my_fifo", O_WRONLY);if (fd == -1) {perror("open error");return 1;}close(fd);unlink("/tmp/my_fifo");printf("Named pipe closed and removed successfully\n");return 0;
}

例子：使用命名管道实现进程间的通信

1. 信息发送程序

#include "pipe.hpp" // 引入管道相关的头文件
using namespace std; // 使用标准命名空间int main(int argc, char* argv[]) // 主函数
{// 检查命令行参数的数量是否正确if(argc != 2){cout << "enter error " <<endl; // 如果参数数量不正确，输出错误信息return 1; // 并返回错误码1}int count = stoi(string(argv[1])); // 将命令行参数转换为整数，表示要发送的消息数量CreatePipe(); // 创建管道int wfd = OpenPipeWrite(); // 打开管道的写端string msg; // 定义一个字符串变量用于存储输入的消息while(count--) // 循环发送消息，直到count减到0{cin >> msg; // 从标准输入读取一条消息write(wfd, msg.c_str(), msg.size()); // 将消息写入管道sleep(1); // 每次写入后暂停1秒}DeletePipe(); // 删除管道return 0; // 程序正常结束，返回0
}

 2. 信息接收程序

#include "pipe.hpp" // 引入管道操作相关的自定义头文件int main()
{char buffer[MAX] = {0}; // 定义一个字符数组作为缓冲区，用于存储从管道读取的数据，初始化为0int fd = OpenPipeRead(); // 打开管道的读端，返回文件描述符while (1) // 无限循环，持续读取管道中的数据{int n = read(fd, buffer, MAX); // 从管道读取数据到缓冲区，返回读取的字节数if(n > 0) // 如果读取到数据cout << buffer << endl; // 输出缓冲区的内容else if(n == 0) // 如果没有数据可读（管道关闭）return 0; // 程序正常退出，返回0else // 如果读取过程中发生错误return 1; // 程序异常退出，返回1}return 0; // 正常情况下不会执行到这里，因为前面的循环是无限的
}

 3. 头文件pipe.hpp

#include<iostream> // 引入标准输入输出库
#include<sys/types.h> // 引入系统类型定义
#include<sys/stat.h> // 引入文件状态定义
#include<cstdio> // 引入标准输入输出库
#include<fcntl.h> // 引入文件控制选项定义
#include <string> // 引入字符串库
#include<unistd.h> // 引入UNIX标准函数定义
#include<cstring> // 引入字符串操作
const char* pipepath = "./mypipe"; // 定义管道路径
mode_t pipemode = 0666; // 定义管道的权限模式
const int MAX = 1024; // 定义最大缓冲区大小
using std::cout; // 使用命名空间std中的cout
using std::cin; // 使用命名空间std中的cin
using std::endl; // 使用命名空间std中的endl// 创建命名管道的函数
bool CreatePipe()
{// 使用mkfifo创建命名管道，如果创建失败则输出错误信息并返回falseif(mkfifo(pipepath, pipemode) < 0){perror("mkfifo error"); // 输出错误信息return false; // 返回false表示创建失败}cout << "mkfifo success" << endl; // 输出创建成功的信息return true; // 返回true表示创建成功
}// 打开管道的通用函数
int OpenPipe(int flags)
{return open(pipepath, flags); // 使用open函数打开管道，返回文件描述符
}// 打开管道读端的函数
int OpenPipeRead()
{return OpenPipe(O_RDONLY); // 以只读模式打开管道
}// 打开管道写端的函数
int OpenPipeWrite()
{return OpenPipe(O_WRONLY); // 以只写模式打开管道
}// 删除命名管道的函数
void DeletePipe()
{unlink(pipepath); // 使用unlink函数删除管道
}

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

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

相关文章

每日一题，零基础入门FPGA——工程师在线精讲，直播预告

每日一题，零基础入门FPGA——工程师在线精讲，直播预告

题目传送门&#xff1a;F学社 zzfpga.com/StudentPlatform/Sheet/QuestionBankhttp://zzfpga.com/StudentPlatform/Sheet/QuestionBank 【第Ⅰ期题目 * 5】 请使用D触发器和必要的逻辑门实现此同步时序电路&#xff0c;用Verilog语言描述。 【第Ⅰ期题目 * 4】 请设计一个0…
阅读更多...
观测云核心技术揭秘：基于时间的半结构化数据模型

观测云核心技术揭秘：基于时间的半结构化数据模型

前言 众所周知&#xff0c;真正意义上的统一监控观测平台本质上是一个超大的数据湖&#xff0c;其存储了大量的来自监控指标&#xff0c;各种各样的日志&#xff0c;各种各样的链路追踪以及包括用户访问行为等海量的可观测性数据。 这些海量数据有什么特点呢&#xff1f; 首先…
阅读更多...
【网络安全】逻辑漏洞：绕过应用程序重要功能

【网络安全】逻辑漏洞：绕过应用程序重要功能

未经许可，不得转载。 文章目录 正文漏洞影响正文 目标：xxx.com 一个流行的汽车平台，允许用户为经销商留下评论。该平台有一个功能，用户可以点赞评论，并且它限制每个用户对每个评论只能点赞一次。 然而，我找到了绕过的方法（并不是并发）。 在点击“点赞”按钮时拦截请…
阅读更多...
新手指南 | 研发人员奖金激励方案步骤实操

新手指南 | 研发人员奖金激励方案步骤实操

研发团队是一个非常独特的存在。在研发人员的薪酬、激励方案设计上也是很多HR的痛点。 毕竟工作变化大&#xff0c;职责变化快、个体能力差异大、投入了不一定会有产出、多线程并行&#xff0c;贡献难判定、知识密度高&#xff0c;价值难衡量等等... 基于以上难点&#xff0c…
阅读更多...
【系统架构设计】嵌入式系统设计（1）

【系统架构设计】嵌入式系统设计（1）

【系统架构设计】嵌入式系统设计&#xff08;1&#xff09; 嵌入式系统概论嵌入式系统的组成硬件嵌入式处理器总线存储器I/O 设备与接口 软件 嵌入式开发平台与调试环境交叉平台开发环境交叉编译环境调试 嵌入式系统概论 嵌入性、专用性、计算机系统是嵌入式系统的三个基本的核…
阅读更多...
0基础轻松玩转.NET Web API 8.0【CICD】项目实战

0基础轻松玩转.NET Web API 8.0【CICD】项目实战

1.背景 最近在学习CI/CD&#xff0c;为了加快熟悉CI/CD&#xff0c;我实操了下基于.Net 8.0的CI/CD项目实战。Ci/CD就是自动化作业&#xff0c;实现项目自动编译、发布、执行等&#xff0c;也有用于拉取推送数据的场景。本文主要介绍了在win 11下搭建CI/CD&#xff0c;实现自动…
阅读更多...
UEFI——PCD的简单使用

UEFI——PCD的简单使用

一、PCD的定义及概念 在UEFI固件接口中&#xff0c;PCD&#xff08;Platform Configuration Database&#xff09;是一个用于存储和访问平台特定配置信息的机制。PCD允许UEFI驱动程序和应用程序在运行时获取和设置平台相关的参数&#xff0c;而无需硬编码这些值。PCD变量可以被…
阅读更多...
加速电商物流效率：推荐几款实用的快递批量查询工具

加速电商物流效率：推荐几款实用的快递批量查询工具

做电商必不可少的快递批量查询平台分享&#xff1a;固乔快递查询助手使用全攻略 在电商行业日益竞争的今天&#xff0c;高效管理物流信息成为了商家们不可或缺的一环。面对每天成百上千的订单和快递单号&#xff0c;如何快速、准确地查询并跟踪物流状态&#xff0c;成为了电商…
阅读更多...
stun和trun

stun和trun

在 WebRTC 中&#xff0c;STUN&#xff08;Session Traversal Utilities for NAT&#xff09;和 TURN&#xff08;Traversal Using Relays around NAT&#xff09;是用于NAT穿透的两种不同的技术&#xff0c;它们解决的问题不同&#xff0c;因此在某些情况下需要同时使用。 ST…
阅读更多...
产品需求过程管理重要性

产品需求过程管理重要性

产品需求过程管理重要性 背景 以下都是真实事项经历回顾&#xff0c;在产品开发过程中&#xff0c;产品经理与研发团队之间的沟通至关重要。然而&#xff0c;沟通不畅或信息缺失常常导致需求无法准确传达&#xff0c;最终影响产品的成功。以下是一些常见的问题&#xff1a; 1.需…
阅读更多...
C++基础【字符串】（Ac-Wing）

C++基础【字符串】（Ac-Wing）

字符串加空格 #include <iostream> #include <cstring> #include <algorithm>using namespace std;int main() {string s;getline (cin, s);for (int i 0; i < s.size(); i )cout << s[i] << " "; }字符串插入 #include<bits/…
阅读更多...
使用HTTP代理注意的点

使用HTTP代理注意的点

“在网络世界中&#xff0c;HTTP代理扮演着桥梁的角色&#xff0c;帮助用户匿名访问网站、加速网页加载、绕过地区限制等。然而&#xff0c;不当或不安全地使用HTTP代理也可能带来一系列问题。以下是在使用HTTP代理时需要注意的几个关键点。” 一、选择可靠的代理服务商 首先&…
阅读更多...
鹰眼应急实时三维重建装备，高质量交付中！

鹰眼应急实时三维重建装备，高质量交付中！

在《2024年地方应急管理科技信息化任务书》的指导和应急管理万亿国债支撑下&#xff0c;全国各地正积极推进应急管理现代化建设&#xff0c;全力提升“数据汇聚服务能力、监测预警能力、指挥调度能力、支撑保障能力”四项应急管理能力。 制定标准化流程规范&#xff0c;保障交…
阅读更多...
[Leetcode 47][Medium]-全排列 II-回溯(全排列问题)

[Leetcode 47][Medium]-全排列 II-回溯(全排列问题)

目录 一、题目描述 二、整体思路 三、代码 一、题目描述 原题地址 二、整体思路 和上一道Leetcode46相比&#xff0c;有变化的地方是要排除重复组合的情况。那么在组合问题中去除重复组合的方法是先对数组进行排序,然后在回溯函数中判断当前元素与上一个元素是否相同,若相同…
阅读更多...
系统架构师考试学习笔记第三篇——架构设计高级知识（11）软件可靠性基础知识

系统架构师考试学习笔记第三篇——架构设计高级知识（11）软件可靠性基础知识

本章知识点&#xff1a; 第11课时主要学习软件可靠性基本概念、建模、管理、设计、测试和评价等内容。本课时内容侧重于概念知识,根据以往全国计算机技术与软件专业技术资格(水平)考试的出题规律,考查的知识点多来源于教材,扩展内容较少。根据考试大纲,本课时知识点会涉及单项选…
阅读更多...
赞奇科技与华为云共襄828 B2B企业节，激活数字内容“云”创作

赞奇科技与华为云共襄828 B2B企业节，激活数字内容“云”创作

8月28日&#xff0c;在2024中国国际大数据产业博览会上&#xff0c;第三届828 B2B企业节正式开幕&#xff0c;旨在融通数智供需&#xff0c;加速企业智改数转&#xff0c;助推中国数智产业实力再升级。 828 B2B企业节是全国首个基于数字化赋能的企业节&#xff0c;由华为联合上…
阅读更多...
SprinBoot+Vue学生选课微信小程序的设计与实现

SprinBoot+Vue学生选课微信小程序的设计与实现

目录 1 项目介绍2 项目截图3 核心代码3.1 Controller3.2 Service3.3 Dao3.4 application.yml3.5 SpringbootApplication3.5 Vue3.6 uniapp代码 4 数据库表设计5 文档参考6 计算机毕设选题推荐7 源码获取 1 项目介绍 博主个人介绍&#xff1a;CSDN认证博客专家&#xff0c;CSDN平…
阅读更多...
C++使用日志库经验总结

C++使用日志库经验总结

1、log4cpp日志源文件路径设置 在 Visual Studio 中&#xff0c;C 项目的日志格式可以通过设置项目的属性来调整。如果你想要使用完整路径来显示诊断消息&#xff0c;可以在项目属性中的“C/C”选项卡下的“高级”属性页中找到“使用完整路径”&#xff08;/FC&#xff09;选项…
阅读更多...
探索数字化生态平台的特色功能，开启未来新征程

探索数字化生态平台的特色功能，开启未来新征程

在数字化浪潮席卷全球的今天&#xff0c;数字化生态平台正以惊人的速度崛起&#xff0c;成为推动经济发展与社会进步的强大引擎。那么&#xff0c;这些平台究竟有哪些独特的特色功能呢&#xff1f;让我们一同深入探索。 首先&#xff0c;我们要明确数字化生态平台的定义。它是利…
阅读更多...
ParallelsDesktop19可在任何Mac上运行Windows软件

ParallelsDesktop19可在任何Mac上运行Windows软件

ParallelsDesktop19是一款Mac虚拟机软件&#xff0c;可在任何Mac上运行Windows&#xff0c;体验不同操作系统之间的无缝集成&#xff0c;并具有创新设计和增强功能&#xff0c;如无密码登录与TouchID、支持macOSSonoma14和增强打印选项。此外&#xff0c;它还支持运行更多Windo…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023