[Linux]：进程间通信(上)

img

✨✨ 欢迎大家来到贝蒂大讲堂✨✨

🎈🎈养成好习惯，先赞后看哦~🎈🎈

所属专栏：Linux学习
贝蒂的主页：Betty’s blog

1. 进程间通信介绍

1.1 进程间通信的概念

进程间通信简称IPC（Interprocess communication），进程间通信就是在不同进程之间传播或交换信息。

因为进程之间具有独立性，所以一个进程是无法与另一个进程进行交流的，但是有些情况下我们一个进程必须要

进程接受一个进程的信息，所以操作系统为其提供了特定的方式。

1.1 进程间通信的目的

  1. 数据传输：一个进程要把自己的数据交给另一个进程,让其继续进行处理。
  2. 资源共享：多个进程之间共享同样的资源。
  3. 通知事件：一个进程需要向另一个或一组进程发送消息，通知它（它们）发生了某种事件（如进程终止时要通知父进程）。
  4. 进程控制：有些进程希望完全控制另一个进程的执行（如Debug进程），此时控制进程希望能够拦截另一个进程的所有陷入和异常,并能够及时知道它的状态改变。

1.1 进程间通信的本质

在操作系统中，运行的进程具有独立性，主要体现在数据层面，代码逻辑则有私有和公有情况(父子进程)。这使得进程间通信颇具难度。为实现通信，进程需借助第三方资源，即操作系统提供的一段内存区域。

画板

所以本质上，进程间通信就是让不同进程看到同一份资源，如内存或文件内核缓冲等。因资源可由操作系统不同模块提供，所以就产生了多种进程间通信方式。

2. 匿名管道

2.1 管道的概念

管道是Unix中最古老的进程间通信的形式，我们把从一个进程连接到另一个进程的数据流称为一个"管道"。

比如我说我们可以通过指令who | wc -l统计当前使用服务器的用户个数，其中指令who为查看当前服务器的登录用户，指令wc -l为统计当前行数，它们运行起来会成为两个进程。但是我们通过管道|将其链接起来，让指令wc -l读取who指令打印出的数据。

画板

2.2 匿名管道

在进程间通信中，匿名管道是一种单向通信机制。它通常用于具有“血缘关系”的进程之间，并且匿名管道只能在本地机器上使用，不能用于网络通信。

其原理就是，创建一个子进程，让父子进程都指向同一个文件，最后我们就可以让父进程向文件写入/读取数据，子进程向文件读取/写入数据。

画板

那么现在我们肯定有一个疑问，那就是创建子进程时，文件描述符数组fd_array会拷贝一份，但是指向的文件为什么不需要拷贝呢？

因为这个数组是为了让该进程能知晓已经打开的文件的个数，所以文件描述符数组fd_array是属于进程的， 既然属于进程，那子进程也需要拷贝一份，因为进程具有独立性。而这个文件是由我们操作系统所管理的，并不属于我们进程，所以子进程在拷贝时并不会再创建一份文件。

并且值得注意的是：

  • 因为父子进程共用的文件资源是由操作系统来维护的，所以当父子进程对该文件进行写入操作时，该文件缓冲区当中的数据并不会发生写时拷贝。比如说我们父子进程打印信息是在同一个屏幕打印的，而不是分别打印在两个屏幕上。
  • 虽然管道使用的是文件，但操作系统一定不会把进程进行通信的数据刷新到磁盘当中，因为这样做有IO参与会降低效率。也就是说，这种文件是一批不会把数据写到磁盘当中的文件，换句话说，磁盘文件和内存文件不一定是一一对应的，有些文件只会在内存当中存在，而不会在磁盘当中存在。

2.3 pipe函数

并且Linux系统中也为我们提供了创建匿名管道的函数——pipe函数，其使用方式如下：

  1. 函数原型：int pipe(int pipefd[2]);
  2. 返回值：创建成功返回0，否则返回-1。
  3. 参数：pipefd[2]是一个输出型参数，其中pipefd[0]代表的是管道读端的文件描述符，pipefd[1]代表的是管道写端的文件描述符。

然后我们就可以使用我们代码来实现我们的进程间通信，其中我们让父进程写入数据，子进程读取数据。

  1. 首先第一步父进程创建出一个管道。

画板

  1. 第二步父进程创建子进程。

画板

  1. 最后一步关闭对应读写端，实现单向通信。

画板

代码实现如下：

#include<cstdio>
#include<cstdlib>
#include<unistd.h>
#include<sys/types.h>
#include<sys/wait.h>
#include<iostream>
#include<cstring>
#include<string>
using namespace std;
#define N 2
#define NUM 1024
void writer(int wfd)
{string str="hello child, i am father";pid_t id=getpid();int num=0;char buffer[NUM];while(true){buffer[0] = 0; // 字符串清空，只是为了提醒阅读代码的人，我把这个数组当做字符串了snprintf(buffer,sizeof(buffer),"%s-%d-%d",str.c_str(),id,num);write(wfd,buffer,strlen(buffer));sleep(1);num++;}}
void reader(int rfd)
{char buffer[NUM];while(true){ssize_t n=read(rfd,buffer,sizeof(buffer)-1);if(n>0){buffer[n]=0;}cout<<"child ("<<getpid()<<") get a message："<<buffer<<endl;}
}
int main()
{int pipefd[2]={0};if(pipe(pipefd) < 0){perror("pipe:");return 1;}pid_t id = fork();if(id==0){//child->readclose(pipefd[1]);//关闭写端reader(pipefd[0]);close(pipefd[0]);}else if(id>0){//father->writeclose(pipefd[0]);writer(pipefd[1]);//进程等待pid_t ret=waitpid(id,nullptr,0);if(ret<0){perror("waitpid:");return 1;}close(pipefd[1]);}else{//fork errorperror("fork:");return 1;}return 0;
}

3. 命名管道

3.1 命名管道

匿名管道只能用于具有"亲缘关系"的进程间通信，所以匿名管道就具有局限性，如果我们想让两个毫不相关的进程间进行通信，就需要使用我们的命名管道。

命名管道与匿名管道都是只存在于内存中的文件，并不会向磁盘刷新，唯一不同的是匿名管道是通过父子进程看到同一份资源，而命名管道是通过路径与文件名的方式找到同一份文件资源，因为我们知道路径具有唯一性。

3.2 mkfifo函数

首先我们可以在命令行通过指令mkfifo 管道名创建一个命名管道，并且我们可以直接通过其进行通信。

然后我们可以在程序中mkfifo函数进行管道创建：

  1. 函数原型：int mkfifo(const char *pathname, mode_t mode);
  2. 返回值：创建成功返回0，否则返回-1。
  3. 参数：mkfifo函数的第一个参数是pathname，表示要创建的命名管道文件。若pathname以路径的方式给出，则将命名管道文件创建在pathname路径下。若pathname以文件名的方式给出，则将命名管道文件默认创建在当前路径下。mkfifo函数的第二个参数是mode，表示创建命名管道文件的默认权限，其守默认掩码umask的约束。

比如说我们可以通过该接口实现客户端client与服务端server间的通信。

首先是需要包含的头文件，以及为了方便管理管道，我们可以将管道文件名定义为宏。

//comment.h
#pragma once
#include<stdio.h>
#include<sys/stat.h>
#include<sys/stat.h> 
#include<sys/types.h> 
#include<fcntl.h> 
#include<unistd.h> 
#define MY_FIFO "./fifo"  //管道的创建路径

以下分别为server.c与client.c的实现：

//server.c
#include"comment.h"
int main()
{umask(0);//将文件默认掩码设置为0if(mkfifo(MY_FIFO,0666)<0)  //创建管道{perror("mkfifo:");return 1;}int fd = open(MY_FIFO,O_RDONLY);//以读方式打开命名管道文件if(fd<0){perror("open");return 2;}//处理业务逻辑,进行相应的读写while(true){char buffer[64] = {0};ssize_t s =  read(fd,buffer,sizeof(buffer)-1);if(s > 0){//读取成功buffer[s] = 0;//字符串末尾置\0printf("client send: %s\n",buffer);}else if(s == 0){//写端关闭，读取数据个数为0，printf("client close\n");break;}else{//读取错误perror("read:");break;}}close(fd);return 0;
}

#include"comment.h"
#include<string.h>   
int main()
{int fd = open(MY_FIFO,O_WRONLY);//以写方式打开命名管道文件if(fd<0){perror("open:");return 1;}//处理业务逻辑while(1){char buffer[64] = {0};//1.先从键盘读取内容printf("enter Message: ");fflush(stdout);//刷新缓冲区//从键盘读数据ssize_t s = read(0,buffer,sizeof(buffer)-1);if(s > 0){buffer[s -1]= 0;//提前置\0，把\n覆盖掉//向管道中写入数据write(fd,buffer,strlen(buffer));}}close(fd);return 0;
}

我们通过管道通信还可以实现很多功能，比如我们可以与进程替换相结合实现一个进程对另一个进程的控制等，当然我们这里就不在实现，感兴趣可以自己实现。

最后我们学习完管道相关知识之后，可能会提出以下疑惑：

命令行管道"|"究竟是匿名管道还是命名管道呢？

我们其实可以通过命令行来直接验证一下：

通过观察我们发现，三个sleep进程的PPID都是相同的，即这三个子进程都是"兄弟进程"，所以我们命令行管道是匿名管道。

4. 管道的特点

管道具有以下几个特点：

  1. 自带同步与互斥机制

管道在同一时刻只允许一个进程进行写入或读取操作，属于临界资源。为避免多个进程同时操作管道导致同时读写、交叉读写及数据不一致等问题，内核会对管道操作进行同步与互斥。

  • 互斥保证一个公共资源同一时刻只能被一个进程使用，对于管道场景即两个进程不能同时操作，需相互等待。
  • 同步则要求两个或以上进程按预定先后次序运行，在管道场景中不仅不能同时操作，还需按特定次序操作。
  1. 生命周期随进程

管道本质上通过文件进行通信，依赖于文件系统。当所有打开该文件的进程都退出后，对应的管道文件也会被释放，所以管道的存在与使用进程紧密相关，其生命周期随进程。

  1. 提供流式服务

进程 A 写入管道的数据，进程 B 每次从管道读取的数据量是任意的，没有明确的数据分割，不分报文段，这种服务方式被称为流式服务。与数据报服务不同，数据报服务的数据有明确分割，按报文段进行处理。

  1. 半双工通信
  • 单工通信(Simplex Communication)：单工模式的数据传输是单向的。通信双方中，一方固定为发送端，另一方固定为接收端。
  • 半双工通信(Half Duplex)：半双工数据传输指数据可以在一个信号载体的两个方向上传输，但是不能同时传输。
  • 全双工通信(Full Duplex)：全双工通信允许数据在两个方向上同时传输，它的能力相当于两个单工通信方式的结合。全双工可以同时(瞬时)进行信号的双向传输。
  1. 管道是面向字节流的，其大小最大为65536字节，即64KB。

5. 管道的特殊情况

在使用管道通信时，可能会出现以下四种特殊情况：

  1. 情况一：若写端进程不进行写入操作，而读端进程一直尝试读取。此时由于管道中没有数据可供读取，读端进程会被挂起，处于等待状态。只有当管道中有数据时，读端进程才会被唤醒，继续进行读取操作。
  2. 情况二：当读端进程不进行读取，而写端进程持续写入时，一旦管道被写满，写端进程就会被挂起。只有在管道中的数据被读端进程读取后，写端进程才会被唤醒，继续进行写入操作。
  3. 情况三：当写端进程将数据写完后关闭写端，读端进程在将管道中的数据全部读完后，此时read返回值为0，我们可以继续执行该进程之后的代码逻辑。
  4. 情况四：若读端进程关闭读端，而写端进程仍在持续向管道写入数据，此时操作系统会将写端进程杀掉。

前三种情况我们都可以很好理解，我们最后验证一下情况四，既然其会被操作系统杀死，我们就可以通过进程等待获取退出信息来验证：

#include <stdio.h>
#include <unistd.h>
#include <string.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/wait.h>
int main()
{int fd[2] = { 0 };if (pipe(fd) < 0){ perror("pipe");return 1;}pid_t id = fork(); //创建子进程if (id == 0){//childclose(fd[0]); //子进程向管道写入数据const char* msg = "hello father, I am child";int count = 5;while (count--){write(fd[1], msg, strlen(msg));sleep(1);}close(fd[1]); //子进程写入完毕，关闭文件exit(0);}//fatherclose(fd[1]); //父进程关闭写端close(fd[0]); //父进程直接关闭读端int status = 0;waitpid(id, &status, 0);printf("child get signal:%d\n", status & 0x7F); //打印子进程收到的信号return 0;
}

我们可以看到，这种情况进程的确会被操作系统杀死，并接受到13号信号。

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

如若内容造成侵权/违法违规/事实不符，请联系一条长河网进行投诉反馈，一经查实，立即删除！

相关文章

jdk相关介绍

jdk相关介绍

JDK&#xff0c;全称Java Development Kit&#xff0c;是Java语言开发的基础工具包。它包含了Java运行时环境&#xff08;JRE&#xff09;以及用于开发Java应用程序的各种工具和库。JDK为Java程序员提供了编译、调试和运行Java应用程序所需的全部环境。 JDK的主要组成部分包括&…
阅读更多...
离线数仓DWD层

离线数仓DWD层

离线数仓DWD层 DWD层设计要点&#xff1a;9.1 交易域加购事务事实表9.2 交易域下单事务事实表9.3 交易域取消订单事务事实表9.4 交易域支付成功事务事实表9.5 交易域退单事务事实表9.6 交易域退款成功事务事实表9.7 交易域购物车周期快照事实表9.8 工具域优惠券领取事务事实表9…
阅读更多...
2024/9/15 408“回头看”之应用层小总结（下）

2024/9/15 408“回头看”之应用层小总结（下）

域名系统DNS: 本地域名服务器 本地域名服务器起着代理的作用&#xff0c;会将报文转发到根域名服务器、顶级域名服务器、权限域名服务器。 递归查询&#xff1a; 迭代查询&#xff1a; 文件传送协议FTP: FTP客户和FTP服务器之间使用的是tcp连接。 控制连接使用21端口&…
阅读更多...
树莓派5上手

树莓派5上手

1 安装系统 Raspberry Pi OS 是基于 Debian 的免费操作系统&#xff0c;针对 Raspberry Pi 硬件进行了优化。Raspberry Pi OS 支持超过 35,000 个 Debian 软件包。树莓派 5 可以安装各种系统&#xff0c;但是如果对于系统没有特殊的要求&#xff0c;还是安装 Raspberry Pi OS …
阅读更多...
基于SSM的二手车管理系统的设计与实现 （含源码+sql+视频导入教程）

基于SSM的二手车管理系统的设计与实现 （含源码+sql+视频导入教程）

&#x1f449;文末查看项目功能视频演示获取源码sql脚本视频导入教程视频 1 、功能描述 基于SSM的二手车管理系统4拥有三种角色 管理员&#xff1a;订单管理、在售车辆管理、下架车辆管理、品牌管理、分类管理、推荐管理、统计等 商家&#xff1a;登录注册、添加/下架/删除车辆…
阅读更多...
各类元器件调试记录-E+H

各类元器件调试记录-E+H

一、EH压力传感器 适用型号为&#xff1a; Cerabar S PMC71, PMP71/75 Deltabar S FMD76/77/78, PMD70/75 Deltapilot S FMB70 调试过程&#xff1a;(后续补上图片) 一、湿标(湿调) 1、前提条件&#xff1a;罐体可以灌满和实际水箱水位高度 2、调试步骤&#xff1a; A、调节语…
阅读更多...
网络安全有救了，37所高校新增网络安全空间安全专业

网络安全有救了，37所高校新增网络安全空间安全专业

《网安面试指南》http://mp.weixin.qq.com/s?__bizMzkwNjY1Mzc0Nw&mid2247484339&idx1&sn356300f169de74e7a778b04bfbbbd0ab&chksmc0e47aeff793f3f9a5f7abcfa57695e8944e52bca2de2c7a3eb1aecb3c1e6b9cb6abe509d51f&scene21#wechat_redirect 《Java代码审…
阅读更多...
凸优化学习（3）——对偶方法、KKT条件、ADMM

凸优化学习（3）——对偶方法、KKT条件、ADMM

&#x1f345; 写在前面 &#x1f468;‍&#x1f393; 博主介绍&#xff1a;大家好&#xff0c;这里是hyk写算法了吗&#xff0c;一枚致力于学习算法和人工智能领域的小菜鸟。 &#x1f50e;个人主页&#xff1a;主页链接&#xff08;欢迎各位大佬光临指导&#xff09; ⭐️近…
阅读更多...
鸿蒙交互事件开发07——手势竞争问题

鸿蒙交互事件开发07——手势竞争问题

如果你也对鸿蒙开发感兴趣&#xff0c;加入“Harmony自习室”吧&#xff01;扫描下方名片&#xff0c;关注公众号&#xff0c;公众号更新更快&#xff0c;同时也有更多学习资料和技术讨论群。 1、背景 在文章鸿蒙交互事件开发05——常用的6种手势类型中&#xff0c;有朋友留言…
阅读更多...
C语言自定义类型-联合与枚举

C语言自定义类型-联合与枚举

在之前的文章中&#xff0c;我们学到了结构体类型&#xff0c;而结构体其实归属于一个大类——自定义类型。那么今天我们就继续讲解关于自定义类型的知识~ 一、类型命名关键字-typedef typedef的作用其实就是标题的意思——为一种类型赋予新的名字。 ① typedef在变量中的应…
阅读更多...
Java【集合】

Java【集合】

一、集合的概述 集合建立在数组基础上&#xff0c;主要位于java.util包中&#xff0c;用来存储Java类对象&#xff0c;并且可以实现各种数据结构。 集合大小可以改变&#xff0c;可以存放不同数据类型数据。集合不能存放基本类型数据&#xff0c;只能存放引用数据类型数据。集…
阅读更多...
力扣题解2848

力扣题解2848

大家好&#xff0c;欢迎来到无限大的频道。 今日继续给大家带来力扣题解。 题目描述&#xff08;简单&#xff09;&#xff1a; 与车相交的点 给你一个下标从 0 开始的二维整数数组 nums 表示汽车停放在数轴上的坐标。对于任意下标 i&#xff0c;nums[i] [starti, endi] &…
阅读更多...
中考全国45套（全国教育发达地区中考试卷）

中考全国45套（全国教育发达地区中考试卷）

文章目录 获取方式 为什么选择这份资源&#xff1f; 权威性与全面性&#xff1a;我们精心搜集了全国教育发达地区的最新中考试卷&#xff0c;确保每一套试卷都代表了该地区的教学水平和考试趋势。这不仅涵盖了丰富的知识点&#xff0c;还融入了各地独特的命题风格&#xff0c;让…
阅读更多...
2020ICPC上海 D - Walker M - Gitignore

2020ICPC上海 D - Walker M - Gitignore

D: 首先显然要二分,判断当前二分的mid时间下是否能满足走满0~n 枚举所有情况,这里按照左,右起点p1,p2分别讨论 p1向左 p2向左(以下向左和向右都代表向左或者向右到墙,而不代表初速度方向)&#xff0c;只需要计算p1或者p2反弹之后还能走距离n就是合法 p1向左 p2向右&#xff…
阅读更多...
3.4.2 __ipipe_init_early之fixup_percpu_data()

3.4.2 __ipipe_init_early之fixup_percpu_data()

点击查看系列文章 》 Interrupt Pipeline系列文章大纲-CSDN博客 3.4.2 __ipipe_init_early之fixup_percpu_data() 这个函数只有在CPU是SMP对称多core的情况下&#xff0c;才会真正运作&#xff0c;否则就是个空函数。 #ifdef CONFIG_SMPstatic inline void fixup_percpu_data…
阅读更多...
H5 three.js 实现六年级观察物体

H5 three.js 实现六年级观察物体

o(&#xffe3;▽&#xffe3;)ブ 我又带着新的demo来啦~ 预览 功能点 立方体的阴影 立方体的添加 位置记录 最大限制 三视图展示 立方体的移除 答题模式 随机出题 题库出题 源码 注释算是比较全了&#xff0c;可能部分会有点绕&#xff0c;还能够再优化一下~ <!DOCTYPE …
阅读更多...
【代码随想录训练营第42期 续Day58打卡 - 图论Part8 - Dijkstra算法

【代码随想录训练营第42期 续Day58打卡 - 图论Part8 - Dijkstra算法

目录 一、Dijkstra算法 实现方式 1、使用优先队列&#xff08;最小堆&#xff09; 2、朴素法&#xff08;简单数组&#xff09; 二、经典例题 题目&#xff1a;卡码网 47. 参加科学大会 题目链接 题解&#xff1a;朴素Dijkstra 三、小结 一、Dijkstra算法 刚入门Dijks…
阅读更多...
AI论文写作测评！类似茅茅虫论文写作助手网站

AI论文写作测评！类似茅茅虫论文写作助手网站

在当前的学术研究和写作环境中&#xff0c;AI论文写作助手成为了许多学者和学生的重要工具。其中&#xff0c;千笔-AIPassPaper和茅茅虫论文写作助手是两款备受关注的平台。本文将对这两款工具进行详细测评&#xff0c;并推荐适合不同需求的用户使用。 千笔-AIPassPaper AI论文…
阅读更多...
实现领域驱动设计（DDD）系列详解：限界上下文

实现领域驱动设计（DDD）系列详解：限界上下文

随着微服务的兴起&#xff0c;限界上下文更是被拔高到战略设计的核心地位&#xff0c;也成了连接问题空间与解空间的重要桥梁&#xff0c;但不可否认&#xff0c;一方面&#xff0c;领域驱动设计社区纷纷发声强调它的重要性&#xff1b;另一方面&#xff0c;还有很多人依旧弄不…
阅读更多...
游戏算法专题之PRD算法:听说你想凭运气抽中荣耀水晶?

游戏算法专题之PRD算法:听说你想凭运气抽中荣耀水晶?

PRD算法全称Pseudo-Random Distribution。是概率分布中的一种常见算法&#xff0c;在游戏开发领域中很常用。 PRD用于控制随机事件的触发概率&#xff0c;使其表现得更加符合预期&#xff0c;相比于传统得随机数生成&#xff0c;PRD算法可以平滑得控制随机事件的触发次数&…
阅读更多...
最新文章

Copyright @ 2022~2023