Linux多进程开发2 - 进程间通信

1、进程间通信的概念        

        进程是一个独立的资源分配单元，不同进程之间的资源是独立的，没有关联，不能在一个进程中直接访问另一个进程的资源。但是，进程不是孤立的，不同的进程需要进行信息的交换和状态的传递等，因此需要进程间通信(IPC:Inter Processes Communication)。

进程间通信的目的:

  • 数据传输：一个进程需要将它的数据发送给另一个进程；
  • 通知事件：一个进程需要向另一个或一组进程发送消息，通知它们发生了某种事件(如进程终止时要通知父进程)；
  • 资源共享：多个进程之间共享同样的资源。为了做到这一点，需要内核提供互斥和同步机制；
  • 进程控制：有些进程希望完全控制另一个进程的执行(如Debug进程)，此时控制进程希望能够拦截另一个进程的所有陷入和异常，并能够及时知道它的状态改变

2、Linux 进程间通信的方式

3、管道

        UNIX对操作系统开发最重要的贡献之一是管道。管道是一个位于CPU内核内存中维护的环形缓冲区，运行两个进程以生产者/消费者的模型进行通信。因此管道是一个先进先出的 FIFO 队列，由一个进程写，另一个进程读。

        管道在创建时获得一个固定大小的字节数。当一个进程试图往管道中写时，如果有足够的空间，则写请求被立即执行；否则该进程被阻塞。

        类似地，如果一个读进程试图读取多于当前管道中的字节数时，它也被阻塞；否则读请求被立即执行。

        操作系统强制实施互斥，即一次只能有一个进程可以访问管道。在管道道中的数据的传递方向是单向的，一端用于写入，一端用于读取，管道是半双工(对讲机，同一时刻只有一方可以讲话)的。

        从管道读数据是一次性操作，数据一旦被读走，就会被管道抛弃，释放空间以便写更多的数据，在管道中无法使用 lseek() 函数来随机访问数据

        管道分为两类：匿名管道、有名管道。只有具有血缘关系(比如父子进程、兄弟进程)的进程才可以共享匿名管道，而不相关的进程只能共享有名管道。

4、管道的读写特点

    读管道：
        管道中有数据，read返回实际读到的字节数。
        管道中无数据：
            写端被全部关闭，read返回0（相当于读到文件的末尾）
            写端没有完全关闭，read阻塞等待

    写管道：
        管道读端全部被关闭，进程异常终止（进程收到SIGPIPE信号）
        管道读端没有全部关闭：
            管道已满，write阻塞
            管道没有满，write将数据写入，并返回实际写入的字节数

5、有名管道的使用

        用一个简单的例子来说明有名管道的具体使用过程

        1、创建一个有名管道，向管道里循环写入100个数字

        2、通过读管道的方式同步读出这些数字

创建管道并写入数据

#include <stdio.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <stdlib.h>
#include <unistd.h>
#include <fcntl.h>
#include <string.h>// 向管道中写数据
int main() {// 1.判断文件是否存在int ret = access("test", F_OK);if(ret == -1) {printf("管道不存在，创建管道\n");// 2.创建管道文件ret = mkfifo("test", 0664);if(ret == -1) {perror("mkfifo");exit(0);}       }// 3.以只写的方式打开管道int fd = open("test", O_WRONLY);if(fd == -1) {perror("open");exit(0);}// 写数据for(int i = 0; i < 100; i++) {char buf[1024];sprintf(buf, "hello, %d\n", i);printf("write data : %s\n", buf);write(fd, buf, strlen(buf));sleep(1);}close(fd);return 0;
}

创建有名管道(fifo):

    1.通过命令： mkfifo 管道名称

    2.通过函数：int mkfifo(const char *pathname, mode_t mode);

    #include <sys/types.h>

    #include <sys/stat.h>

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

        参数：

            - pathname: 管道名称的路径

            - mode: 文件的权限 和 open 的 mode 是一样的，是一个八进制的数

        返回值：成功返回0，失败返回-1，并设置错误号

读出数据

#include <stdio.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <stdlib.h>
#include <unistd.h>
#include <fcntl.h>// 从管道中读取数据
int main() {// 1.打开管道文件int fd = open("test", O_RDONLY);if(fd == -1) {perror("open");exit(0);}// 读数据while(1) {char buf[1024] = {0};int len = read(fd, buf, sizeof(buf));if(len == 0) {printf("写端断开连接了...\n");break;}printf("recv buf : %s\n", buf);}close(fd);return 0;
}

运行结果：

        *当先暂停写数据时，读端会显示“写端断开连接了”

        *当先暂停读数据时，写端也会跟着暂停，原理是管道读端被全部关闭，进行异常终止（收到一个 SIGPIPE 信号）

根据实验结果得出结论：

        1.一个为只读而打开一个管道的进程会阻塞，直到另外一个进程为只写打开管道

        2.一个为只写而打开一个管道的进程会阻塞，直到另外一个进程为只读打开管道

6、有名管道实现简单版聊天功能

任务总览图

分别创建2个进程来模拟2个用户

用户A

#include <stdio.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <stdlib.h>
#include <fcntl.h>
#include <string.h>int main() {// 1.判断有名管道文件是否存在int ret = access("fifo1", F_OK);if(ret == -1) {// 文件不存在printf("管道不存在，创建对应的有名管道\n");ret = mkfifo("fifo1", 0664);if(ret == -1) {perror("mkfifo");exit(0);}}ret = access("fifo2", F_OK);if(ret == -1) {// 文件不存在printf("管道不存在，创建对应的有名管道\n");ret = mkfifo("fifo2", 0664);if(ret == -1) {perror("mkfifo");exit(0);}}// 2.以只写的方式打开管道fifo1int fdw = open("fifo1", O_WRONLY);if(fdw == -1) {perror("open");exit(0);}printf("打开管道fifo1成功,等待写入...\n");// 3.以只读的方式打开管道fifo2int fdr = open("fifo2", O_RDONLY);if(fdr == -1) {perror("open");exit(0);}printf("打开管道fifo2成功,等待读取...\n");char buf[128];// 4.循环的写读数据while(1) {memset(buf, 0, 128);// 获取标准输入的数据fgets(buf, 128, stdin);// 写数据ret = write(fdw, buf, strlen(buf));if(ret == -1) {perror("write");exit(0);}// 5.读管道数据memset(buf, 0, 128);ret = read(fdr, buf, 128);if(ret <= 0) {perror("read");break;}printf("fromB: %s\n", buf);}// 6.关闭文件描述符close(fdr);close(fdw);return 0;
}

用户B

#include <stdio.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <stdlib.h>
#include <fcntl.h>
#include <string.h>int main() {// 1.判断有名管道文件是否存在int ret = access("fifo1", F_OK);if(ret == -1) {// 文件不存在printf("管道不存在，创建对应的有名管道\n");ret = mkfifo("fifo1", 0664);if(ret == -1) {perror("mkfifo");exit(0);}}ret = access("fifo2", F_OK);if(ret == -1) {// 文件不存在printf("管道不存在，创建对应的有名管道\n");ret = mkfifo("fifo2", 0664);if(ret == -1) {perror("mkfifo");exit(0);}}// 2.以只读的方式打开管道fifo1int fdr = open("fifo1", O_RDONLY);if(fdr == -1) {perror("open");exit(0);}printf("打开管道fifo1成功, 等待读取...\n");// 3.以只写的方式打开管道fifo2int fdw = open("fifo2", O_WRONLY);if(fdw == -1) {perror("open");exit(0);}printf("打开管道fifo2成功, 等待写入...\n");char buf[128];// 4.循环的读写数据while(1) {// 5.读管道数据memset(buf, 0, 128);ret = read(fdr, buf, 128);if(ret <= 0) {perror("read");break;}printf("fromA: %s\n", buf);memset(buf, 0, 128);// 获取标准输入的数据fgets(buf, 128, stdin);// 写数据ret = write(fdw, buf, strlen(buf));if(ret == -1) {perror("write");exit(0);}}// 6.关闭文件描述符close(fdr);close(fdw);return 0;
}

fgets(buf, 128, stdin);

        表示从键盘输入(stdin)读取最多128个字符到 buf 数组中，直到遇到换行符、文件结束符或者读取到了第127个字符为止。fgets 函数会将读取的字符放入 buf 数组中，同时在末尾添加一个null字符，以确保字符串以null结尾。

实验结果：

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

从C到Py：Python的组合数据类型

从C到Py：Python的组合数据类型

这一部分开始&#xff0c;我们将讲解Python中的组合数据类型&#xff0c;这里的知识十分基础而且重要&#xff0c;也已经与C语言的框架愈差愈远。 目录 序列和索引 1、概念 2、切片操作 3、序列的其他操作 列表 1、概念 2、创建与删除 3、列表的操作 4、列表生成式 …
阅读更多...
string和char*的转换

string和char*的转换

1、使用 c_str() 方法&#xff1a; std::string 类提供了一个 c_str() 方法&#xff0c;它返回一个指向以 null 结尾的字符数组的指针&#xff08;即 C 风格的字符串&#xff09;。 std::string str "Hello"; const char* charPtr str.c_str();注意&#xff1a;返…
阅读更多...
【YOLOV5 入门】——Pyside6/PyQt5可视化UI界面后端逻辑

【YOLOV5 入门】——Pyside6/PyQt5可视化UI界面后端逻辑

声明&#xff1a;笔记是做项目时根据B站博主视频学习时自己编写&#xff0c;请勿随意转载&#xff01; 一、环境安装 VScode/Pycharm终端进入虚拟环境后&#xff0c;输入下面代码安装pyside6&#xff0c;若用的Pycharm作为集成开发环境&#xff0c;也下载个pyqt5&#xff1a; …
阅读更多...
得物 Zookeeper SLA 也可以 99.99% ｜ 得物技术

得物 Zookeeper SLA 也可以 99.99% ｜ 得物技术

一、背景 ZooKeeper&#xff08;ZK&#xff09;是一个诞生于2007年的分布式应用程序协调服务。尽管出于一些特殊的历史原因&#xff0c;许多业务场景仍然不得不依赖它。比如&#xff0c;Kafka、任务调度等。特别是在 Flink 混合部署 ETCD 解耦 时&#xff0c;业务方曾要求绝对…
阅读更多...
什么是蓝桥杯？

什么是蓝桥杯？

蓝桥杯是中国著名的计算机程序设计竞赛&#xff0c;旨在挖掘和培养优秀的计算机人才。自2004年起&#xff0c;蓝桥杯已经成功举办多届比赛&#xff0c;吸引了全国各地的大批学生参与其中。这项比赛不仅是展示学生编程技能的平台&#xff0c;更是一个促进学术交流和提升创新能力…
阅读更多...
C语言之探秘：访问结构体空指针与结构体空指针的地址的区别(九十三)

C语言之探秘：访问结构体空指针与结构体空指针的地址的区别(九十三)

简介&#xff1a; CSDN博客专家&#xff0c;专注Android/Linux系统&#xff0c;分享多mic语音方案、音视频、编解码等技术&#xff0c;与大家一起成长&#xff01; 优质专栏&#xff1a;Audio工程师进阶系列【原创干货持续更新中……】&#x1f680; 优质专栏&#xff1a;多媒…
阅读更多...
npm配置阿里镜像库

npm配置阿里镜像库

1、配置阿里云镜像源 #查看当前使用的镜像地址命令 npm config get registry#设置阿里镜像源 npm config set registry http://registry.npmmirror.com 这里要注意下&#xff0c;之前的镜像源地址 https://registry.npm.taobao.org/ 已经不能用了&#xff0c;这里要更改为新…
阅读更多...
SpringCloud之LoadBalancer负载均衡器的简单使用

SpringCloud之LoadBalancer负载均衡器的简单使用

SpringCloud之LoadBalancer负载均衡器的简单使用 loadbalancer用于对提供服务的集群做一个节点的选取规则。 如图所示&#xff0c;load balancer集成在调用方 示例 创建loadbalance-base模块,并引入相关依赖 <dependencies><dependency><groupId>org.spr…
阅读更多...
【玩转PGSQL】基础管理防火墙及用户权限管理-知否知否

【玩转PGSQL】基础管理防火墙及用户权限管理-知否知否

基础管理 登录方式 psql -d postgres -h 127.0.0.1 -p 5432 -U postgre-d 库 -h IP -p 端口 -U 用户基础sql -- 查看所有库 \l-- 创建库 create database test;-- 进入库 \c test-- 查看所有表 \d-- 查看表结构 \d t1;-- 查看所有用户 \du-- 列显示 \x-- 显示当前库下schem…
阅读更多...
基于有序抖动块截断编码的水印嵌入和提取算法matlab仿真

基于有序抖动块截断编码的水印嵌入和提取算法matlab仿真

目录 1.算法运行效果图预览 2.算法运行软件版本 3.部分核心程序 4.算法理论概述 5.算法完整程序工程 1.算法运行效果图预览 噪声测试 旋转测试 压缩测试 2.算法运行软件版本 matlab2022a 3.部分核心程序 ............................................................…
阅读更多...
STM32—外部中断_按键控制 LED

STM32—外部中断_按键控制 LED

目录 1 、 电路构成及原理图 2 、编写实现代码 main.c exti.c 3、代码讲解 4、烧录到开发板调试、验证代码 5、检验效果 开发板介绍 相关笔记 此笔记基于朗峰 STM32F103 系列全集成开发板的记录 1 、 电路构成及原理图 外部中断---EXTI EXTI&#xff08;External…
阅读更多...
codeforce #925 (div3) 题解

codeforce #925 (div3) 题解

D. Divisible Pairs 给出数组 a a a&#xff0c;如果二元组 ( i , j ) (i,j) (i,j)满足 a i a j m o d x 0 & & a i − a j m o d y 0 a_i a_j mod x 0 \&\& a_i - a_j mod y 0 ai​aj​modx0&&ai​−aj​mody0&#xff0c;则beauty。其中 i &…
阅读更多...
BEVFormer代码阅读

BEVFormer代码阅读

1. 代码地址 https://github.com/fundamentalvision/BEVFormer 2. 代码结构 个人理解&#xff0c;代码库中的代码与两篇论文都略有不同&#xff0c;总结起来&#xff0c;其结构如下。 3. BEVFormer 的 Pipeline 根据自己调试算法模型以及对论文的理解&#xff0c;我这里将 …
阅读更多...
牛客网刷题 ：BC50 你是天才吗

牛客网刷题 ：BC50 你是天才吗

描述 据说智商140以上者称为天才&#xff0c;KiKi想知道他自己是不是天才&#xff0c;请帮他编程判断。输入一个整数表示一个人的智商&#xff0c;如果大于等于140&#xff0c;则表明他是一个天才&#xff0c;输出“Genius”。 输入描述&#xff1a; 多组输入&#xff0c;每…
阅读更多...
（十）C++自制植物大战僵尸游戏设置功能实现

（十）C++自制植物大战僵尸游戏设置功能实现

植物大战僵尸游戏开发教程专栏地址http://t.csdnimg.cn/m0EtD 游戏设置 游戏设置功能是一个允许玩家根据个人喜好和设备性能来调整游戏各项参数的重要工具。游戏设置功能是为了让玩家能够根据自己的需求和设备性能来调整游戏&#xff0c;以获得最佳的游戏体验。不同的游戏和平…
阅读更多...
音视频、网络带宽等常用概念详解

音视频、网络带宽等常用概念详解

1.aac音频参数解释 AAC帧大小为1024个sample&#xff1a;指AAC编码一般以1024个采样为一个音频帧。 采样率48khz&#xff1a;指1秒&#xff08;即1000毫秒&#xff09;采集48000次。 计算1秒有多少帧&#xff1a;48000 / 1024 46.875 a&#xff08;用a表示计算结果&#xff0…
阅读更多...
vite - WebAssembly入门

vite - WebAssembly入门

1. 初始化 vite 项目 1.1 安装 nvm&#xff08;可选&#xff09; brew update brew install nvm在 ~/.zshrc 添加 export NVM_DIR~/.nvm source $(brew --prefix nvm)/nvm.sh执行如下命令 source ~/.zshrc1.2 安装 node nvm install nodenvm ls -> …
阅读更多...
PyTorch Scheduler动态调整学习率

PyTorch Scheduler动态调整学习率

文章目录 PyTorch动态调整学习率1.使用官方scheduler2.自定义scheduler参考 PyTorch动态调整学习率 深度学习中长久以来一直存在一个令人困扰的问题&#xff0c;那就是如何选择适当的学习率。如果学习速率设置得过小&#xff0c;会导致模型收敛速度缓慢&#xff0c;训练时间延…
阅读更多...
vscode 打代码光标特效

vscode 打代码光标特效

vscode 打代码光标特效 在设置里面找到settings 进入之后在代码最下方加入此代码 "explorer.confirmDelete": false,"powermode.enabled": true, //启动"powermode.presets": "fireworks", // 火花效果// particles、 simple-rift、e…
阅读更多...
Day13-C++基础之文件操作

Day13-C++基础之文件操作

文件操作 #include<iostream> #include<fstream> #include<string> using namespace std; ​ class Person{ public:char m_Name[64];int m_Age; }; ​ int main(){//文本文件操作 ​//写文件//1.包含头文件 fstream//2.创建流对象ofstream ofs;//3.指定打开…
阅读更多...
最新文章

Copyright @ 2022~2023