无名管道 / 有名管道(FIFO)

news2024/11/23 21:52:50

根据上节所讲就可以了解到:管道其实就是实现进程间通讯IPC中的一种类型方法

基本概念(无名管道)

管道是一种最基本的IPC机制,通常指无名管道,也是UNIX系统IPC最古老的形式。管道只能作用于有血缘关系的进程之间,完成数据传递。调用pipe系统函数即可创建一个管道。有如下特质:

  1. 其本质是一个伪文件(实为内核缓冲区),可以使用普通的read,write等函数进行读写
  2. 由两个文件描述符引用,一个表示读端,一个表示写端
  3. 规定数据从管道的写端流入管道,从读端流出

管道的原理

管道实为内核使用环形队列机制,借助内核缓冲区(4k)实现。

管道的局限性

  • 数据一旦被读走,便不在管道中存在,不可反复读取
  • 由于管道采用半双工通信方式。因此,数据只能在一个方向上流动

所谓半双工,其实在讲串口的时候就提到过,也就是同一时间要么只能写要么只能读,不能同时写和读。 对于进程通讯就是:父进程写的时候子进程只能读;子进程写的时候父进程只能读。

  • 只能在有公共祖先的进程间使用管道

( 常见的通信方式有,单工通信、半双工通信、全双工通信 

pipe函数(无名管道)

当成功调用pipe函数时,会创建两个文件描述符,fd[0] -> 读(r)fd[1]-> 写(w)之后如果想要向管道写数据就往fd[1]里面写,如果想从管道读数据就从fd[0]里面读!

如果要关闭管道,只需要关闭这两个文件描述符就可以了。

需要添加的库

 #include <unistd.h>

函数原型

int pipe(int pipefd[2]);

函数参数

  • pipefd[2]:表示一个包含两个文件描述符的数组,也就是上面提到分别代表读和写的 fd[0] 和 fd[1]
  • 返回值:若成功返回0,失败则返回-1

实操演示

创建一个名为'IPC"的文件夹,关于各种IPC的学习代码都放在这个文件夹下:

注意,由于fork函数会拷贝一份一样的程序给子进程,所以管道的创建应该在fork之前,这样父子进程就都有了fd[0]和fd[1],并且由于管道指向内核,所以父子进程的fd[0]和fd[1]是相同的。

#include <unistd.h>
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/wait.h>


int main()
{
	int fd[2];
	pid_t fork_return;
	char *writebuf = "mjmmjmmm";
	char readbuf[1024] = {0};

	if(pipe(fd) == -1){
		printf("pipe error\n");
	}

	fork_return = fork();
	if(fork_return > 0){//father
		close(fd[0]);
		//ssize_t write(int fd, const void *buf, size_t count);
		write(fd[1],writebuf,strlen(writebuf));
		wait(NULL);
	}else if(fork_return == -1){//error
		printf("fork error\n");
	}else{//son
		close(fd[1]);
		//ssize_t read(int fd, void *buf, size_t count);
		read(fd[0],&readbuf,1024);
		printf("read from pipe:%s\n",readbuf);
		exit(1);
	}


	return 0;
}

实现效果

基本概念(有名管道)

FIFO,也称为命名管道,它是一种文件类型。

有名管道的特点

  • FIFO可以在无关的进程之间交换数据,与无名管道不同
  • FIFO有路径名与之相关联,它以一种特殊设备文件形式存在于文件系统中

mkfifo函数(有名管道) 

需要添加的库

#include <sys/stat.h>

函数原型

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

函数参数

  • pathname:文件路径
  • mode:mode 参数与open函数中的 mode 相同。一旦创建了一个 FIFO,就可以用一般的文件I/O函数操作它

关于open函数中的mode:

其中较为常用的是:

  • S_IRWXU:对主用户来说可读,可写,可执行
  • S_IRUSR:对主用户来说可读
  • S_IWUSR:对主用户来说可写
  • S_IXUSR:对主用户来说可执行

详见:Linux 系统编程 开篇/ 文件的打开/创建_mjmmm的博客-CSDN博客

  • 返回值:成功返回0,出错返回-1

既然可以用一般文件的I/O函数操作它,就意味可以使用open来打开,而open中的第二个参数flag中有一个选项是“O_NONBLOCK”,这是非阻塞标志

  • 若没有指定O_NONBLOCK(默认),只读 open 要阻塞到某个其他进程为写而打开此 FIFO。类似的,只写 open 要阻塞到某个其他进程为读而打开它

  • 若指定了O_NONBLOCK,则只读 open 立即返回。而只写 open 将出错返回 -1 如果没有进程已经为读而打开该 FIFO,其errno置ENXIO。

参考:进程间通信(一)管道的pipe函数 FIFO的mkfifo函数_mkfifo 多进程_点灯小哥的博客-CSDN博客

实操演示

FIFO的通讯方式类似于在进程中使用文件来传输数据,只不过FIFO类型文件同时具有管道的特性。在数据读出时,FIFO管道中同时清除数据,并且“先进先出”

fifo1.c:(只读open FIFO,并不设“O_NONBLOCK”

#include <sys/types.h>
#include <sys/stat.h>
#include <stdio.h>
#include <errno.h>
#include <fcntl.h>


int main()
{
	if(mkfifo("./fifo",S_IRWXU) == -1 && errno != EEXIST) //如果创建失败 且 没有已存在的FIFO
        {
                printf("mkfifo failed\n");
                perror("why");
        }

	int fd = open("./fifo",O_RDONLY); //only read
	printf("open success\n");

	return 0;
}

实现效果1:

可见,由于没有设置O_NONBLOCK,且没有进程只写打开FIFO,所以只读打开FIFO会一直阻塞

fifo2.c:(只读open FIFO,并设置“O_NONBLOCK”

#include <sys/types.h>
#include <sys/stat.h>
#include <stdio.h>
#include <errno.h>
#include <fcntl.h>


int main()
{
	if(mkfifo("./fifo",S_IRWXU) == -1 && errno != EEXIST)
        {
                printf("mkfifo failed\n");
                perror("why");
        }

	int fd = open("./fifo",O_RDONLY|O_NONBLOCK); //only read
	printf("open success\n");

	return 0;
}

实现效果2:

 

可见,由于加上了O_NONBLOCK,虽然没有进程只写打开FIFO,但是只读打开不会阻塞而是立刻返回,并执行了printf 

fifo3.c & fifo4.c:(创建两个进程,fifo3一直写,fifo4一直读)

fifio3.c:(一直写)
#include <sys/types.h>
#include <sys/stat.h>
#include <stdio.h>
#include <errno.h>
#include <fcntl.h>
#include <string.h>
#include <unistd.h>


int main()
{
	char *str = "mjmmmmjjm";

	int fd = open("./fifo",O_WRONLY); //only write
	printf("open success\n");

	while(1){
		write(fd,str,strlen(str));
		sleep(1);

	}

	close(fd);

	return 0;
}
fifo4.c:(一直读)
#include <sys/types.h>
#include <sys/stat.h>
#include <stdio.h>
#include <errno.h>
#include <fcntl.h>
#include <unistd.h>


int main()
{
	char buf[30] = {0};
    int nread = 0;
	
	if(mkfifo("./fifo",S_IRWXU) == -1 && errno != EEXIST)
        {
                printf("mkfifo failed\n");
                perror("why");
        }

	int fd = open("./fifo",O_RDONLY); //only read
	printf("read open success\n");
	
	while(1){
		read(fd,&buf,30);
		printf("read %d byte from fifo,context: %s\n",nread,buf);
	}

	close(fd);

	return 0;
}

实现效果3:

先编译并运行fifo4.c:

可见没有进程只写打开FIFO,所以一直阻塞

然后再新的窗口编译并运行fifo3.c:

此时有进程只写打开FIFO并每隔一秒向其中写入数据

此时再观察fifo4.c的输出:

 

此时只读FIFO不再阻塞,并每隔一秒读到只写FIFO写入的数据! 

上述例子可以扩展成 客户进程—服务器进程 通信的实例负责写的fifo3.c的作用类似于客户端,可以打开多个客户端向一个服务器发送请求信息,负责读的fifo4.c类似于服务器,它适时监控着FIFO的读端,当有数据时,读出并进行处理,但是有一个关键的问题是,每一个客户端必须预先知道服务器提供的FIFO接口,下图显示了这种安排:

 

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

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

相关文章

R语言实现随机生存森林(2)

library(survival) library(randomForestSRC) help(package"randomForestSRC") #构建普通的随机生存森林 data(cancer,package"survival") lung$status<-lung$status-1 rfsrc.fit1 <- rfsrc(Surv(time, status) ~ ., lung,ntree 100,block.size 1,…

时序预测 | MATLAB实现WOA-CNN-LSTM鲸鱼算法优化卷积长短期记忆神经网络时间序列预测

时序预测 | MATLAB实现WOA-CNN-LSTM鲸鱼算法优化卷积长短期记忆神经网络时间序列预测 目录 时序预测 | MATLAB实现WOA-CNN-LSTM鲸鱼算法优化卷积长短期记忆神经网络时间序列预测预测效果基本介绍模型描述程序设计学习总结参考资料 预测效果 基本介绍 时序预测 | MATLAB实现WOA-…

maven install

maven install maven 的 install 命令&#xff0c;当我们的一个 maven 模块想要依赖其他目录下的模块时&#xff0c;直接添加会找不到对应的模块&#xff0c;只需要找到需要引入的模块&#xff0c;执行 install 命令&#xff0c;就会将该模块放入本地仓库&#xff0c;就可以进…

Linux文件属性查看和修改学习

一、基本属性 1、看懂文件属性&#xff1a; Linux系统是一种典型的多用户系统&#xff0c;不同的用户处于不同的地位&#xff0c;拥有不同的权限。为了保护系统的安全性&#xff0c; Linux系统对不同的用户访问同一文件&#xff08;包括目录文件&#xff09;的权限做了不同的…

对约瑟夫问题的进一步思考

约瑟夫问题重述&#xff1a; 在计算机编程的算法中&#xff0c;类似问题又称为约瑟夫环 约瑟夫环&#xff1a;N个人围成一圈&#xff0c;从第一个开始报数&#xff0c;第M个将被杀掉&#xff0c;最后剩下一个&#xff0c;其余人都将被杀掉。 例如N6&#xff0c;M5&#xff0…

gRPC vs REST:创建API的方法比较

本文对gRPC和REST的特征和区别进行了介绍&#xff0c;这可能是当今创建API最常用的两种方法。 文章目录 一、gRPC的介绍 二、什么是REST&#xff1f; 三、什么是gRPC? 四、gRPC和REST的比较 &#xff08;1&#xff09;底层HTTP协议 &#xff08;2&#xff09;支持的数据…

实现C++多线程的完全指南

目录 引言&#xff1a;1. 理解多线程编程的基本概念2. 引入C标准库中的线程库3. 创建线程4. 线程同步和互斥5. 线程间的通信使用多线程需要关注的要点结论&#xff1a; 引言&#xff1a; 在现代软件开发中&#xff0c;多线程编程已经成为一项非常重要的技能。通过利用多线程&a…

前后端分离------后端创建笔记(07)表单验证

1、我输入数据&#xff0c;然后关闭&#xff0c;重新打开会发现残存的数据仍然保留着 2、点了这个x号&#xff0c;数据就全部被清理了 3、点这三个地方&#xff0c;数据全部都清理掉 4、这里先写一个方法 4.1 定义一个方法 4.2 这里表单的数据在哪里&#xff0c;就是这个 4.3 …

最新Kali Linux安装教程:从零开始打造网络安全之旅

Kali Linux&#xff0c;全称为Kali Linux Distribution&#xff0c;是一个操作系统(2013-03-13诞生)&#xff0c;是一款基于Debian的Linux发行版&#xff0c;基于包含了约600个安全工具&#xff0c;省去了繁琐的安装、编译、配置、更新步骤&#xff0c;为所有工具运行提供了一个…

无监督学习之主成分分析-半导体制造高维数据如何降维

数据降维不只存在于半导体数据中&#xff0c;它是存在于各行各业的&#xff0c;我们要分析的数据维数较多的时候全部输入维数较大这时就要采取降维的方法综合出主要的几列用于我们的分析。 PCA的哲学理念是要抓住问题的主要矛盾进行分析&#xff0c;是将多指标转化为少数几个…

13 docker使用问题

目录 docker模块分布&#xff1a; ①&#xff1a;安装"abseil"C库 ②&#xff1a;安装CMake​编辑 ③&#xff1a;grpc安装 ④&#xff1a;protobuf安装​编辑 ⑤&#xff1a;qt界面显示 ⑥&#xff1a;dockerfile编写​编辑 ⑦&#xff1a;执行docker脚本 …

(隐性)类型转换和算数转换

类型转换&#xff08;char,short&#xff09; 几个char 类型或者short 类型的数相加&#xff0c;会把他们提升为整形来相加 整型提升的意义&#xff1a; 表达式的整型运算要在CPU的相应运算器件内执行&#xff0c;CPU内整型运算器(ALU)的操作数的字节长度 一般就是int的字节长…

开学触控笔买哪个牌子好?ipad可以用的电容笔推荐

随着开学时间的临近&#xff0c;各大学院的学生们也都陆陆续续为走进校园而做准备了。那么开学自然需要买一些必要的数码电子产品&#xff0c;比如搭配iPad使用的电容笔。我们究竟要不要买苹果原装电容笔&#xff1f;事实上&#xff0c;如果只是为了写字记录东西的话&#xff0…

python爬虫数据解析xpath、jsonpath,bs4

数据的解析 解析数据的方式大概有三种 xpathJsonPathBeautifulSoup xpath 安装xpath插件 打开谷歌浏览器扩展程序&#xff0c;打开开发者模式&#xff0c;拖入插件&#xff0c;重启浏览器&#xff0c;ctrlshiftx&#xff0c;打开插件页面 安装lxml库 安装在python环境中的Scri…

windows11下配置vscode中c/c++环境

本文默认已经下载且安装好vscode&#xff0c;主要是解决环境变量配置以及编译task、launch文件的问题。 自己尝试过许多博客&#xff0c;最后还是通过这种方法配置成功了。 Linux(ubuntu 20.04)配置vscode可以直接跳转到配置task、launch文件&#xff0c;不需要下载mingw与配…

C#_字符串

String类型 字符串是信息最重要载体&#xff0c;相对于图像、语音、视频更易读易处理&#xff1b;C#字符串具有 不可变 特征&#xff0c; 从使每一次修改都要需要申请内存空间&#xff0c;并且需要复制源字符串到新的内存空间&#xff0c;还要需要销毁原有空间。 优势&#x…

前端实现文件预览功能

前端实现文件预览功能 ❝ 需求&#xff1a;实现一个在线预览pdf、excel、word、图片等文件的功能。 介绍&#xff1a;支持pdf、xlsx、docx、jpg、png、jpeg。 以下使用Vue3代码实现所有功能&#xff0c;建议以下的预览文件标签可以在外层包裹一层弹窗。 ❞ 图片预览 iframe标签…

详细安装配置django

安装配置使用Django。 1&#xff0c;下载安装 django pip install django 2.创建设置项目 先进入要放置项目的文件夹下 2.1&#xff0c; 创建项目 django-admin startproject Api_project 2.2&#xff0c; 创建app命令 cd Api_project dir看一下是否有 manage.py 文件…

ORB-SLAM2第五节---局部地图跟踪(阶段二)

保证三种跟踪方式更加准确 1.局部关键帧 当前帧F的局部关键帧包括&#xff1a; 能够观测到当前帧F中地图点的共视关键帧KF1、KF2&#xff0c;称为一级共视关键帧。一级共视关键帧的共视关键帧&#xff08;前10个共视程度最高的关键帧&#xff09;&#xff0c;比如图中的KF1的…

取证--实操

2022年美亚杯个人赛 运用软件DB Browser for SQLite &#xff08;一款用于查看SQLlite数据库文件的浏览器工具&#xff09; 火眼&#xff0c;盘古石手机取证系统等 案件详情 于2022年10月&#xff0c;有市民因接获伪冒快递公司的电邮&#xff0c;不慎地于匪徒架设的假网站提…