命名管道详解

news2024/11/24 13:33:22

一、命名管道

1、命名管道与匿名管道一个很显著的区别是:匿名管道只能在有血缘关系的进程间进行通信,但命名管道可以让两个毫无关系的进程进行通信。

2、如果我们想在不相关的进程间交换数据,我们可以用到FIFO文件来进行通信,这个文件也被称之为命名管道。

3、命名管道其实就是一种特殊的文件类型。

二、命名管道通信的原理

进程间通信的原理就是让两个独立的进程看到同一份文件,通过在这个文件里进行读写,就实现了两个进程间的通信了。

匿名管道是通过子进程会继承父进程的PCD的特性,实现两个进程看到同一份文件来实现的。

而命名管道是直接创建了一个FIFO文件来实现,两个不相关的进程看到同一个文件的。

这是一个进程,打开了一个磁盘上的文件,如果两个进程打开了同一个文件,他们会使用同一个struct_file:

 

如果这两个进程同时写入这个文件的话,数据会进入到缓冲区中,然后再定期刷新到磁盘上。这样也可以实现两个进程建的通信,但是这样子太慢了,我们还需要刷新到磁盘上。如果我们有一个内存级文件的话,我们就不需要通过磁盘这样减速的外设进行通信了。这也是我们为什么要将fifo文件的定为命名管道文件的原因。

这个过程是如何保证两个进程看到的文件就是同一个呢?文件的唯一性是由绝对路径决定的,一个路径只会对应一个文件。

三、创建一个命名管道

方法一——命令行的方式:

mkfifo filename

这里的fifoname需要加上路径,不加的话默认就是本目录下

例子:

$ mkfifo ./fifo
$ echo "hello">fifo
$ cat <fifo

解释:第一行在本目录下创建了一个fifo文件,第二行使用echo指令将“hello”重定向进了fifo,第三行,将fifo文件中的内容重定向进了stdout。

echo和cat也是两个进程,在这个例子中我们也用fifo文件让这两个进程进行了通信。

方法二——通过系统调用:

1、创建一个fifo文件

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

filename与上面同理,mode就是文件创建的权限。但它会受到umask的影响:mode&~umask

因此我们一般会调用umask()函数将umask置零——umask(0);

2、两个进程通过open函数将fifo文件打开,一个以O_RDONLY,一个以O_WRONLY将文件打开。

    int wfd=open(fifoname.c_str(),O_WRONLY);
    if(wfd<0)
    {
        std::cout<<errno<<":"<<strerror(errno)<<std::endl;
        return 3;
    }
int rfd=open(fifoname.c_str(),O_RDONLY);
    if(rfd<0)
    {
        std::cout<<errno<<":"<<strerror(errno)<<std::endl;
        return 2;
    }
    std::cout<<"fifo open sucess,begin ipc"<<std::endl;

3、负责写的进程开始向fifo文件里写入,而负责读取的进程就开始读取。

char buffer[NUM];
    while(true)
    {
        std::cout<<"请输入你的信息#";
        char *msg=fgets(buffer,sizeof(buffer),stdin);
        assert(msg);
        (void)msg;
        buffer[strlen(buffer)-1]=0;
        ssize_t n=write(wfd,buffer,strlen(buffer));
        assert(n>0);
        (void)n;
        if(strcasecmp(buffer,"quit")==0) break;
    }
    char buffer[NUM];
    while(true)
    {
        buffer[0]=0;
        int n =read(rfd,buffer,sizeof(buffer)-1);
        if(n>0)
        {
            buffer[n]=0;
            std::cout<<buffer<<std::endl;
            fflush(stdout);
        }
        else if(n==0)
        {
            std::cout<<"client out,me too"<<std::endl;
            break;
        }
        else{
            std::cout<<n<<std::endl;
            std::cout<<errno<<":"<<strerror(errno)<<std::endl;
            break;
        }

    }

四、上实例

makefile

.PHONY:all
all:clientPipe serverPipe
serverPipe.c
clientPipe:clientPipe.c
 g++ -o $@ $^ std=c++11
serverPipe:serverPipe.c
 gcc -o $@ $^ std=c++11
.PHONY:clean
clean:
 rm -f clientPipe serverPipe

server.cc//这就是创建fifo文件的进程

#include<iostream>
#include<cerrno>
#include<cstring>
#include<sys/types.h>
#include<sys/stat.h>
#include<fcntl.h>
#include<unistd.h>
#include"comm.hpp"


int main()
{
    //1、创建管道文件
    umask(0);//这个不影响系统配置,只改变当前进程。
    int n=mkfifo(fifoname.c_str(),mode);
    if(n!=0)
    {
        std::cout<<errno<<":"<<strerror(errno)<<std::endl;
        return 1;
    }
    std::cout<<"create fifo success"<<std::endl;

    //2、服务端直接开启管道文件

    int rfd=open(fifoname.c_str(),O_RDONLY);
    if(rfd<0)
    {
        std::cout<<errno<<":"<<strerror(errno)<<std::endl;
        return 2;
    }
    std::cout<<"fifo open sucess,begin ipc"<<std::endl;
    
    //开始通信
    char buffer[NUM];
    while(true)
    {
        buffer[0]=0;
        int n =read(rfd,buffer,sizeof(buffer)-1);
        if(n>0)
        {
            buffer[n]=0;
            std::cout<<buffer<<std::endl;
            fflush(stdout);
        }
        else if(n==0)
        {
            std::cout<<"client out,me too"<<std::endl;
            break;
        }
        else{
            std::cout<<n<<std::endl;
            std::cout<<errno<<":"<<strerror(errno)<<std::endl;
            break;
        }

    }
    close(rfd);


    unlink(fifoname.c_str());



    return 0;
}

client.cc//负责写入的文件

#include <iostream>
#include <cstdio>
#include <cerrno>
#include <cstring>
#include <cassert>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <unistd.h>
// #include <ncurses.h>
#include "comm.hpp"

int main()
{
    //1、不需要创建管道文件,我只需要打开对应的文件即可

    int wfd=open(fifoname.c_str(),O_WRONLY);
    if(wfd<0)
    {
        std::cout<<errno<<":"<<strerror(errno)<<std::endl;
        return 3;
    }

    //进行常规通信
    char buffer[NUM];
    while(true)
    {
        std::cout<<"请输入你的信息#";
        char *msg=fgets(buffer,sizeof(buffer),stdin);
        assert(msg);
        (void)msg;
        buffer[strlen(buffer)-1]=0;
        ssize_t n=write(wfd,buffer,strlen(buffer));
        assert(n>0);
        (void)n;
        if(strcasecmp(buffer,"quit")==0) break;
    }

    close(wfd);

    return 0;
}

运行结果:

 

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

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

相关文章

【Nginx rewrite】

目录 一、常见的Nginx 正则表达式二、location1、location 解释2、location 示例说明&#xff1a;3、实际网站使用中&#xff0c;至少有三个匹配规则定义&#xff1a; 二、rewrite1、rewrite跳转实现&#xff1a;2、rewrite 执行顺序如下&#xff1a;3、rewrite 示例 一、常见的…

B-3:Linux 系统渗透提权

B-3&#xff1a;Linux 系统渗透提权 任务环境说明&#xff1a; 服务器场景&#xff1a;Server2204&#xff08;关闭链接&#xff09; 用户名&#xff1a;hacker 密码&#xff1a;123456 1.使用渗透机对服务器信息收集&#xff0c;并将服务器中 SSH 服务端口号作为 flag 提 …

Java工厂模式(随笔)

前言&#xff1a;Java工厂模式是一种创建型设计模式&#xff0c;它提供了一种将对象创建过程封装到一个单独的类中的方式&#xff0c;这个类就是被称为‘工厂类’&#xff0c;它根据特定的条件来决定应该创建哪个对象&#xff01; 文章目录&#xff1a; 三大工厂模式介绍特殊工…

计算机网络第二章——物理层(上)

提示&#xff1a;男儿何不带吴钩&#xff0c;收取关山五十州 文章目录 2.1.1 物理层基本概念知识引导物理层接口特征 2.1.2 数据通信基础知识数据通信相关术语数据通信系统要考虑的问题三种通信方式串行传输&并行传输同步传输&异步传输 脑图时刻 2.1.3 数据通信基础知识…

Google Play上架aab保姆级教程(纯aab上架/已上架apk转aab上架)

0、上传密钥 & 应用签名密钥 “Google 会使用上传证书验证您的身份&#xff0c;并使用您的应用签名密钥为 APK 签名以进行分发” 以上为官方解释。 2021年8月起&#xff0c;上传google play的应用必须以aab格式&#xff0c;aab的签名流程要比之前apk的复杂一些。需要上传…

如何真正有效地应对项目中的需求变更?

需求变更在奉行唯快不破的互联网公司&#xff0c;可算程序员头号噩梦&#xff0c;“996”直接元凶。 阿里口号拥抱变化。既然需求变更无法被消灭&#xff0c;就要通过学习&#xff0c;掌握更好应对需求变更方法。 1 常见的需求变更流程 先要发起变更申请&#xff0c;由变更委…

从IO多路复用到redis线程模型

文章目录 Unix IO模型分类阻塞IO - Blocking IO非阻塞IO - NoneBlocking IOIO多路复用 - IO multiplexing信号驱动IO - signal driven IO异步IO - asynchronous IO同步与异步的定义阻塞与非阻塞的定义 IO多路复用有哪些实现IO多路复用的大致实现selectpollepoll redis的线程模型…

Python实战基础19-异常处理及程序调试

1、异常概述 在程序运行过程中&#xff0c;经常会遇到各种各样的错误&#xff0c;这些错误统称为“异常”。 这些异常有的是由于开发者将关键字敲错&#xff0c;这类错误产生的是SyntaxError:invalid syntax&#xff08;无效语法&#xff09;&#xff0c;这将直接导致程序不能…

3.二进制高可用安装k8s 1.23集群(生产级)

二进制高可用安装k8s集群(生产级) 本文档适用于kubernetes1.23 节点 Etcd Cluster Etcd是一个数据库,k8s做的一些变更啥的都会存到Etcd中 如果集群比较大建议与master节点分装,单独装Etcd master节点 master分为几个重要的组件 你所有的流量都会经过Kube-APIServer Co…

排序算法——希尔排序图文详解

文章目录 希尔排序基本思想整体插入思想预排序结论 代码实现实现代码直接插入排序与希尔排序的效率比较测试代码&#xff1a; 时间复杂度 希尔排序 注1&#xff1a;本篇是基于对直接插入排序法的拓展&#xff0c;如果对直接插入法不了解&#xff0c;建议先看看直接插入排序 注…

Learning C++ No.27 【布隆过滤器实战】

引言 北京时间&#xff1a;2023/5/31/22:02&#xff0c;昨天的计算机导论考试&#xff0c;三个字&#xff0c;哈哈哈&#xff0c;摆烂&#xff0c;大致题目都是一些基础知识&#xff0c;但是这些基础知识都是非常非常理论的知识&#xff0c;理论的我一点不会&#xff0c;像什么…

【自制C++深度学习框架】表达式层的设计思路

表达式层的设计思路 在深度学习框架中&#xff0c;Expression Layer&#xff08;表达式层&#xff09;是指一个通用的算子&#xff0c;其允许深度学习网络的不同层之间结合和嵌套&#xff0c;从而支持一些更复杂的操作&#xff0c;如分支之间的加减乘除&#xff08;elementAdd…

PyTorch 深度学习 || 专题二:PyTorch 实验框架的搭建

PyTorch 实验框架的搭建 1. PyTorch简介 PyTorch是由Meta AI(Facebook)人工智能研究小组开发的一种基于Lua编写的Torch库的Python实现的深度学习库&#xff0c;目前被广泛应用于学术界和工业界&#xff0c;PyTorch在API的设计上更加简洁、优雅和易懂。 1.1 PyTorch的发展 “…

Numpy---生成数组的方法、从现有数组中生成、生成固定范围的数组

1. 生成数组的方法 np.ones(shape, dtypeNone, orderC) 创建一个所有元素都为1的多维数组 参数说明: shape : 形状&#xff1b; dtypeNone: 元素类型&#xff1b; order &#xff1a; {‘C’&#xff0c;‘F’}&#xff0c;可选&#xff0c;默认值&#xff1a;C 是否在内…

BPMN2.0自动启动模拟流程

思路&#xff1a;BPMN的流程模拟启动&#xff0c;主要是通过生成令牌&#xff0c;并启动令牌模拟 流程模拟的开启需要关键性工具&#xff1a;bpmn-js-token-simulation&#xff0c;需要先行下载 注&#xff1a;BPMN2.0的流程模拟工具版本不同&#xff0c;启动方式也不一样&am…

Kafka某Topic的部分partition无法消费问题

今天同事反馈有个topic出现积压。于是上kfk管理平台查看该topic对应的group。发现6个分区中有2个不消费&#xff0c;另外4个消费也较慢&#xff0c;总体lag在增长。查看服务器日志&#xff0c;日志中有rebalance 12 retry 。。。Exception&#xff0c;之后改消费线程停止。 查…

chatgpt赋能python:Python实现数据匹配的方法

Python实现数据匹配的方法 在数据分析和处理中&#xff0c;经常需要将两组数据进行匹配。Python作为一门强大的编程语言&#xff0c;在数据匹配方面也有着其独特的优势。下面我们将介绍Python实现数据匹配的方法。 数据匹配 数据匹配通常指的是将两组数据根据某些特定的规则…

理解calico容器网络通信方案原理

0. 前言 Calico是k8s中常用的容器解决方案的插件&#xff0c;本文主要介绍BGP模式和IPIP模式是如何解决的&#xff0c;并详细了解其原理&#xff0c;并通过实验加深理解。 1. 介绍Calico Calico是属于纯3层的网络模型&#xff0c;每个容器都通过IP直接通信&#xff0c;中间通…

试验SurfaceFlinger 中Source Crop

在 SurfaceFlinger 中&#xff0c;Source Crop 是用于指定源图像的裁剪区域的一个概念。Source Crop 可以理解为是一个矩形区域&#xff0c;它定义了源图像中要被渲染到目标区域的部分。在 Android 中&#xff0c;Source Crop 通常用于实现屏幕分辨率适应和缩放等功能。 在 Sur…

【Java基础篇】逻辑控制练习题与猜数字游戏

作者简介&#xff1a; 辭七七&#xff0c;目前大一&#xff0c;正在学习C/C&#xff0c;Java&#xff0c;Python等 作者主页&#xff1a; 七七的个人主页 文章收录专栏&#xff1a;Java.SE&#xff0c;本专栏主要讲解运算符&#xff0c;程序逻辑控制&#xff0c;方法的使用&…