Linux进程通信之管道

news2024/10/7 4:30:47

目录

1、无名管道

1.无名管道的特点

2.pipe函数创建管道

3.图例 

  

2、命名管道(FIFO)

1.命名管道的特点

2.mkfifo 函数-创建命名管道

 3.示例

1.循环读取数据

2.循环写入数据


1、无名管道

管道通常指的就是无名管道,

1.无名管道的特点

  1. 管道是半双工的,只支持数据的单向传输,有固定的读端和写端。
  2. 无名管道用于有亲缘关系的进程间通信
  3. 无名管道可以看作一种特殊的文件,对它的读写我们可以直接使用普通的read、write等函数进行操作,但是注意无名管道并不是普通的文件,它不存在任何的文件系统中,只存在于内存中
  4. 管道里的数据被读走了就会从管道中消失

2.pipe函数创建管道

pipe 函数是用于创建管道的系统调用,通常用于在父子进程之间进行单向通信

函数原型

int pipe(int pipefd[2]);

参数:

  • pipefd: 一个包含两个文件描述符的整数数组,pipefd[0] 用于读取数据,pipefd[1] 用于写入数据。

返回值:

  • 如果成功,返回 0。
  • 如果失败,返回 -1,并设置 errno 指示错误类型。

pipe函数会创建两个文件描述符,pipefd[0]是读端、pipefd[1]是写端

需要注意的是,pipe 函数创建的管道是阻塞的,如果管道已满(写端写入速度过快),写操作将会被阻塞,直到有空间可用

3.图例 

  

如果要使数据从父进程流向子进程就需要关闭父进程的读端和子进程的写端,反之就使数据从子进程流向父进程 

#include <stdio.h>
#include <unistd.h>
#include <string.h>
#include <stdlib.h>

int main() {
    int fd[2];            // 用于存储管道的文件描述符,fd[0] 为读取端,fd[1] 为写入端
    int pid;              // 用于存储 fork 函数的返回值,表示当前是父进程还是子进程
    char buf[128] = {0};  // 用于存储从管道中读取的数据

    // 创建管道
    if (pipe(fd) == -1) {
        printf("pipe 创建失败\n");
        perror("pipe");
        exit(-1);  // 如果 pipe 创建失败,退出程序,返回 -1
    }

    // 创建子进程
    pid = fork();
    if (pid < 0) {
        printf("fork 创建失败\n");
        perror("fork");
        exit(-1);  // 如果 fork 创建失败,退出程序,返回 -1
    } else if (pid > 0) {  // 父进程
        printf("parent process\n");

        close(fd[0]);  // 关闭读取端,因为父进程只负责写入数据
        write(fd[1], "holle wjh happy", strlen("holle wjh happy"));  // 向管道写入数据
        wait(NULL);  // 等待子进程结束

    } else {  // 子进程
        printf("child process\n");

        close(fd[1]);  // 关闭写入端,因为子进程只负责读取数据
        read(fd[0], buf, 128);  // 从管道读取数据到 buf 中
        printf("read: %s\n", buf);

        exit(0);  // 子进程正常结束,返回 EXIT_SUCCESS
    }

    return 0;
}

2、命名管道(FIFO)

命名管道(Named Pipe)是一种特殊类型的管道,与无名管道(通过 pipe 创建的)不同,它具有文件系统中的名字,并且可以通过文件系统路径来访问。命名管道在进程间通信中提供了一种有趣而强大的方式。

1.命名管道的特点

  1. 命名管道是通过在文件系统中创建一个具有名字的特殊文件来实现的。这个文件的路径就是命名管道的名字
  2. 命名管道的使用方式与文件类似,可以使用标准的文件读写操作函数来进行进程间通信。打开命名管道后,可以使用 readwrite 等函数进行数据传输。
  3. 命名管道常用于独立的进程之间通信。在这种情况下,各个进程可以通过打开相同路径名的命名管道文件来进行通信,也就是说命名管道可以在无关进程之间进行通信,这里和无名管道不同
  4. 像无名管道一样,命名管道的读写操作也是阻塞的。如果没有数据可读,读取操作会被阻塞,直到有数据为止;如果管道已满,写入操作会被阻塞,直到有空间可用。

2.mkfifo 函数-创建命名管道

函数原型

int mkfifo(const char *pathname, mode_t mode);

mkfifo是 "make FIFO" 的缩写,用于创建一个新的命名管道

参数:

  • pathname:要创建的命名管道的路径名。
  • mode:创建的文件权限。通常使用八进制表示,例如 0666

返回值:

  • 如果成功创建命名管道,返回 0。
  • 如果失败,返回 -1,并设置 errno 表示具体的错误类型。

注意:

  • 在成功创建命名管道后,可以使用标准的文件操作函数(如 openreadwrite 等)来进行读写操作。
  • 如果已经存在同名的普通文件或目录,mkfifo 会失败。

 3.示例

1.循环读取数据
#include <sys/stat.h>
#include <sys/types.h>
#include <fcntl.h>
#include <unistd.h>
#include <string.h>
#include <stdlib.h>
#include <errno.h>
#include <stdio.h>

int main() {
    char buf[30] = {0};

    // 尝试创建命名管道
    if (mkfifo("./file", 0600) == -1 && errno != EEXIST) {
        printf("mkfifo 失败!!!\n");
        perror("mkfifo");
        exit(EXIT_FAILURE);
    } else if (errno == EEXIST) {
        perror("mkfifo");
        // 如果管道已经存在,继续执行
    }

    // 打开命名管道进行读取
    int fd = open("./file", O_RDONLY);
    if (fd == -1) {
        printf("open 失败!!!\n");
        perror("open");
        exit(EXIT_FAILURE);
    } else {
        // 循环读取数据
        while (1) {
            int read_count = read(fd, buf, 20);
            if (read_count > 0) {
                printf("read_count = %d, reads = %s\n", read_count, buf);
            } else if (read_count == 0) {
                // 如果 read 返回 0,表示已经读到文件末尾,可以采取适当的处理方式
                printf("End of file reached. Exiting...\n");
                break;
            } else {
                // 处理 read 函数返回的错误
                perror("read");
                break;
            }
        }
        // 关闭文件描述符
        close(fd);
    }

    return 0;
}
2.循环写入数据
#include <stdio.h>
#include <unistd.h>
#include <string.h>
#include <stdlib.h>
#include <errno.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>

int main() {
    // 创建一个名为 "file" 的命名管道
    if (mkfifo("./file", 0600) == -1 && errno != EEXIST) {
        // 如果创建失败且不是因为文件已存在,则输出错误信息并退出程序
        printf("mkfifo 失败!!!\n");
        perror("mkfifo");
        exit(EXIT_FAILURE);
    } else if (errno == EEXIST) {
        // 如果管道已经存在,则输出相应的错误信息
        perror("mkfifo");
    }

    // 打开命名管道进行写入
    int fd = open("./file", O_WRONLY);
    if (fd == -1) {
        // 如果打开失败,则输出错误信息
        perror("open");
    } else {
        // 在循环中每秒写入一次数据到管道中
        while (1) {
            sleep(1);
            int write_count = write(fd, "happy bay wjh", strlen("happy bay wjh"));
            printf("write_count = %d\n", write_count);
        }

        // 关闭文件描述符
        close(fd);
    }

    return 0;
}

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

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

相关文章

Support Vector Machine 建模(基于三种数据集)

目录 一、 SVM 对于 Iris 数据集的处理 建模&#xff1a; 二、 SVM 对于 弯月数据集的处理 建模&#xff1a; 三、 SVM 对于 direct marketing campaigns (phone calls)数据集的处理 建模&#xff1a; Support Vector Machine (SVM)是一种机器学习算法&#xff0c;属于监…

数据结构排序——选择排序与堆排序(c语言实现)

数据结构排序——选择排序与堆排序&#xff08;c语言实现&#xff09; 今天继续排序的内容&#xff1a; 文章目录 1.选择排序1.1基本介绍1.2代码实现1.2.1基础款1.2.2进阶款 2.堆排序2.1基本介绍2.2代码实现 1.选择排序 1.1基本介绍 选择排序&#xff08;Selection Sort&#…

RTMP vs SRT:延迟与最大带宽的比较

引言 文来自Haivision的白皮书&#xff0c;比较了RTMP和SRT两种流媒体协议的优缺点&#xff0c;并通过实验测试了两种协议在延迟和最大带宽两方面的表现。 本文福利&#xff0c; 免费领取C音视频学习资料包学习路线大纲、技术视频/代码&#xff0c;内容包括&#xff08;音视频…

Labelimg打标工具编译版使用介绍——免安装conda等python虚拟环境,简单易用上手快,不容易报错

首先直接给出免积分的下载地址&#xff0c;开源软件&#xff0c;直接共享给csdn的各位开发者&#xff0c;求个三连不过分吧。点赞关注收藏。谢谢各位支持 资源地址如下 1 打开D:\xxxxx\labelImg\data内的predefined_classes.txt文件&#xff0c; 修改其中的类别为自己需要的…

JavaWeb——后端之登录功能

6. 登录功能 6.1 登录认证 只进行用户名和密码是否存在的操作 Slf4j RestController public class LoginController {Autowiredpublic EmpService empService;PostMapping("/login")public Result login(RequestBody Emp emp) {log.info("{}员工登录", …

数据结构——队列(Queue)

目录 1.队列的介绍 2.队列工程 2.1 队列的定义 2.1.1 数组实现队列 2.1.2 单链表实现队列 2.2 队列的函数接口 2.2.1 队列的初始化 2.2.2 队列的数据插入&#xff08;入队&#xff09; 2.2.3 队列的数据删除&#xff08;出队&#xff09; 2.2.4 取队头数据 2.2.5 取队…

基于JAVA的教学过程管理系统 开源项目

目录 一、摘要1.1 项目介绍1.2 项目录屏 二、功能模块2.1 教师端2.2 学生端2.3 微信小程序端2.3.1 教师功能如下2.3.2 学生功能如下 三、系统展示 四、核心代码4.1 查询签到4.2 签到4.3 查询任务4.4 查询课程4.5 生成课程成绩 六、免责说明 一、摘要 1.1 项目介绍 基于JAVAVu…

56、Flink 的Data Source 原理介绍

Flink 系列文章 一、Flink 专栏 Flink 专栏系统介绍某一知识点&#xff0c;并辅以具体的示例进行说明。 1、Flink 部署系列 本部分介绍Flink的部署、配置相关基础内容。 2、Flink基础系列 本部分介绍Flink 的基础部分&#xff0c;比如术语、架构、编程模型、编程指南、基本的…

SpringBoot Import提示Cannot resolve symbol

背景 项目开发过程中经常在IDEA中出现Cannot resolve symbol&#xff0c;但是依赖确定已经通过maven或者gradle依赖了 常见原因 IDEA 存在缓存 File -> Invalidate Caches/Restart jar包的scope不正常&#xff0c;如果只是runtime则无法import&#xff0c;需要调整为com…

LeetCode 2221. 数组的三角和

文章目录 1. 题目 2. 解题 1. 题目 给你一个下标从 0 开始的整数数组 nums &#xff0c;其中 nums[i] 是 0 到 9 之间&#xff08;两者都包含&#xff09;的一个数字。 nums 的 三角和 是执行以下操作以后最后剩下元素的值&#xff1a; num…

一天一个设计模式---工厂方法

概念 工厂模式是一种创建型设计模式&#xff0c;其主要目标是提供一个统一的接口来创建对象&#xff0c;而不必指定其具体类。工厂模式将对象的实例化过程抽象出来&#xff0c;使得客户端代码不需要知道实际创建的具体类&#xff0c;只需通过工厂接口或方法来获取所需的对象。…

探讨JS混淆技术及其加密解密实例

引言 在当前计算机科学领域中&#xff0c;保护软件代码的安全性和隐私性变得愈发重要。为了防止黑客攻击和恶意软件分析&#xff0c;开发人员采用各种技术来混淆和加密其代码&#xff0c;其中包括JS混淆技术。本文将介绍JS混淆技术的原理和应用&#xff0c;并提供一些相关的加密…

印章管理详解|契约锁帮助提前预防99%的印章风险

传统实体印章不仅存在私刻私盖、盗用乱用、易伪造等安全隐患&#xff0c;此外&#xff0c;线下面签的方式也不便于异地、非工作时间用印&#xff0c;分公司用印常常两地来回跑。组织的印章到底怎么“管”才能保障安全和使用效率&#xff1f; 一、 印章管理风险有哪些&#xff…

Python爬虫-爬取豆瓣Top250电影信息

&#x1f388; 博主&#xff1a;一只程序猿子 &#x1f388; 博客主页&#xff1a;一只程序猿子 博客主页 &#x1f388; 个人介绍&#xff1a;爱好(bushi)编程&#xff01; &#x1f388; 创作不易&#xff1a;喜欢的话麻烦您点个&#x1f44d;和⭐&#xff01; &#x1f388;…

物理环境测评

1.1 物理位置选择 1.1.1 防震防风防雨 安全要求 机房场地选择在具有防震防风防雨等能力的建筑内 测评方法 核查是否有建筑物抗震设防审批文档 核查是否有雨水渗透的痕迹 核查是否有可灵活开启的窗户&#xff0c;若有窗户&#xff0c;是否做了封闭&#xff0c;上锁等防护措…

lua每日tips

目录 1&#xff0c;EC618系列不支持win7下刷机2&#xff0c;为何室内无法gps定位3&#xff0c;Lot平台自动锁定4&#xff0c; LuaTools的部分操作界面是支持拖拽功能的5&#xff0c;Air780E省略 1&#xff0c;EC618系列不支持win7下刷机 1&#xff0c; EC618系列不支持win7下刷…

数据结构-怀化学院期末题(322)

图的深度优先搜索 题目描述&#xff1a; 图的深度优先搜索类似于树的先根遍历&#xff0c;是树的先根遍历的推广。即从某个结点开始&#xff0c;先访问该结点&#xff0c;然后深度访问该结点的第一棵子树&#xff0c;依次为第二顶子树。如此进行下去&#xff0c;直到所有的结点…

nginx部署前端项目自动化脚本

文章目录 配置入口服务器nginx的conf.d使用docker创建一个nginx配置自动化脚本 前言 将项目 通过nginx 部署到 新的服务器 通过nginx反向代理出去 配置入口服务器nginx的conf.d 一般在这个文件夹下 找不到使用 find / -name nginx 2>/dev/null 找到nginx 的位置如果有些没有…

限制选中指定个数CheckBox控件(2/2)

实例需求&#xff1a;工作表中有8个CheckBox控件&#xff08;下文中简称为控件&#xff09;&#xff0c;现在需要实现限制用户最多只能勾选4个控件。 在上一篇博客中已经实现了这个需求&#xff0c;其基本思路是用户选中第5个控件时&#xff0c;事件代码将取消勾选最后一个选中…

Python 开源扫雷游戏 PyMine 发布介绍视频

Python 开源扫雷游戏 PyMine 发布介绍视频 Python 开源扫雷游戏 PyMine 是笔者开发的基于 wxPython 的 Python 扫雷游戏&#xff0c;现已发布介绍视频。视频请见&#xff1a;https://www.bilibili.com/video/BV1aW4y1N7Dd/ PyMine 比较忠实的还原了微软的扫雷游戏。在算法设计…