进程通信知识基础【Linux】——下篇

目录

前文

一，命名管道

创建命名管道

1. getline——c++库

2. unlink——系统接口

实践代码

common.hpp

client.cpp

server.cpp

Log.cpp

二，共享内存（system V接口）

1. 创建共享内存

shmget接口

2. 删除共享内存

常见ipc指令

shmctl接口

3. 映射到虚拟内存（挂起）

shmat接口

去关联

shmdt接口

小结：

三，信号量概念

概念引入 

小结

嘿！收到一张超美的风景图，希望你每天都能开心顺心！

 

前文

经过进程池的实践（哈希思想应用【C++】(位图，布隆过滤器，海量数据处理面试题)-CSDN博客），我们对管道有了一定的理解，本篇继续给大家分享其余一些进程通信的知识。

一，命名管道

管道应用的一个限制就是只能在具有共同祖先（具有亲缘关系）的进程间通信。如果我们想在 不相关的进程之间交换数据，可以使用 FIFO文件来做这项工作，它经常被称为 命名管道。
命名管道是一种 特殊类型的 文件。

创建命名管道

在指令端创建

$  mkfifo   filename

在程序中创建

#include <sys/types.h>
#include <sys/stat.h>int mkfifo(const char *pathname, mode_t mode);

其中，pathname为管道文件路径，mode为权限掩码，mkfifo函数返回值为0表示成功，-1表示失败，错误原因存储在errno中。

下面我们来一个例子：

创建好一个命名管道后，执行下面指令，我们会遇到光标不动的现象。

echo "hello" > FilePipe

原因是：我们只是向命名管道进行写入，没有打开命名管道的读端(从命名管道中读取数据), 进入了一种阻塞状态。（这也是管道的一种控制）

解决方法也很简单，就是在另一个窗口，对命名管道进行读数据，这时就会中断写入的阻塞状态。

cat  <  FilePipe 

实践包含一些其他接口：

1. getline——c++库

istream& getline (istream& is, string& str, char delim);

其中，is是输入流，str是存储读取结果的字符串，delim是指定的分隔符（可选，默认为'\n'，cin, scanf等是以空格和换行符为分隔符）。函数的返回值是输入流is的引用

getline函数的作用是从输入流is中读取一行文本，并将其存储到字符串str中。如果读取成功，则返回输入流is的引用。如果读取失败，则返回输入流的状态为false。

2. unlink——系统接口

int unlink(const char *pathname);

参数pathname为要删除的文件的路径名。当调用unlink接口时，系统会删除指定路径的文件。如果文件不存在或者无法访问，则会返回-1，并设置errno变量来指示错误类型。

下面头文件中： 

_COMM_H（名字自定义） 宏则是用来防止头文件的重复包含，通过定义这个宏可以在编译过程中检测到头文件是否被多次包含，避免出现重复定义的错误。

实践代码

common.hpp

#ifndef _COMM_H_
#define _COMM_H_
#include <iostream>
#include <vector>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <unistd.h>
#include <cstring>
#include <cstdlib>
#include <cstdio>
#include "Log.hpp"using namespace  std;#define MOODE 0666
#define SIZE 128
#define CHNUMS 3string Pipename = "FilePipe";
string PipeAddress = "./FilePipe";#endif

client.cpp

#include "common.hpp"int main()
{// 1. 客户向服务端,传输请求int fd = open(PipeAddress.c_str(), O_WRONLY);if (fd < 0 ){cout << "open fail" << endl;}string buff;while (1){cout << " Please set your information :> ";getline(cin, buff);  //getline接口的优势在于它可以读取一行文本，并且自动将换行符（\n）作为行结束符write(fd, buff.c_str(), buff.size());}// 关闭命名管道close (fd);// 用户信息读取完后，需要我们删除这个命名管道文件。unlink(Pipename.c_str());//unlink接口是用于删除一个指定的文件或符号链接的系统调用。 return 0;
}

server.cpp

#include "common.hpp"
#include <sys/wait.h>static void Getmessage(int fd) // 设置成静态函数的目的是，让其他文件，无法使用该函数
{char buff[SIZE];Log("处理数据开始", Test) << "[" << getpid() << "] "<< " step 3 " << endl;while (1){memset(buff, '\0', sizeof(buff));ssize_t byte = read(fd, buff, sizeof(buff) - 1);if (byte > 0){cout << "[" << getpid() << "] " << buff << endl;}else if ( byte == 0){cout << " write close " << endl;break;}else{perror(" read fail");cout << "[" << getpid() << "] " << " read error "  << endl;break;}}
}int main()
{// 1. 创建命名管道if (mkfifo(PipeAddress.c_str(), MOODE) < 0 ){perror( " mkfifo fail ");}Log("创建命名管道成功", debug) << "step 1" << endl;// 2. 文件操作int fd = open(PipeAddress.c_str(), O_RDONLY);if (!fd){perror(" open fail");exit(-1);}Log("文件操作成功", debug) << "step 2" << endl;pid_t id;vector<int> FdList;for (int i = 0; i < CHNUMS; i++){id = fork();if (id == 0){Getmessage(fd);exit(1);  // 子进程完美退出，等待父进程接收}}// 父进程接受子进程退出int status = 0;for (int i = 0; i < CHNUMS; i++){// waitpid(FdList[i], nullptr, 0);  这样子写会些坑，不知道哪一个子进程先状态改变waitpid(-1, &status, 0); // -1则是随机等待一个子进程状态改变} // 4. 关闭文件close(fd);unlink(PipeAddress.c_str());Log("关闭文件", warning) << "step 4" << endl;return 0;
}

Log.cpp

#ifndef _LOG_
#define _LOG_
#include <iostream>
#include <ctime>
#include <string>
using namespace std;#define debug 0
#define warning 1
#define Test 2string list_level[3] = {"debug","warning","Test"  
};ostream&  Log(const char* str, int level)
{cout <<  str << " | " << (unsigned)time(0) << " | " << list_level[level] << " ";return cout;
}#endif

下面是上面代码功能的形象图：

二，共享内存（system V接口）

共享内存是一种操作系统进程通信的方式，它允许多个进程共享同一块物理内存区域，从而实现高效的数据交换和共享。

共享内存的原理是将一块物理内存映射到多个进程的虚拟地址空间中，这样多个进程就可以直接读写这块内存，而不需要通过复制数据或者消息传递等方式进行通信。

共享内存通常使用信号量来实现进程间的同步和互斥访问。

多个进程共享一块物理内存，操作系统一定得这个操作进行有序管理，而一旦涉及管理，必然要进行 先描述，再组织。

所有共享内存 =  共享内存块 +  对应共享内存块的内核数据结构。

1. 创建共享内存

shmget接口

返回值：一个操作系统运行时，肯定不只一个共享内存，众多的共享内存也被一个内核数据结构管理起来，而返回值就类似文件描述中的fd。

1.   int shmflg:  IPC_CREAT（单独用以0替代） and IPC_EXCL 两个宏，前者单独用，共享内存不存在则创建；存在，则返回之。    后者，单独用没有意义，两者通过按位与一起用，底层不存在则创建；存在则出错返回（意义：保证每次共享内存都是最新的）。

2.   key_t key: 我们知道一个操作系统中有众多的共享内存，而key通过特殊的算法规则处理，形成唯一的通行码，找到精确共享内存。

那如何获取 key，通过ftok接口（就是一个对数据进行算法规则处理）。

 

  • pathname:  一个我们可以访问的路径（操作系统会访问其inode值（一个存储标识值））； 
  • proj_id :    就是一个int值。如果想获取一个相同的key值，proj_id也得相同。

返回值：-1失败；大于0则是key值。

3.   size_t size :   共享空间的字节大小。最后是页(4096)的整数倍。原因：假设要4097，则操作系统会创建8192字节，但中间空间我们又无法访问这就是浪费资源了。

2. 删除共享内存

输入指令： 查看共享内存资源

手动删除：

ipcs -m      

然后输入：ipcrm  -m  shmid值

 这里我们要注意的是：共享内存的生命周期随内核！！，除非重启！

perms: 权限值，为0时，谁也无法访问该共享内存，需要在shmget时需要输入权限，比如： shmget(123,  4096 , IPC_CREAT | IPC_EXCL | 0666)，权限同文件一样

常见ipc指令

1. ipcs - 显示系统中的IPC资源信息
2. ipcrm - 删除IPC资源
3. ipcs -q - 显示消息队列信息
4. ipcs -s - 显示信号量信息
5. ipcs -m - 显示共享内存信息 

代码删除：

shmctl接口

cmd:  可以理解为功能选项，我们可以选择删除，获取共享空间属性信息等等。IPC_STAT, IPC_RMID等等

shmid：理解为共享内存的标识符吧。

*buf  :  这是管理共享内存的数据结构指针，可用通过buf获取或者修改其属性。

返回值： -1表示失败。

3. 映射到虚拟内存（挂起）

shmat接口

shmid:  共享内存唯一的id 

shmaddr:  去设置一个虚拟地址。（由于我们不清楚虚拟地址的使用情况，这里建议null/nullptr，让计算机来产生）

shmflg: 挂接方式，以只读（SHM_R默认0），只写(SHM_W)，还是读写(SHM_R | SHM_W )方式挂接。

返回值： 就是计算机返回共享内存虚拟地址的开头； 返回0则失败。

当一旦挂起成功，进程关联数就会增加

去关联

shmdt接口

shmaddr:   共享内存虚拟地址起始地址。 

返回值：-1失败； 0成功，成功删除后同时，进程关联数减一。

成功创建共享内存后位置分布的逻辑图

代码示例：

#include <stdio.h>
#include <sys/ipc.h>
#include <sys/shm.h>int main() {key_t key = ftok("shmfile",65);  // 创建一个keyint shmid = shmget(key,1024,IPC_CREAT|0666);  // 创建共享内存区char *str = (char*) shmat(shmid,(void*)0,0);  // 将共享内存区连接到当前进程的地址空间printf("Write data : ");gets(str);printf("Data written in memory: %s\n",str);shmdt(str);  // 分离共享内存区shmctl(shmid,IPC_RMID,NULL);  // 删除共享内存区return 0;
}

这里介绍一个比较重要的格式打印数据的接口： snprintf()接口 

小结：

1. 共享内存是进程通信(IPC)中，速度最快的。因为这个方法不需要过多的拷贝数据，而且不用经过操作系统，在用户层直接读取修改。

2. 由于共享内存没有访问控制（读写端独立），容易引发并发问题（两端数据不一致问题）。

三，信号量概念

概念引入 

小结

我们需要理解这个概念

没理解？没事，这个我们在多线程里，用代码的形式进行解释。

下期预告：信号！！

结语

   本小节就到这里了，感谢小伙伴的浏览，如果有什么建议，欢迎在评论区评论，如果给小伙伴带来一些收获请留下你的小赞，你的点赞和关注将会成为博主创作的动力。

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

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

相关文章

C++经典面试题(万字总结版)

C++经典面试题(万字总结版)

一&#xff0e;编译链接运行 1. 虚拟地址空间的内存布局 Linux内存管理 | 二、虚拟地址空间布局 - 知乎 (zhihu.com) 3G的用户空间和1G的内核空间。 用户态有&#xff1a;代码段、数据段、堆、栈、bss段、文件映射和匿名映射区 内核态有&#xff1a;安全保护区、固定映射区、…
阅读更多...
SolidWorks二次开发 C#-读取基于Excel的BOM表信息

SolidWorks二次开发 C#-读取基于Excel的BOM表信息

SolidWorks二次开发 C#-读取基于Excel的BOM表信息 问题点来源解决方案及思路相关引用链接 问题点来源 这是一位粉丝问的一个问题&#xff0c;他说到: 老师&#xff0c;请问Solidworks二次开发工程图中"基于Excel的材料明细表"怎么读取里面的数据&#xff1f; Ps:这…
阅读更多...
基于ssm新锐台球厅管理系统的设计与实现论文

基于ssm新锐台球厅管理系统的设计与实现论文

新锐台球厅管理系统 摘要 随着信息技术在管理上越来越深入而广泛的应用&#xff0c;作为一般的台球厅都会跟上时代的变化&#xff0c;用上计算机来代表重复性的劳动&#xff0c;并且给用户一种新奇的感受&#xff0c;实现新锐台球厅管理系统 在技术上已成熟。本文介绍了新锐台…
阅读更多...
C++：函数重载

C++：函数重载

1.函数重载概念 函数重载就是用同一个函数名定义的不同函数&#xff0c;当函数名和不同的参数搭配时函数的功能和含义不同。 2.实现函数重载的条件 同一个作用域&#xff0c;参数个数不同或者参数类型不同或者参数顺序不同(满足一个即可) void func(){} void func(int x){} v…
阅读更多...
EXCEL SUM类函数

EXCEL SUM类函数

参考资料 万能函数SUMPRODUCT超实用的10种经典用法 目录 一. SUM二. SUMIF2.1 统计贾1的销售额2.2 > 900 的销售总额2.3 计算贾1和贾22的销售总额2.4 多区域计算 三. SUMIFS3.1 统计苹果&#xff0c;在第一季度的总数量3.2 统计苹果&#xff0c;在第一季度&#xff0c;>…
阅读更多...
2024最新FL Studio21.2MAC电脑版中文版下载安装步骤教程

2024最新FL Studio21.2MAC电脑版中文版下载安装步骤教程

FL Studio 简称FL&#xff0c;全称Fruity Loops Studio&#xff0c;因此国人习惯叫它"水果"。目前最新版本是FL Studio21.1.1.3750版本&#xff0c;它让你的计算机就像是全功能的录音室&#xff0c;大混音盘&#xff0c;非常先进的制作工具&#xff0c;让你的音乐突破…
阅读更多...
SpringIOC之@Primary

SpringIOC之@Primary

博主介绍&#xff1a;✌全网粉丝5W&#xff0c;全栈开发工程师&#xff0c;从事多年软件开发&#xff0c;在大厂呆过。持有软件中级、六级等证书。可提供微服务项目搭建与毕业项目实战&#xff0c;博主也曾写过优秀论文&#xff0c;查重率极低&#xff0c;在这方面有丰富的经验…
阅读更多...
【动态读取配置文件】ParameterTool读取带环境的配置信息

【动态读取配置文件】ParameterTool读取带环境的配置信息

不同环境Flink配置信息是不同的&#xff0c;为了区分不同环境的配置文件&#xff0c;使用ParameterTool工具读取带有环境的配置文件信息 区分环境的配置文件 三个配置文件&#xff1a; flink.properties&#xff1a;决定那个配置文件生效 flink-dev.properties&#xff1a;测…
阅读更多...
mysql 中查询字段内容长度以及是否是纯数字的函数

mysql 中查询字段内容长度以及是否是纯数字的函数

1、字段内容长度查询 select * from abpusers where LENGTH(UserName)<4 结果&#xff1a; 2、 查询纯数字&#xff0c;使用正则表达式 select * from abpusers where UserName REGEXP ^[0-9]$ 结果如下&#xff1a;
阅读更多...
【C语言加油站】qsort函数的模拟实现

【C语言加油站】qsort函数的模拟实现

qsort函数的模拟实现 导言一、回调函数二、冒泡排序2.1 冒泡排序实现升序 三、qsort函数3.1 qsort函数的使用3.2 比较函数 四、通过冒泡排序模拟实现qsort函数4.1 任务需求4.2 函数参数4.3 函数定义与声明4.4 函数实现4.4.1 函数主体4.4.2 比较函数4.4.3 元素交换 4.5 my_qsort…
阅读更多...
navicat连接mysql报错过程以及解决

navicat连接mysql报错过程以及解决

1.刚开始报错如下图 于是我利用这段报错信息&#xff08;2059 - Authentication plugin caching sha2 password cannot be loaded&#xff09;百度。 1.1上面报错的原因和解决过程 百度说是mysql的加密方式不对&#xff0c;如下图 所以这里进入数据库&#xff0c;修改mysql这…
阅读更多...
缓存击穿的原因和解决方案

缓存击穿的原因和解决方案

缓存击穿 原因&#xff1a;一个被高并发访问并且缓存重建业务较复杂的key突然失效了&#xff0c;无数的请求访问会在瞬间给数据库带来巨大的冲击 解决方案 1.互斥锁 优点 没有额外的内存消耗保证一致性实现简单 缺点 线程需要等待&#xff0c;性能受影响可能有死锁风险 …
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023