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.rhkb.cn/news/309905.html

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

相关文章

【算法基础】插入排序与二分查找、升级二分查找

【算法基础】插入排序与二分查找、升级二分查找

文章目录 1. 插入排序1.1 插入排序的思想1.2 插入排序的实现 2. 普通二分查找2.1 普通二分查找的思想2.2 普通二分查找的实现 3. 升级二分查找3.1 升级二分查找思想3.2 升级二分查找实现 1. 插入排序 1.1 插入排序的思想 插入排序很类似于已有一副有序的扑克牌&#xff0c;不断…
阅读更多...
儿童对讲机玩具AW30N方案

儿童对讲机玩具AW30N方案

一、儿童对讲机简介 儿童对讲机一种专为孩子们设计的通讯设备&#xff0c;可以让父母与孩子之间进行双向通讯&#xff0c;增强亲子关系&#xff0c;增强孩子的可玩性。儿童对讲机近几年发展的比较快&#xff0c;相比之前的方案&#xff0c;在设计、生产、成本都优化了很多&…
阅读更多...
Win10 使用Telnet

Win10 使用Telnet

命令行 telnet 127.0.0.1 80 调试是否能连接服务 输入exit 回车即可退出 相比于ping的不同
阅读更多...
Java编译期注解处理器AbstractProcessor使用

Java编译期注解处理器AbstractProcessor使用

我们接触的注解主要分为以下两类 运行时注解&#xff1a;通过反射在运行时动态处理注解的逻辑编译时注解&#xff1a;通过注解处理器在编译期动态处理相关逻辑 编译期注解我们常用的有Lombok&#xff0c;在class文件中自动生成get和set方法 解编译期处理流程最关键的一个类就…
阅读更多...
【TCP套接字编程,UDP套接字编程】

【TCP套接字编程,UDP套接字编程】

文章目录 TCP套接字编程Socket编程Socket 编程TCP套接字编程TCPsocket编程C/S socket 交互: TCP数据结构 sockaddr_in数据结构 hostent UDP套接字编程UDP Socket编程Client/server socket 交互: UDP TCP套接字编程 Socket编程 应用进程使用传输层提供的服务才能交换报文。实现…
阅读更多...
【嵌入式】交叉编译指南：将开源软件带到嵌入式世界

【嵌入式】交叉编译指南：将开源软件带到嵌入式世界

&#x1f9d1; 作者简介&#xff1a;阿里巴巴嵌入式技术专家&#xff0c;深耕嵌入式人工智能领域&#xff0c;具备多年的嵌入式硬件产品研发管理经验。 &#x1f4d2; 博客介绍&#xff1a;分享嵌入式开发领域的相关知识、经验、思考和感悟,欢迎关注。提供嵌入式方向的学习指导…
阅读更多...
PostgreSQL入门到实战-第二十八弹

PostgreSQL入门到实战-第二十八弹

PostgreSQL入门到实战 PostgreSQL中数据分组操作(三)官网地址PostgreSQL概述PostgreSQL中GROUPING SETS命令理论PostgreSQL中GROUPING SETS命令实战更新计划 PostgreSQL中数据分组操作(三) 使用PostgreSQL grouping sets子句在查询中生成多个分组集。 官网地址 声明: 由于操…
阅读更多...
建筑覆膜板是干什么用的？

建筑覆膜板是干什么用的？

在现代建筑施工中,覆膜板是一种非常重要的工程材料。它俗称"模板",主要用于浇筑混凝土和钢筋结构的支撑和固定。覆膜板的质量直接关系到建筑物的施工效率和质量,因此选择一家专业、靠谱的生产厂家至关重要。 贵港市能强优品木业有限公司就是一家广西知名的建筑覆膜板…
阅读更多...
[SystemVerilog]常见设计模式/实践

[SystemVerilog]常见设计模式/实践

常见设计模式/实践 RTL 设计&#xff08;尤其是 ASIC&#xff09;的最终目标是制作出最小、最快的电路。为此&#xff0c;我们需要了解综合工具如何分析和优化设计。此外&#xff0c;我们还关注仿真速度&#xff0c;因为等待测试运行实际上是在浪费工程精力。虽然综合和仿真工…
阅读更多...
【Linux】封装一下简单库 理解文件系统

【Linux】封装一下简单库 理解文件系统

提示&#xff1a;文章写完后&#xff0c;目录可以自动生成&#xff0c;如何生成可参考右边的帮助文档 目录 前言 一、封装一下简单库 二、理解一下stdin(0)、stdout(1)、stderr(3) 2.1、为什么要有0、1、2呢&#xff1f; 2.2、特点 2.3、如果我想让2也和1重定向到一个文件…
阅读更多...
如何在Linux系统部署Joplin笔记并结合内网穿透实现无公网IP远程访问

如何在Linux系统部署Joplin笔记并结合内网穿透实现无公网IP远程访问

文章目录 1. 安装Docker2. 自建Joplin服务器3. 搭建Joplin Sever4. 安装cpolar内网穿透5. 创建远程连接的固定公网地址 Joplin 是一个开源的笔记工具&#xff0c;拥有 Windows/macOS/Linux/iOS/Android/Terminal 版本的客户端。多端同步功能是笔记工具最重要的功能&#xff0c;…
阅读更多...
华为数通方向HCIP-DataCom H12-821题库(多选题：321-340)

华为数通方向HCIP-DataCom H12-821题库(多选题：321-340)

第321题 关于OSPF的命令描述，不正确的是: A、stub区域和totally stub区域配置了no-summary参数 B、OSPFv2和OSPF v3配置接口命令的区别是OSPF V2可以使用network命令，而OSPFv3直接 C、在接口上使能stubrouter命令用来配置次路由器为stub路由器，stub路由器可以与非stub路由 …
阅读更多...
微软搭建零售新媒体创意工作室大举抢占数字营销广告市场

微软搭建零售新媒体创意工作室大举抢占数字营销广告市场

“微软新零售创意工作室新平台利用生成式人工智能&#xff0c;在几秒钟内轻松定制横幅广告。零售媒体预计到2026年将成为一个价值1000亿美元的行业。” 零售媒体在过去几年中发展迅速。根据eMarketerOpens在新窗口的数据&#xff0c;预计到2024年&#xff0c;仅美国的零售媒体…
阅读更多...
【Node.js】Express学习笔记（黑马）

【Node.js】Express学习笔记（黑马）

目录 初识 ExpressExpress 简介Express 的基本使用托管静态资源nodemon Express 路由路由的概念路由的使用 Express 中间件中间件的概念Express 中间件的初体验中间件的分类 初识 Express Express 简介 什么是 Express&#xff1f; 官方给出的概念&#xff1a;Express 是基于…
阅读更多...
navicat远程连接mysql的异常解决-1130-2003-10061

navicat远程连接mysql的异常解决-1130-2003-10061

结论&#xff1a; 1、修改数据库下root用户的host字段(为空或%) 2、修改 /etc/mysql/mysql.conf.d/mysqld.cnf 文件下 bind-address 的配置为 0.0.0.0 或者屏蔽此配置内容 (默认配置是&#xff1a; bind-address 127.0.0.1) 补充&#xff1a; 查看数据库下用户与host字段的关…
阅读更多...
3D医疗图像配准 | 基于Vision-Transformer+Pytorch实现的3D医疗图像配准算法

3D医疗图像配准 | 基于Vision-Transformer+Pytorch实现的3D医疗图像配准算法

项目应用场景 面向医疗图像配准场景&#xff0c;项目采用 Pytorch ViT 来实现&#xff0c;形态为 3D 医疗图像的配准。 项目效果 项目细节 > 具体参见项目 README.md (1) 模型架构 (2) Vision Transformer 架构 (3) 量化结果分析 项目获取 https://download.csdn.net/down…
阅读更多...
【uniapp】vscode安装插件、ts校验、允许json文件注释

【uniapp】vscode安装插件、ts校验、允许json文件注释

1、vscode安装的插件&#xff1a; uni-create-viewuni-hlperuniapp小程序扩展 2、ts校验 安装插件&#xff1a; pnpm i -D types/wechat-miniprogram uni-helper/uni-app-types配置tsconfig.json {"extends": "vue/tsconfig/tsconfig.json","compi…
阅读更多...
内核是如何接收⽹络包的？

内核是如何接收⽹络包的？

应用层做的那么舒服&#xff0c;为什么还要去看驱动和内核&#xff1f; “工作了四五年&#xff0c;并不是有4-5年经验&#xff0c;⽽是⼯作了4-5年⽽已” 引言 Linux里最重要的一个模块-网络模块,用简单的udp来举例&#xff0c;下图是我在大学的时候的基于linux的socket网络…
阅读更多...
顶顶通呼叫中心中间件(mod_cti基于FreeSWITCH)-回铃音补偿

顶顶通呼叫中心中间件(mod_cti基于FreeSWITCH)-回铃音补偿

文章目录 前言联系我们解决问题操作步骤 前言 回铃音&#xff1a; 当别人打电话给你时&#xff0c;你的电话响铃了&#xff0c;而他听到的声音叫做回铃音。回铃音是被叫方向主叫方传送&#xff0c;也是彩铃功能的基础。我们平时打电话听到的“嘟 嘟 嘟 嘟”的声音&#xff0c;就…
阅读更多...
mysql 查询实战-变量方式-解答

mysql 查询实战-变量方式-解答

对mysql 查询实战-变量方式-题目&#xff0c;进行一个解答。&#xff08;先看题&#xff0c;先做&#xff0c;再看解答&#xff09; 1、查询表中⾄少连续三次的数字 1&#xff0c;处理思路 要计算连续出现的数字&#xff0c;加个前置变量&#xff0c;记录上一个的值&#xff0c…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023