进程管道:父进程和子进程

news2024/11/26 4:24:07

在接下来的对pipe调用的研究中,我们将学习如何在子进程中运行一个与其父进程完全不同的另外一个程序,而不是仅仅运行一个相同程序。我们用exec调用来完成这一工作。这里的一个难点是,通过exec调用的进程需要知道应该访问哪个文件描述符。在前面的例子中,因为子进程本身有file_pipes数据的一份副本,所以这并不成为问题。但经过exec调用后,情况就不一样了,因为原先的进程已经被新的子进程替换了。为解决这个问题,我们可以将文件描述符(它实际上只是一个数字)作为一个参数传递给用exec启动的程序。

为了演示它是如何工作的,我们需要使用两个程序。第一个程序是数据生产者,它负责创建管道和启动子进程,而后者是数据消费者。

实验 管道和exec函数 

(1)下面这个程序pipe3.c是从pipe2.c修改而来。我们在改动的地方加上了阴影,如下所示:

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

#define DEBUG_INFO(format, ...) printf("%s - %d - %s :: "format"\n",__FILE__,__LINE__,__func__ ,##__VA_ARGS__)

void test_01(void){
    int len = 0;
    int fds_pipes[2];
    const char some_data[] = "123";
    const char some_data2[] = "456";
    pid_t pid;
    int res;

    char buf[BUFSIZ + 1];
    char buf2[BUFSIZ + 1];


    memset(buf,0,sizeof(buf));
    memset(buf2,0,sizeof(buf2));

    res = pipe(fds_pipes);
    if(res != 0){
        perror("pipe:");
        return;
    }
    pid = fork();
    if(pid < 0){
        perror("fork:");
        return ;
    }
    if(pid == 0){

        sprintf(buf,"%d",fds_pipes[0]);
        sprintf(buf2,"%d",fds_pipes[1]);
        DEBUG_INFO("CHILD");
        res = execl("/big/work/ipc/_build_/pipe4","pipe4",buf,buf2,(char*)0);
        if(res != 0){
            perror("execl:");
            exit(-1);
        }
        sleep(1);
        exit(0);
    }
    len = write(fds_pipes[1],some_data,BUFSIZ);
    DEBUG_INFO("PARENT:pid = %lu,write -- len = %d\n",getpid(),len);
    exit(0);
}

int main(int argc, char**argv){
    test_01();
    DEBUG_INFO("hello world");
    return 0;
}

(2)数据消费者程序pipe4.c负责读取数据,它的代码要简单得多,如下所示: 

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

#define DEBUG_INFO(format, ...) printf("%s - %d - %s :: "format"\n",__FILE__,__LINE__,__func__ ,##__VA_ARGS__)

void test_01(int argc, char**argv){
    int len = 0;
    pid_t pid;
    int res;
    int fd_write;
    int fd_read;
    char buf[BUFSIZ + 1];

    memset(buf,0,sizeof(buf));
    sscanf(argv[1], "%d", &fd_read);
    sscanf(argv[2], "%d", &fd_write);

    len = read(fd_read,buf,sizeof(buf));
    DEBUG_INFO("read:len = %d,buf = %s,fd_read=%d",len,buf,fd_read);
}

int main(int argc, char**argv){
    test_01(argc,argv);
    DEBUG_INFO("hello world");
    return 0;
}

要记住,pipe3在程序中调用pipe4,运行pipe3时,我们将看到如下所示的输出结果: 

 实验解析

pipe3程序的开始部分和前面的例子一样,用pipe调用创建一个管道,然后用fork调用创建一个新进程。接下来,它用sprintf把读取管道数据的文件描述符保存到一个缓存区中,该缓存区中的内容将构成pipe4程序的一个参数。我们通过execl调用来启动pipe4程序,execl的参数如下所示。

 ❑ 要启动的程序。

❑ argv[0]:程序名。

❑ argv[1]:包含我们想让被调用程序去读取的文件描述符。

❑(char *)0:这个参数的作用是终止被调用程序的参数列表。

pipe4程序从参数字符串中提取出文件描述符数字,然后读取该文件描述符来获取数据。

管道关闭后的读操作 

在继续学习之前,我们再来仔细研究一下打开的文件描述符。至此,我们一直采取的是让读进程读取一些数据然后直接退出的方式,并假设Linux会把清理文件当作是在进程结束时应该做的工作的一部分。

但大多数从标准输入读取数据的程序采用的却是与我们到目前为止见到的例子非常不同的另外一种做法。通常它们并不知道有多少数据需要读取,所以往往采用循环的方法,读取数据——处理数据——读取更多的数据,直到没有数据可读为止。

当没有数据可读时,read调用通常会阻塞,即它将暂停进程来等待直到有数据到达为止。如果管道的另一端已被关闭,也就是说,没有进程打开这个管道并向它写数据了,这时read调用就会阻塞。但这样的阻塞不是很有用,因此对一个已关闭写数据的管道做read调用将返回0而不是阻塞。这就使读进程能够像检测文件结束一样,对管道进行检测并作出相应的动作。注意,这与读取一个无效的文件描述符不同,read把无效的文件描述符看作一个错误并返回-1。

如果跨越fork调用使用管道,就会有两个不同的文件描述符可以用于向管道写数据,一个在父进程中,一个在子进程中。只有把父子进程中的针对管道的写文件描述符都关闭,管道才会被认为是关闭了,对管道的read调用才会失败。我们还将深入讨论这一问题,在学习到O_NONBLOCK标志和FIFO时,我们将看到一个这样的例子。

 把管道用作标准输入和标准输出 

现在,我们已知道了如何使得对一个空管道的读操作失败,下面我们来看一种用管道连接两个进程的更简洁的方法。我们把其中一个管道文件描述符设置为一个已知值,一般是标准输入0或标准输出1。在父进程中做这个设置稍微有点复杂,但它使得子程序的编写变得非常简单。这样做的最大好处是我们可以调用标准程序,即那些不需要以文件描述符为参数的程序。为了完成这个工作,我们需要使用在第3章中介绍过的dup函数。dup函数有两个紧密关联的版本,它们的原型如下所示:

#include <unistd.h>

int dup(int oldfd);
int dup2(int oldfd, int newfd);

dup调用的目的是打开一个新的文件描述符,这与open调用有点类似。不同之处是,dup调用创建的新文件描述符与作为它的参数的那个已有文件描述符指向同一个文件(或管道)。对于dup函数来说,新的文件描述符总是取最小的可用值。而对于dup2函数来说,它所创建的新文件描述符或者与参数file_descriptor_two相同,或者是第一个大于该参数的可用值。

我们可以使用更通用的fcntl调用(command参数设置为F_DUPFD)来达到与调用dup和dup2相同的效果。虽然如此,但dup调用更易于使用,因为它是专门用于复制文件描述符的。而且它的使用非常普遍,你可以发现,在已有的程序中,它的使用比fcntl和F_DUPFD更频繁。

那么,dup是如何帮助我们在进程之间传递数据的呢?诀窍就在于,标准输入的文件描述符总是0,而dup返回的新的文件描述符又总是使用最小可用的数字。因此,如果我们首先关闭文件描述符0然后调用dup,那么新的文件描述符就将是数字0。因为新的文件描述符是复制一个已有的文件描述符,所以标准输入就会改为指向一个我们传递给dup函数的文件描述符所对应的文件或管道。我们创建了两个文件描述符,它们指向同一个文件或管道,而且其中之一是标准输入。

用close和dup函数对文件描述符进行处理

理解当我们关闭文件描述符0,然后调用dup究竟发生了什么的最简单的方法就是,查看开头的4个文件描述符的状态在这一过程中的改变情况,如下表所示

 

 实验 管道和dup函数

再回到前面的例子,但这次,我们将把子程序的stdin文件描述符替换为我们创建的管道的读取端。我们还将对文件描述符做一些清理,使得子程序可以正确检测到管道中数据的结束。与往常一样,为了简洁起见,我们省略了一些错误检查。用如下的代码将pipe3.c修改为pipe5.c:

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

#define DEBUG_INFO(format, ...) printf("%s - %d - %s :: "format"\n",__FILE__,__LINE__,__func__ ,##__VA_ARGS__)

void test_01(void){
    int len = 0;
    int fds_pipes[2];
    const char some_data[] = "123";
    pid_t pid;
    int res;

    char buf[BUFSIZ + 1];

    memset(buf,0,sizeof(buf));

    res = pipe(fds_pipes);
    if(res != 0){
        perror("pipe:");
        return;
    }
    pid = fork();
    if(pid < 0){
        perror("fork:");
        return ;
    }
    if(pid == 0){
        close(0);
        res = dup(fds_pipes[0]);
        DEBUG_INFO("res = %d", res);
        close(fds_pipes[0]);
        close(fds_pipes[1]);
        res = execlp("od","od","-c",(char*)0);
        if(res != 0){
            perror("execl:");
            exit(-1);
        }
        sleep(1);
        exit(0);
    }
    close(fds_pipes[0]);
    len = write(fds_pipes[1],some_data,strlen(some_data));
    close(fds_pipes[1]);
    DEBUG_INFO("PARENT:pid = %lu,write -- len = %d\n",getpid(),len);
    sleep(3);
    exit(0);
}

int main(int argc, char**argv){
    test_01();
    DEBUG_INFO("hello world");
    return 0;
}

 执行结果:

 实验解析

与往常一样,这个程序创建一个管道,然后通过fork创建一个子进程。此时,父子进程都有可以访问管道的文件描述符,一个用于读数据,一个用于写数据,所以总共有4个打开的文件描述符。

我们首先来看子进程。子进程先用close(0)关闭它的标准输入,然后调用dup(file_pipes[0])把与管道的读取端关联的文件描述符复制为文件描述符0,即标准输入。接下来,子进程关闭原先的用来从管道读取数据的文件描述符file_pipes[0]。因为子进程不会向管道写数据,所以它把与管道关联的写操作文件描述符file_pipes[1]也关闭了。现在,它只有一个与管道关联的文件描述符,即文件描述符0,它的标准输入。

接下来,子进程就可以用exec来启动任何从标准输入读取数据的程序了。在本例中,我们使用的是od命令。od命令将等待数据的到来,就好像它在等待来自用户终端的输入一样。事实上,如果没有明确使用检测这两者之间不同的特殊代码,它并不知道输入是来自一个管道,而不是来自一个终端。

父进程首先关闭管道的读取端file_pipes[0],因为它不会从管道读取数据。接着它向管道写入数据。当所有数据都写完后,父进程关闭管道的写入端并退出。因为现在已没有打开的文件描述符可以向管道写数据了,od程序读取写到管道中的3个字节数据后,后续的读操作将返回0字节,表示已到达文件尾。当读操作返回0时,od程序就退出运行。这类似于在终端上运行od命令,然后按下Ctrl+D组合键发送文件尾标志。下图显示调用pipe之后的情况。

 下图显示调用fork之后的情况。

 下图显示程序做好数据传输准备之后的情况。

 CMakeLists.tx 、编译脚本和sftp.json

cmake_minimum_required(VERSION 3.8)
project(myapp)

# add_compile_options("-std=c++11")

add_executable(popen popen.c)
add_executable(popen2 popen2.c)
add_executable(popen3 popen3.c)
add_executable(popen4 popen4.c)
add_executable(pipe1 pipe1.c)
add_executable(pipe2 pipe2.c)
add_executable(pipe3 pipe3.c)
add_executable(pipe4 pipe4.c)
add_executable(pipe5 pipe5.c)


rm -rf _build_
mkdir _build_ -p
cmake -S ./ -B _build_
make -C _build_
# ./_build_/popen
# ./_build_/popen2
# ./_build_/popen3
# ./_build_/popen4
# ./_build_/pipe1
# ./_build_/pipe2
# ./_build_/pipe3
# ./_build_/pipe4
./_build_/pipe5
{
    "name": "My Server",
    "host": "192.168.31.138",
    "protocol": "sftp",
    "port": 22,
    "username": "lkmao",
    "password": "lkmao",
    "remotePath": "/big/work/ipc",
    "uploadOnSave": true,
    "useTempFile": false,
    "openSsh": false
}

小结

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

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

相关文章

设计模式(十三):行为型之模板方法模式

设计模式系列文章 设计模式(一)&#xff1a;创建型之单例模式 设计模式(二、三)&#xff1a;创建型之工厂方法和抽象工厂模式 设计模式(四)&#xff1a;创建型之原型模式 设计模式(五)&#xff1a;创建型之建造者模式 设计模式(六)&#xff1a;结构型之代理模式 设计模式…

S200, S1700, S5700交换机忘记密码怎么办(huawei)

目录 交换机忘记密码怎么办&#xff1f;如何修改或清除密码&#xff1f; 简介 一&#xff1a;修改了所有默认密码&#xff0c;还忘记了所有密码 二&#xff1a;忘记了Console口登录密码 方法一&#xff1a;通过STelnet/Telnet登录设备修改Console口密码 方法二&#xff1…

RV1126笔记三十六:PaddleOCR环境搭建一

若该文为原创文章,转载请注明原文出处。 在前面测试过PaddleOCR的文字识别功能,现在自己搭建训练模型并测试。 这篇主要是环境搭建,环境为win10无GPU. 1、创建环境 # 创建paddle环境 conda create -n paddle python=3.8 # 查看环境 conda env list # 切换环境 conda acti…

第三章 模型篇:模型与模型的搭建

写在前面的话 这部分只解释代码&#xff0c;不对线性层(全连接层)&#xff0c;卷积层等layer的原理进行解释。 尽量写的比较全了&#xff0c;但是自身水平有限&#xff0c;不太确定是否有遗漏重要的部分。 教程参考&#xff1a; https://pytorch.org/tutorials/ https://githu…

RK3588平台开发系列讲解(以太网篇)SGMII和RGMII接口特性

文章目录 一、MAC 与 PHY的连接二、MAC 与 PHY 在OSI 中位置2.1、网络层2.2、数据链路层2.3、物理层三、RGMII四、SGMII沉淀、分享、成长,让自己和他人都能有所收获!😄 一、MAC 与 PHY的连接 从硬件的角度看,以太网接口电路主要由MAC控制器和物理层PHY芯片两部分组成。 以…

Redis 五大数据类型/结构

Redis 五大数据类型/结构 操作文档 官方文档: https://redis.io/commands 中文文档: http://redisdoc.com/ Redis 数据存储格式 一句话: redis 自身是一个Map&#xff0c;其中所有的数据都是采用key : value 的形式存储 key 是字符串&#xff0c;value 是数据&#xff0c;数…

流媒体接入服务的一般模型

0x00 背景说明 媒体接入服务用来实现媒体资源(resource)的接收和发送&#xff0c;在有限范围内实现不同接入协议的转换。 0x01 一般模型 媒体传输通道的建立步骤通常分为两个阶段&#xff1a; 握手/协商媒体传输 其中&#xff0c;握手/协商操作通常包含&#xff1a; 媒体…

【GD32F303CCT6BlueBill开箱点灯教程】

【GD32F303CCT6BlueBill开箱点灯教程】 1. 搭建环境1.1 官方资料1.2 安装Keil 51.3 安装芯片选型插件pack包 2. 编译2.1 Keil4转换为Keil5工程2.2 选择芯片型号2.3 存储器类型2.4 选择下载器2.5 内存下载设置 3. 烧录3.1 Keil内烧录3.1.1 J-Link烧录3.1.2 ST-Link烧录3.1.3 CMS…

读书笔记:《远见:如何规划职业生涯3大阶段》

《远见&#xff1a;如何规划职业生涯3大阶段》&#xff0c;作者布赖恩&#xff0e; 费瑟斯通豪&#xff0c;豆瓣链接&#xff1a;https://book.douban.com/subject/27609489/ 主旨&#xff1a;描述职业生涯中3个截然不同但相互关联的阶段&#xff0c;教会我们如何不断储备职场燃…

【linux指南--命令大全】

系统的学习linux常用的命令&#xff0c;命令很全所以篇幅很长&#xff0c;可以作为你查阅命令的手册。也欢迎大佬们评论区补充。 文章目录 常见目录介绍配置文件系统操作帮助命令man 帮助help 帮助info 帮助 显示当前的目录名称文件查看建立目录删除空目录复制文件移动文件删除…

Qt下面窗口嵌套,嵌套窗口中包含:QGraphicsView、QGraphicsScene、QGraphicsIte

Qt系列文章目录 文章目录 Qt系列文章目录前言一、嵌套窗口二、注意事项 前言 我们有一个主窗口mainwindow,需要向其中放入新的界面&#xff0c;你可以自己定义里面内容。 Qt的嵌套布局由QDockWidget完成&#xff0c;用Qt Creator拖界面得到的dock布置形式比较固定&#xff0c;…

vmware设置centos客户机和windows宿主机共享文件夹

一、安装内核 kernel-devel 包 yum install gcc yum install kernel-devel-$(uname -r) 注意&#xff0c;如果自己修改过内核版本&#xff0c;需要确保 uname -r 显示的版本和实际使用的内核版本一致。 二、安装 vmware-tools 在vmware上点击菜单&#xff1a;虚拟机->安…

Android kotlin 实现仿京东多个item向左自动排队(横向、动手滑动、没有首尾滑动)功能

文章目录 一、实现效果二、引入依赖三、源码实现1、适配器2、视图实现一、实现效果 二、引入依赖 在app的build.gradle在添加以下代码 1、implementation com.github.CymChad:BaseRecyclerViewAdapterHelper:3.0.6,这个里面带的适配器,直接调用就即可 BaseRecyclerViewAdapt…

【图神经网络】图神经网络(GNN)学习笔记:Graph Embedding

图神经网络&#xff08;GNN&#xff09;学习笔记&#xff1a;Graph Embedding 为什么要进行图嵌入Graph embedding?Graph Embedding使用图嵌入的优势有哪些&#xff1f;图嵌入的方法有哪些&#xff1f;节点嵌入方法&#xff08;Node Embeddings&#xff09;1. DeepWalk2. LINE…

CTFShow-WEB入门篇命令执行详细Wp(29-40)

WEB入门篇--命令执行详细Wp 命令执行&#xff1a;Web29&#xff1a;Web30&#xff1a;Web31&#xff1a;web32&#xff1a;web33&#xff1a;web34&#xff1a;web35&#xff1a;web36&#xff1a;web37&#xff1a;web38&#xff1a;web39&#xff1a;web40&#xff1a; CTFSh…

【哈希表part02】| 454.四数相加、383.赎金信、15.三数之和、18.四数之和

目录 ✿LeetCode454.四数相加❀ ✿LeetCode383.赎金信❀ ✿LeetCode15.三数之和❀ ✿LeetCode18.四数之和❀ ✿LeetCode454.四数相加❀ 链接&#xff1a;454.四数相加 给你四个整数数组 nums1、nums2、nums3 和 nums4 &#xff0c;数组长度都是 n &#xff0c;请你计算有多…

Hive3安装

Mysql安装 卸载Centos7自带的mariadb rpm -qa|grep mariadb rpm -e mariadb-libs-5.5.64-1.el7.x86_64 --nodeps rpm -qa|grep mariadb 安装mysql mkdir /export/software/mysql 上传mysql-5.7.29-1.el7.x86_64.rpm-bundle.tar 到上述文件夹下后解压 tar xvf mysql-5.7.29-1…

微服务技术简介

微服务技术简介 服务架构的演变微服务架构的常见概念微服务常见的解决方案Spring CloudSpring Cloud Alibaba微服务技术对比常用的微服务组件 微服务架构图 服务架构的演变 单体架构&#xff1a;当一个系统业务量很小的时候&#xff0c;将业务的所有功能集中在一个项目中开发&…

红帽认证常见答疑(一):有效期、考试题型、考试对年龄和身份要求、英语水平等

红帽认证有效期 红帽的每个证书都有有效期&#xff0c;期限3年。RHCE过期前可以考下午的RHCE&#xff08;EX294&#xff09;或者考一门RHCA来延期3年。证书过期后在红帽官网上无法下载证书&#xff0c;但仍然可以查询到考试记录&#xff0c;不会影响到就业求职&#xff0c;如果…

2.6 TCP与UDP的可靠性传输

目录 一、TCP可靠性传输1、重传机制1.1、超时重传1.2、快速重传1.3、SACK1.4、Duplicate SACK 2、滑动窗口3、流量控制3.1 滑动窗口与流量控制3.2窗口关闭 4、拥塞控制4.1拥塞窗口4.2 慢启动4.3 拥塞避免4.4 拥塞发生4.5 快速恢复 二、UDP可靠性传输1、主要策略2、重传机制2.1 …