Linux进程通信——IPC、管道、FIFO的引入

2023/12/5 6:13:35

进程间的通信——IPC

进程间通信 (IPC,InterProcess Communication) 是指在不同进程之间传播或交换信息

IPC的方式通常有管道 (包括无名管道和命名管道)消息队列、信号量、共享存储、Socket、Streams等。其中 Socket和Streams支持不同主机上的两个进程IPC

单机:若是在单一机器上,则为单机通信

半双工管道
全双工管道
消息队列
信号量
共享内存

多机:多台机器上,为网络通信

网络通信种类如下:

管道

管道,通常指无名管道(之所以叫无名管道是因为没有文件名),是 UNIX 系统IPC最古老的形式。

特点

(1)它是半双工的(即数据只能在一个方向上流动)具有固定的读端和写端
(2)它只能用于具有亲缘关系的进程之间的通信(也是父子进程或者兄弟进程之间)。
(3)它可以看成是一种特殊的文件,对于它的读写也可以使用普通的read、write 等函数。但是它不是普通的文件,并不属于其他任何文件系统,并且只存在于内存中
(4)管道中不储存数据,数据写进后读取就会消失,类似于水流。

原型

#include <unistd.h>     //函数pipe包含的头文件
int pipe(int fd[2]);    // 返回值:若成功返回0,失败返回-1

当一个管道建立时,它会创建两个文件描述符: fd[0]为读而打开,fd[1]为写而打开。如下图:

要关闭管道只需将文件描述符关闭即可。

close(fd[0]);
close(fd[1]);

创建

单个进程中的管道几乎没有任何用处。所以,通常调用 pipe 的进程接着调用 fork,这样就创建了父进程与子进程之间的 IPC 半双工通道。如下图所示:

左图为调用fork函数创建了IPC半双工管道,右图为父进程到子进程的管道。

代码示例

#include<stdio.h>
#include<unistd.h>
#include<string.h>
#include<stdlib.h>
int main()
{
        int pid=0;
        int fd[2];
        char buf[128];

        if(pipe(fd) == -1)//如果管道创建失败
	    {
                printf("creat pipe failed\n");
        }

        pid=fork();
        if(pid<0)//创建子进程失败
	    {
                printf("creat failed\n");
        }
        else if(pid >0)//进入父进程
	    {
                printf("this is father\n");
                close(fd[0]);//关闭读文件描述符
                write(fd[1],"read from father",strlen("read from father"));//将内容写入管道中
		        wait();//等待子进程
	    }
	    else//进入子进程
	    {
                printf("this is child\n");
                close(fd[1]);//关闭写文件描述符
                read(fd[0],buf,128);//将管道中内容读取到buf
                printf("read form father:%s\n",buf);
		        exit(0);//子进程退出
        }
        return 0;
}

以上代码实现了管道通信,但read在没有读取到内容时会阻塞,直到读取内容后才正常运行,可以做以下调试:

#include<stdio.h>
#include<unistd.h>
#include<string.h>
#include<stdlib.h>
int main()
{
        int pid=0;
        int fd[2];
        char buf[128];

        if(pipe(fd) == -1)//如果管道创建失败
	    {
                printf("creat pipe failed\n");
        }

        pid=fork();
        if(pid<0)//创建子进程失败
	    {
                printf("creat failed\n");
        }
        else if(pid >0)//进入父进程
	    {
                sleep(3);//进入父进程后睡眠3秒再运行
                printf("this is father\n");
                close(fd[0]);//关闭读文件描述符
                write(fd[1],"read from father",strlen("read from father"));//将内容写入管道中
		        wait();//等待子进程
	    }
	    else//进入子进程
	    {
                printf("this is child\n");
                close(fd[1]);//关闭写文件描述符
                read(fd[0],buf,128);//将管道中内容读取到buf
                printf("read form father:%s\n",buf);
		        exit(0);//子进程退出
        }
        return 0;
}

方案是创建父进程后让其睡眠3秒后再执行父进程中的代码,可见在睡眠时子进程先运行其代码,但并没有执行read函数,此时表现为堵塞状态,直到3秒后父进程正常运行并将内容写入管道中,子进程才读取管道中的内容并成功打印。

FIFO

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

特点

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

原型

#include <sys/stat.h>
int mkfifo (const char *pathname, mode t mode) ;// 返回值: 成功返回0,出错返回-1

第一部分参数是文件的路径,第二部分的 mode 参数与open函数中的 mode 相同。一旦创建了一个 FIFO,就可以用一般的文件1/0函数操作它。如:open、read、write等函数。

当 open 一个FIFO时,是否设置非阻塞标志 (O_NONBLOCK) 的区别:

  • 若没有指定O_NONBLOCK(默认),只读 open 要阻塞到某个其他进程为写而打开此 FIFO。类似的,只写 open 要阻塞到某个其他进程为读而打开它
  • 若指定了O_NONBLOCK,则只读 open 立即返回。而只写 open 将出错返回 -1 。如果没有进程已经为读而打开该 FIFO,其errno置ENXIO

创建

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

代码示例

read.c

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

int main()
{
	int fd = 0;
	int n_read = 0;
	char buf[128];
	
	if(mkfifo("./file",0600) == -1 && errno!=EEXIST)//判断管道出错原因是不是在于已经创建
	{
		printf("mkfifo failure\n");
        perror("why");
	}
	else
	{
		if(errno==EEXIST)//管道已经创建
		{
            printf("file eexist\n");
        }
		else//管道未创建
		{
            printf("mkfifo successed\n");
        }
    }
	fd = open("./file",O_RDONLY);//只写方式打开
	printf("open file succeed\n");
	n_read = read(fd,buf,128);//需要等待写入完毕才能读取,才能执行下列代码
	printf("read %d byte from file,context is %s\n",n_read,buf);
	close(fd);

	return 0;
}

write.c

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

int main()
{
        char *buf="hello word!!!!!!!!!!";
        int fd;

	    fd = open("./file",O_WRONLY);//只写方式打开
        printf("write file success\n");
        write(fd,buf,strlen(buf));//将字符串内容写入fd中,写完才可以读取
	    close(fd);
	
        return 0;
}

可见执行read文件时,显示管道已经存在后停止执行后续代码,当执行write文件后read文件继续执行后续代码,实现管道间的通信。


http://www.jnnr.cn/a/1081953.html

相关文章

原理Redis-ZipList

ZipList 1) ZipList的组成2) ZipList的连锁更新问题3) 总结 1) ZipList的组成 ZipList 是一种特殊的“双端链表” &#xff0c;由一系列特殊编码的连续内存块组成。可以在任意一端进行压入/弹出操作, 并且该操作的时间复杂度为 O(1)。 ZipListEntry: ZipList 中的Entry并不像…

python -opencv 边缘检测

python -opencv 边缘检测 边缘检测步骤: 第一步&#xff1a;读取图像为灰度图 第二步&#xff1a;进行二值化处理 第三步&#xff1a;使用cv2.findContours对二值化图像提取轮廓 第三步&#xff1a;将轮廓绘制到图中 代码如下&#xff1a; from ctypes.wintypes import SIZ…

几个强力的nodejs库

几个强力的nodejs库 nodejs被视为许多Web开发人员的理想运行时环境。 nodejs的设计是为了在运行时中使用JavaScript编写的代码&#xff0c;它是世界上最流行的编程语言之一&#xff0c;并允许广泛的开发者社区构建服务器端应用程序。 nodejs提供了通过JavaScript库重用代码的…

C#开发的OpenRA游戏之属性QuantizeFacingsFromSequence(7)

C#开发的OpenRA游戏之属性QuantizeFacingsFromSequence(7) 前面分析了身体的方向,在这里继续QuantizeFacingsFromSequence属性,这个属性就是通过序列定义文件里获取身体的方向。 根据前面分析可知,同样有一个信息类QuantizeFacingsFromSequenceInfo: [Desc("Deriv…

【2023云栖】陈守元:阿里云开源大数据产品年度发布

本文根据 2023 云栖大会演讲实录整理而成&#xff0c;演讲信息如下&#xff1a; 演讲人&#xff1a;陈守元 | 阿里云计算平台事业部开源大数据产品总监 演讲主题&#xff1a;阿里云开源大数据产品年度发布 随着云计算的不断发展&#xff0c;未来数据处理和应用的趋势将围绕C…

基于安卓android微信小程序的好物分享系统

运行环境 开发语言&#xff1a;Java 框架&#xff1a;ssm JDK版本&#xff1a;JDK1.8 服务器&#xff1a;tomcat7 数据库&#xff1a;mysql 5.7&#xff08;一定要5.7版本&#xff09; 数据库工具&#xff1a;Navicat11 开发软件&#xff1a;eclipse/myeclipse/idea Maven包&a…

Springboot+vue的机动车号牌管理系统(有报告)。Javaee项目,springboot vue前后端分离项目

演示视频: Springbootvue的机动车号牌管理系统&#xff08;有报告&#xff09;。Javaee项目&#xff0c;springboot vue前后端分离项目 项目介绍&#xff1a; 本文设计了一个基于Springbootvue的前后端分离的机动车号牌管理系统&#xff0c;采用M&#xff08;model&#xff09…

LeetCode977.有序数组的平方(双指针法、暴力法、列表推导式)

LeetCode977.有序数组的平方 1.问题描述2.解题思路3.代码4.知识点 1.问题描述 给你一个按 非递减顺序 排序的整数数组 nums&#xff0c;返回 每个数字的平方 组成的新数组&#xff0c;要求也按 非递减顺序 排序。 示例 1&#xff1a; 输入&#xff1a;nums [-4,-1,0,3,10] …

Node.js之TCP(net)

Hi I’m Shendi Node.js之TCP&#xff08;net&#xff09; 最近使用Nodejs编写程序&#xff0c;需要用到自己编写的分布式工具&#xff0c;于是需要将Java版的用NodeJs重新写一遍&#xff0c;需要使用到TCP通信&#xff0c;于是在这里记录下Node.js TCP 的使用方法 依赖 需要使…

在UOS系统中编译CEF源码

一、下载cef代码 git clone gitbitbucket.org:chromiumembedded/cef.git 二、执行自动下载代码 由于chromium的代码很大&#xff0c;至少需要准备大概80G的硬盘&#xff01;&#xff01;&#xff01;整个代码量太大还是多准备一些空间吧&#xff08;强烈建议使用固态硬盘保存否…

指针变量和地址

A.指针变量和地址 理解了内存和地址的关系&#xff0c;我们再回到C语⾔&#xff0c;在C语⾔中创建变量其实就是向内存申请空间&#xff0c;比如&#xff1a; #include <stdio.h> int main() {int a 10;return 0; } ⽐如&#xff0c;上述的代码就是创建了整型变量a&…

你好,我叫Python,欢迎你认识派森。(来自关于Python语言的全方位自我介绍。

文章目录 自我简介一、Python的发展历程二、Python的特色1.语言特色2.语法特色 三、Python2与Python3的比较1.print 函数2.Unicode3.除法运算4.异常5.八进制字面量表示6.不等运算符7.python 3.0严格使用tab键进行缩进 四、Python适用开发场景及成果1.应用领域2.Python开发出的应…

特效!视频里的特效在哪制作——Adobe After Effects

今天&#xff0c;我们来谈谈一款在Adobe系列中推出的一款图形视频处理软件&#xff0c;适用于从事设计和视频特技的机构&#xff0c;包括电视台、动画制作公司、个人后期制作工作室以及多媒体工作室的属于层类型后期软件——Adobe After Effects。 Adobe After Effects&#xf…

OTP语音芯片 NV080D在智能空气检测仪的应用

随着人们对健康和环保的关注度不断提高&#xff0c;人们对看不见的家居环境也越来越重视。智能空气检测仪的市场需求也在不断增长中&#xff0c;呈现稳中向好的趋势。智能空气检测仪能够检测室内空气中的PM2.5、甲醛、TVOC等有害物质&#xff0c;同时还可以检测温湿度、空气质量…

通过easyexcel实现数据导入功能

上一篇文章通过easyexcel导出数据到excel表格已经实现了简单的数据导出功能&#xff0c;这篇文章也介绍一下怎么通过easyexcel从excel表格中导入数据。 目录 一、前端代码 index.html index.js 二、后端代码 controller service SongServiceImpl 三、功能预览 四、后端…

企业实现员工聊天和转账行为的实时监管

如何解决企业营销团队的管理问题&#xff1f; 在当今竞争激烈的市场环境中&#xff0c;企业营销团队的管理显得尤为重要。营销团队是企业发展的重要支柱&#xff0c;然而&#xff0c;一些常见的问题如员工飞单、私单、辱骂删除客户、离职带走公司客户以及工作不认真、工作量无…

FileNotFoundError: Could not find module ‘XXX\lib\site-packages\llvmlite

https://aka.ms/vs/17/release/vc_redist.x64.exe 解决方法:安装c环境 FileNotFoundError: Could not find module xxx\workenv\lib\site-packages\llvmlite\binding\llvmlite.dll (or one of its dependencies). Try using the full path with constructor syntax. 装了个新…

【数据结构与算法】Kadane‘s算法(动态规划、最大子数组和)

文章目录 一、算法原理二、例题2.1 最大子数组和2.2 环形子数组的最大和 一、算法原理 Kadanes算法是一种用于解决最大子数组和问题的动态规划算法。这类问题的目标是在给定整数数组中找到一个连续的子数组&#xff0c;使其元素之和最大&#xff08;数组含有负数&#xff09;。…

软件测试:测试分类

一. 按照测试对象划分 1.1 界面测试 界面测试(简称UI测试),按照界面的需求(UI设计稿)和界面的设计规则,对我们软件界面所展示的全部内容进行测试和检查,一般包括如下内容: • 验证界面内容的完整性,一致性,准确性,友好性,兼容性.比如页面内容对屏幕大小的自适应,换行,内容是否…

毕业设计ASP.NET 2368酒店信息管理系统【程序源码+文档+调试运行】

一、摘要 本文旨在设计并实现一个功能全面、易于使用的酒店信息管理系统。系统将管理员、客户和前台客服三种用户的需求纳入考虑&#xff0c;并针对每种用户设计了相应的功能模块。系统功能包括用户管理、客户管理、客房管理、商品管理、客房预订管理、入住管理和系统管理。此…
最新文章