Linux 第二十九章

🐶博主主页:@ᰔᩚ. 一怀明月ꦿ 

❤️‍🔥专栏系列:线性代数,C初学者入门训练,题解C,C的使用文章,「初学」C++,linux

🔥座右铭:“不要等到什么都没有了,才下定决心去做”

🚀🚀🚀大家觉不错的话,就恳求大家点点关注,点点小爱心,指点指点🚀🚀🚀

目录

共享内存

共享内存的特点:

rm和unlink的区别

源码

comm.h

server.cc

client.cc

Makefile

共享内存的字段

消息队列 (了解)

创建消息队列

发送数据

接收数据

删除消息队列

消息队列的字段

信号量 

创建信号量集:

信号量的控制


 

共享内存

shmat返回的是共享内存的起始地址

共享内存的特点:

1.共享内存的通信方式,并没有同步机制

2.共享内存是所有进程间通信,速度最快的

例如:

管道文件通信:需要把数据写到字符串中然后写入文件,读的时候,是从文件读到字符串中

共享内存通信:直接把数据写到共享内存中,读的时候,直接从共享内存中读

3.共享内存可以提供较大的空间

rm和unlink的区别

在Linux中,rm和unlink都是用于删除文件的命令和函数,它们有以下区别:

 

1. 命令与函数:rm是一个命令,用于在终端上执行删除文件的操作;unlink是一个系统调用函数,用于在程序中删除文件。

2. 功能:rm命令可以删除指定的文件或目录,包括其中的所有内容。它还支持删除多个文件和使用递归选项来删除目录及其内容。unlink函数仅用于删除一个文件的目录项,即删除文件的硬链接。

3. 使用方式:rm命令的基本语法如下:

 

rm [选项] 文件...

 

unlink函数的基本语法如下:

int unlink(const char *pathname);

4. 错误处理:rm命令会在删除文件时给出警告或错误信息,例如询问是否删除只读文件、权限不足等。unlink函数在删除文件失败时返回-1,并将错误码存储在errno变量中,可以使用perror或其他错误处理机制来处理错误。

 

总的来说,rm命令更方便用于终端上删除文件和目录,而unlink函数更适用于在程序中删除文件的目录项。

源码

comm.h

#pragma once
#include <iostream>
#include <string>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/stat.h>
#include<cstring>
#include<sys/shm.h>#define FILENAME ".fifo" // 隐藏文件using namespace std;const string pathname = "/home/BCH/1_27/shm"; // 路径给的是当前工作路径const int proj_id = 0x11223344; // 随便设的一个数字// 共享内存的大小,建议设置成为n*4096,因为底层分配shm大小的时候,是以4096的为基数倍增的
const int size = 4096;// 创建key值key_t getkey(){key_t key = ftok(pathname.c_str(), proj_id);if (key < 0){cerr << "error: " << errno << "errstring :" << strerror(errno) << endl;exit(1);}return key;
}string tohex(int id){char buffer[1024];snprintf(buffer, sizeof(buffer), "0x%x", id);return buffer;
}int createshmHelper(key_t key, int flag){int shmid = shmget(key, size, flag);if (shmid < 0){cerr << "error: " << errno << "errstring :" << strerror(errno) << endl;return -1;}return shmid;
}// 是给用户端使用的
int createshm(key_t key){return createshmHelper(key, IPC_CREAT | IPC_EXCL | 0666);
}// 是给客户端使用的
int getshm(key_t key){return createshmHelper(key, IPC_CREAT);
}bool Mkfifo(){int n = mkfifo(FILENAME, 0666);if (n < 0){cerr << "error: " << errno << "errstring :" << strerror(errno) << endl;return false;}return true;
}

server.cc

#include <iostream>
#include <sys/ipc.h>
#include <sys/shm.h>
#include <sys/types.h>
#include <cstring>
#include <unistd.h>
#include <sys/stat.h>
#include <fcntl.h>
#include "comm.hpp"using namespace std;class Init{
public:Init(){// 创建命名管道bool r = Mkfifo();if (!r)return; // 创建不成功就返回key_t key = getkey();cout << "key :" << tohex(key) << endl;// key:不要在应用层使用,只用来在内核标志shm的唯一性(类似fd)// shmid:应用这个共享内存的时候,我们使用shmid来进行操作共享内存(类似FILE*)// 创建在内存shmcout << "创建shm成功" << endl;shmid = createshm(key);cout << "shmid :" << shmid << endl;// 挂接虚拟地址cout << "开始将shm映射到进程虚拟地址空间中" << endl;s = (char *)shmat(shmid, nullptr, 0); // 设置为nullptr,是让os从共享区找一块连续空间rfd = open(FILENAME, O_RDONLY);}~Init(){// 取消挂接虚拟地址cout << "开始将shm从进程的地址空间移除" << endl;shmdt(s);// 控制shm// 1.删除shmcout << "开始将shm从os中删除" << endl;shmctl(shmid, IPC_RMID, nullptr);close(rfd);// unlink删除管道文件unlink(FILENAME);}int shmid;int rfd;char *s;
};int main(){Init init;while (true){// wait// 因为共享内存做不到同步机制,但是我们可以借助命名管道实现机制,来实现共享内存的同步机制// 我们可以创建一个管道,让服务端先读管道里的东西,然后再读共享内存里的东西,如果客户端// 没有在管道里写东西,则服务端就一直等客户端在管道里写东西,不然不会读取共享内存里的东西int code = 0;ssize_t n = read(init.rfd, &code, sizeof(code));if (n > 0){// 直接读取内容cout << "s: " << init.s << endl;sleep(1);}else if (n == 0){break;}}return 0;
}

client.cc

#include <iostream>
#include <sys/ipc.h>
#include <sys/shm.h>
#include <sys/types.h>
#include <cstring>
#include <unistd.h>
#include <sys/stat.h>#include <fcntl.h>
#include "comm.hpp"using namespace std;int main(){// 创建key值key_t key = getkey();int shmid = getshm(key);// 挂接shmchar *s = (char *)shmat(shmid, nullptr, 0);int wfd = open(FILENAME, O_WRONLY);char c = 'a';for (; c <= 'z'; c++){s[c - 'a'] = c;cout << "write: " << c << "done" << endl;sleep(1);int code = 1;write(wfd, &code, sizeof(code));}// 取消挂接shmdt(s);close(wfd);return 0;
}

Makefile

.PHONY:all
all:client serverclient:client.cc
g++ -o $@ $^ -std=c++11server:server.cc
g++ -o $@ $^ -std=c++11.PHONY:clean
clean:
rm -f client server

在 Linux 中,unlink 是一个系统调用,它允许用户空间程序删除文件的目录项(directory entry),从而减少文件的链接计数。这个系统调用的原型通常可以在 unistd.h 头文件中找到。同时,C 语言标准库也提供了一个与系统调用对应的函数 unlink,它是通过对系统调用的封装来实现的。通过调用这个库函数,程序可以方便地使用 unlink 系统调用来删除文件。因此,unlink 在 Linux 中既是一个系统调用,也是一个 C 标准库函数。

共享内存的字段

内核源码:The buf argument is a pointer to a shmid_ds structure, defined in <sys/shm.h> as follows:struct shmid_ds {struct ipc_perm shm_perm;    /* Ownership and permissions */size_t          shm_segsz;   /* Size of segment (bytes) */time_t          shm_atime;   /* Last attach time */time_t          shm_dtime;   /* Last detach time */time_t          shm_ctime;   /* Last change time */pid_t           shm_cpid;    /* PID of creator */pid_t           shm_lpid;    /* PID of last shmat(2)/shmdt(2) */shmatt_t        shm_nattch;  /* No. of current attaches */...};The ipc_perm structure is defined as follows (the highlighted fields are settable using IPC_SET):struct ipc_perm {key_t          __key;    /* Key supplied to shmget(2) */uid_t          uid;      /* Effective UID of owner */gid_t          gid;      /* Effective GID of owner */uid_t          cuid;     /* Effective UID of creator */gid_t          cgid;     /* Effective GID of creator */unsigned short mode;     /* Permissions + SHM_DEST andSHM_LOCKED flags */unsigned short __seq;    /* Sequence number */};注释:
struct ipc_perm shm_perm;   // 共享内存段的权限信息
size_t shm_segsz;           // 共享内存段的大小(字节数)
time_t shm_atime;           // 上次访问共享内存段的时间
time_t shm_dtime;           // 上次与共享内存段断开连接的时间
time_t shm_ctime;           // 上次更改共享内存段属性的时间
pid_t shm_cpid;             // 创建共享内存段的进程ID
pid_t shm_lpid;             // 最后操作共享内存段的进程ID
unsigned short shm_nattch;  // 当前连接到共享内存段的进程数
unsigned short shm_unused;  // 保留字段,未使用struct ipc_perm {key_t __key;    // 对象的键值uid_t uid;      // 拥有者的用户IDgid_t gid;      // 拥有者的组IDuid_t cuid;     // 创建者的用户IDgid_t cgid;     // 创建者的组IDunsigned short mode;    // 访问权限和标志unsigned short __seq;    // 序列号
};

共享内存=共享内存空间+属性

消息队列 (了解)

6e9a8cbe39b94fbbba0d1cad6624f23a.png

一个进程给另一个进程发送数据块

创建消息队列,也需要key(标识符),和创建共享内存的key一样

 

注意:管道是一种单向通信的方式,创建两个管道,从而实现双向通信的效果。而共享内存和消息队列等可以实现双向通信

 

虽然两个进程都可以把数据放在同一个消息队列里面,但肯定每一个进程放的数据是有自己的标识的,所以一定能够分清楚队列里面的数据是谁的

创建消息队列

int msgget(key_t key, int msgflg);//msgfla标志位,和shmget类似

发送数据

int msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg);
各个参数的含义如下:* msqid:消息队列的标识符,是由 msgget 调用返回的消息队列标识符。
* msgp:指向消息数据的指针,通常是一个自定义的结构体指针,用于存储要发送的消息内容。
* msgsz:消息的大小,以字节为单位。
* msgflg:用于指定发送消息的选项,常用的选项包括 0 或 IPC_NOWAIT,表示发送操作的阻塞或非阻塞方式。

接收数据

ssize_t msgrcv(int msqid, void *msgp, size_t msgsz, long msgtyp, int msgflg);//就是消息的
各个参数的含义如下:
* msqid:消息队列的标识符,是由 msgget 调用返回的消息队列标识符。
* msgp:指向接收消息数据的缓冲区指针,通常是一个自定义的结构体指针,用于存储接收到的消息内容。
* msgsz:缓冲区的大小,以字节为单位,用于指定可以接收的消息的最大大小。
* msgtyp:用于选择接收哪种类型的消息,如果为 0,则表示接收队列中的第一条消息;如果大于 0,则表示接收类型字段与 msgtyp相匹配的第一条消息;如果小于 0,则表示接收类型字段小于或等于 msgtyp 绝对值的第一条消息。
* msgflg:用于指定接收消息的选项,常用的选项包括 0 或 IPC_NOWAIT,表示接收操作的阻塞或非阻塞方式。

删除消息队列

int msgctl(int msqid, int cmd, struct msqid_ds *buf);//和shmctl

消息队列,系统中可不可以同时存在多个消息队列?可以

消息队列也要在内核中,把它管理起来,如何管理呢?现描述,再组织

消息队列=队列+队列属性

消息队列的字段

The msqid_ds data structure is defined in <sys/msg.h> as follows:struct msqid_ds {struct ipc_perm msg_perm;     /* Ownership and permissions */time_t          msg_stime;    /* Time of last msgsnd(2) */time_t          msg_rtime;    /* Time of last msgrcv(2) */time_t          msg_ctime;    /* Time of last change */unsigned long   __msg_cbytes; /* Current number of bytes inqueue (nonstandard) */msgqnum_t       msg_qnum;     /* Current number of messagesin queue */msglen_t        msg_qbytes;   /* Maximum number of bytesallowed in queue */pid_t           msg_lspid;    /* PID of last msgsnd(2) */pid_t           msg_lrpid;    /* PID of last msgrcv(2) */};The ipc_perm structure is defined as follows (the highlighted fields are settable using IPC_SET):struct ipc_perm {key_t          __key;       /* Key supplied to msgget(2) */uid_t          uid;         /* Effective UID of owner */gid_t          gid;         /* Effective GID of owner */uid_t          cuid;        /* Effective UID of creator */gid_t          cgid;        /* Effective GID of creator */unsigned short mode;        /* Permissions */unsigned short __seq;       /* Sequence number */};

 

信号量 

信号量本质:就是一个计数器,保护共享资源(信号量是一种用于进程间同步和互斥的系统资)

信号量一次可以创建多个,类似于数组的形式

semaphore:信号量

创建信号量集:

在 Linux 中,semget 函数用于创建一个新的信号量集或获取一个已存在的信号量集的标识符。下面是 semget 函数的函数原型:

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/sem.h>int semget(key_t key, int nsems, int semflg);
各个参数的含义如下:
* key:用于标识信号量集的键值。可以使用 ftok 函数生成一个唯一的键值。
* nsems:指定需要创建或获取的信号量集中的信号量数量。
* semflg:用于指定信号量的权限和选项,常用的选项包括 IPC_CREAT(如果不存在则创建)和 IPC_EXCL(与 IPC_CREAT 一起使用,确保只创建新的信号量集)等。
调用 semget 函数后,它会返回一个信号量集的标识符,用于后续对该信号量集进行操作,比如通过 semop 执行 P/V 操作。

需要注意的是,如果是创建新的信号量集,需要指定 IPC_CREAT 标志和合适的权限位,例如 0666。如果是获取已存在的信号量集,只需要提供相应的键值即可。

信号量的控制

在 Linux 中,semctl 函数用于对信号量集进行控制操作,比如获取或设置信号量的值、删除信号量集等。

下面是 semctl 函数的函数原型:
 

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/sem.h>
int semctl(int semid, int semnum, int cmd, …);//因为创建信号量是创建的信号量集,semnum的值(首个信号量是0)就是信号量集其中一个信号量
各个参数的含义如下:
* semid:要操作的信号量集的标识符。
* semnum:指定要操作的具体信号量的索引。对于整个信号量集的操作,可以指定为 0。
* cmd:指定要执行的操作命令,可以是以下之一:* GETVAL:获取指定信号量的值。* SETVAL:设置指定信号量的值。* IPC_RMID:删除信号量集。
在使用 semctl 函数时,具体的操作和参数会根据 cmd 的不同而有所变化。

例如,当 cmd 为 GETVAL 时,需要提供一个 union semun 类型的第四个参数,用于接收信号量的值。当 cmd 为 SETVAL 时,需要提供一个 union semun 类型的第四个参数,用于设置信号量的值。

 

内核是如何看待IPC资源的!

1.他是单独设计的模块

2.理清楚ipc资源再内核中维护的方式

在内核底层,都是通过共享内存、消息队列、信号量继承ipc资源

 🌸🌸🌸如果大家还有不懂或者建议都可以发在评论区,我们共同探讨,共同学习,共同进步。谢谢大家! 🌸🌸🌸  

 

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

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

相关文章

el-tree

Vue.js 组件结构&#xff1a; 是一个 Vue.js 组件&#xff0c;它由一些 Vue 文件组成&#xff0c;包括模板&#xff08;template&#xff09;、脚本&#xff08;script&#xff09;和样式&#xff08;style&#xff09;。 模板部分定义了组件的结构和布局&#xff0c;包括树节点…

分布式光伏管理系统的意义与核心技术

分布式光伏管理系统遵循安全可靠、经济合理原则&#xff0c;满足电力系统自动化总体规划要求&#xff0c;且充分考虑光伏发电的因素&#xff0c;对分布式光伏发电、用电进行集中监控、统一调度、统一运维。为用户提供运维服务&#xff0c;实现能源互联&#xff0c;信息互通&…

软件安全测试可以检测软件哪些安全问题?

软件安全测试是一种旨在发现和评估软件应用程序中的安全漏洞和隐患的测试方法。通过安全测试&#xff0c;可以发现并修复潜在的安全问题&#xff0c;从而提高软件应用程序的可靠性和安全性。下面将介绍软件安全测试可以检测到的几种主要安全问题。 身份验证漏洞&#xff1a;身份…

如何将 DFMini player MP3 模块与 Arduino 结合使用

要创建此项目&#xff0c;您将使用&#xff1a; DFPlayer迷你MP3模块 10kΩ电阻 开关按钮 面包板 Arduino UNO 杜邦线 现在&#xff0c;我们将学习如何构建该项目。 什么是DF Mini Player MP3模块 DFMini Player 模块是一个小型音乐播放器。它成本低、功耗低&#xff0c;可…

五月采购节 | 全场板卡八七折起

淘宝搜索【北京迅为电子官方企业】 5月13日~5月15日 海量优惠券等你拿&#xff01; 复制下方链接到淘宝 直接进入店铺&#xff01; https://shop459378556.taobao.com

空号检测-号码批量检测API接口-关机停机风险号检测

手机空号检测分为普通空号检测和实时检测两种类型&#xff1a; 普通空号检测返回结果&#xff1a;实号、风险号、空号、沉默号 。 1.普通版的检测不会实时更新数据&#xff0c;因此其数据库中的信息可能不是最新的。 2.覆盖基础运营商的数据库&#xff0c;检测范围相对有限&…

每个工作室都需要的10种插件类型

插件通常是将平淡的表现转变为引人注目的声音艺术品的最灵活和经济高效的方式。对于大多数没有足够空间或资金积累昂贵外置设备的人来说&#xff0c;在电脑中工作是我们的录音能够达到广播标准的理想途径。在德声&#xff0c;我们认为每个工作室都可以从插件中受益&#xff0c;…

Spring Boot整合ElasticSearch实战 - 第511篇

历史文章&#xff08;文章累计500&#xff09; 《国内最全的Spring Boot系列之一》 《国内最全的Spring Boot系列之二》 《国内最全的Spring Boot系列之三》 《国内最全的Spring Boot系列之四》 《国内最全的Spring Boot系列之五》 《国内最全的Spring Boot系列之六》 《…

呼叫中心系统选pscc好还是okcc好

选择PSCC&#xff08;商业软件呼叫中心&#xff09;还是OKCC&#xff08;开源呼叫中心&#xff09;&#xff0c;应基于以下几个关键因素来决定&#xff1a; 技术能力&#xff1a;如果企业拥有或愿意投入资源培养内部技术团队&#xff0c;开源解决方案可能更合适&#xff0c;因为…

Spring+Mybatis-plus 实现 Gauss DB数据库代码生成

需求&#xff1a; 使用的gauss db数据库&#xff08;类似oracle语法&#xff09;&#xff0c;需要根据指定表生成entity、dao等代码 1&#xff0c;引入依赖 <?xml version"1.0" encoding"UTF-8"?> <project xmlns"http://maven.apache.or…

http代理ip按流量划算还是个数划算?

随着科技的进步和互联网的发展&#xff0c;越来越多的企业在业务上都需要用到代理&#xff0c;那么http代理ip按流量划算还是个数划算&#xff1f;小编接下来就跟大家介绍一下&#xff1a; 首先我们得先了解http代理ip的按流量模式和个数模式分别是什么&#xff1a; 一、按流…

软件设计中的数字:7

“ 使软件更易理解的秘密&#xff1a;米勒法则” 小游戏 学习之前先一起玩一个小游戏。 3秒钟时间&#xff0c;看看下面的图片中有多少个小块&#xff1f; 3秒到了&#xff0c;数出来了吗&#xff1f;22个。 没数出来也没关系&#xff0c;我也没数出来o(╥﹏╥)o 现在&…

WEB前端复习——JS

JS是运行在客户端的脚本&#xff08;script&#xff09;语言 引入JS进html ①sript标签内编写 <script type"text/javascript">document.write("<h1>hi</h1>")window.alert("who") </script> ②外部JS script src【…

生产环境节点扩容方案

datanode节点扩缩容(1人天) 注意:新增节点需要走商务,节点扩容需要申请新的license 制品包下载 #内网下载(环境检查脚本) wget --user=admin --password=Y!bC2hx0TN@21cal http://10.69.71.180:8082/artifactory/product/qiudongyang/precheck/os-check20221127.tar…

牛客热题:比较版本号

&#x1f4df;作者主页&#xff1a;慢热的陕西人 &#x1f334;专栏链接&#xff1a;力扣刷题日记 &#x1f4e3;欢迎各位大佬&#x1f44d;点赞&#x1f525;关注&#x1f693;收藏&#xff0c;&#x1f349;留言 文章目录 牛客热题&#xff1a;比较版本号题目链接方法一:暴力…

Elasticsearch做到像mysql这样的表连接Parent-Child实现

比如在mysql中我有两张表&#xff0c;movies和ratings&#xff0c;这两张表依赖movie_id实现关联。 那么我需要在elasticsearch中实现一下两个任务 电影标题为When Will I Be Loved的电影评分的均值是多少电影评分大于5的电影标题是什么 可以看出来这两个问题都需要将movies和…

服务调用中的异常处理方案

背景 在微服务架构中,A服务调用B服务,当B服务中抛出异常时,我们的意愿是能够获取到所有的异常信息,并且可以触发服务的熔断降级。 但由于全局异常处理机制的存在,会帮我们处理B服务中抛出的异常,并把HTTP的状态码设置为200,那么此时对A服务来说,对B服务抛出的异常是无…

在线抠图网站

https://pixian.ai/ 这个网站提供一键去除图像背景的智能抠图服务。 水印去除剂 - 删除照片中的任何水印 该网站是一个智能抠图工具&#xff0c;可以帮助用户去除照片中的水印。 HAMA | AI Object remover, Image Eraser 这是一个智能抠图AI工具的网站&#xff0c;可以帮助…

电商平台接口自动化框架实践||电商API数据采集接口

电商数据采集接口 语言&#xff1a;python 接口自动化实现流程 红色为可实现/尚未完成 绿色为需要人工干预部分 自动生成测试用例模板&#xff08;俩种方式二选一&#xff09;&#xff1a; mimproxy&#xff0c;通过浏览器代理抓包方式&#xff0c;访问 H5 或者 web 页面&a…

processing完整教程

概述&#xff1a;processing在我眼里就是libgdx的高度封装&#xff0c;如果各位会libgdx&#xff0c;学processing应该可以说是无师自通&#xff0c;当然processing是java语言那边的。 processing是什么&#xff1f; 官网是这样解释的&#xff1a;Processing 是一本灵活的软件…