Linux 第二十九章

news2024/11/19 3:23:44

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

❤️‍🔥专栏系列:线性代数,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*)
        // 创建在内存shm
        cout << "创建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.删除shm
        cout << "开始将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);

    // 挂接shm
    char *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 server


client:client.cc
g++ -o $@ $^ -std=c++11


server: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 and
                                           SHM_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;      // 拥有者的用户ID
    gid_t gid;      // 拥有者的组ID
    uid_t cuid;     // 创建者的用户ID
    gid_t cgid;     // 创建者的组ID
    unsigned 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 in
                                                queue (nonstandard) */
               msgqnum_t       msg_qnum;     /* Current number of messages
                                                in queue */
               msglen_t        msg_qbytes;   /* Maximum number of bytes
                                                allowed 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.coloradmin.cn/o/1675643.html

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

相关文章

vuex的基本认知

目录 一、什么是vuex 二、vuex的应用场景 三、vuex的优势 一、什么是vuex Vuex是一个vue的状态管理工具&#xff0c;状态就是数据。 进一步解释&#xff1a;vuex是一个插件&#xff0c;可以帮助我们管理vue通用的数据&#xff08;多组件共享的数据&#xff09; 二、vuex的…

2024中国(厦门)国际医用消毒及感控设备展览会

2024中国&#xff08;厦门&#xff09;国际医用消毒及感控设备展览会 2024 China (Xiamen) International Medical Disinfection And Infection Control Exhibition 致力于打造医用消毒及感控设备产业采购一站式平台 时 间&#xff1a;2024年11月1-3日 November 1-3, 2024 …

算法_前缀和

DP34 【模板】前缀和 import java.util.Scanner;// 注意类名必须为 Main, 不要有任何 package xxx 信息 public class Main {public static void main(String[] args) {Scanner in new Scanner(System.in);// 注意 hasNext 和 hasNextLine 的区别int n in.nextInt(),q in.ne…

Vmware ESXi无法创建虚拟机

点击创建虚拟机&#xff0c;没有反应 esxi在网页端无法创建虚拟机&#xff0c;与浏览器插件supercopy超级复制有关。 关闭插件在此页面运行&#xff0c;即可解决问题。 这个插件严重影响虚拟机正常的操作&#xff0c; 我还以为我的虚拟机炸了&#xff0c;格式化后&#xff0c;又…

【风变】Python爬虫精进复习-20240430

参考笔记 下面给出一个巨佬学习风变pyhton基础语法和爬虫精进的笔记&#xff08;链接&#xff09; 风变编程笔记(一)-Python基础语法 风变编程笔记(二)-Python爬虫精进 技术总结 request BeautifulSoup selenium BeautifulSoup 练习0-1&#xff1a;文章下载 import requ…

鸿蒙 DevEcoStudio:用户名密码获取保存

【使用首选项实现用户名密码保存获取】 打开src/main/ets/entryability路径下的EntryAbility.ts文件 在 export default class EntryAbility extends UIAbility {onCreate(want, launchParam) {hilog.info(0x0000, testTag, %{public}s, Ability onCreate);下边添加内容&…

ASP.NET邮件收发程序的设计与开发

摘 要 《邮件收发程序的设计与开发》是一个综合性的程序设计&#xff0c;涉及到界面、系统、数据库、协议、编码等多个方面的内容。本设计前台采用.NET技术,后台数据库采用SQL Server 2000&#xff0c;语言采用C#&#xff0c;主要讲述了邮件系统的注册、登陆、管理、发送和…

【激活函数--下】非线性函数与ReLU函数

文章目录 一、非线性函数在神经网络中的重要性二、ReLU函数介绍及其实现2.1 ReLU函数概述2.2 ReLU函数的Python实现及可视化 一、非线性函数在神经网络中的重要性 在神经网络中&#xff0c;激活函数的选择对于网络的性能和能力至关重要。阶跃函数和Sigmoid函数除了是激活函数的…

ssti学习(1)

一、成因&#xff1a; 渲染模板时&#xff0c;没有严格控制对用户的输入。&#xff08;使用了危险的模板&#xff0c;导致用户可以和flask程序进行交互&#xff09; flask是一种基于web开发的web服务器&#xff0c;如果用户可以和flask交互&#xff0c;则可以执行eval、syste…

智慧公厕:公共厕所信息化的创新之路

公共厕所是城市建设中不可或缺的一环&#xff0c;但长期以来&#xff0c;由于管理不善和设施落后&#xff0c;公厕成为城市环境中的一大难题。为了解决这个问题&#xff0c;变革式的智慧公厕应运而生。 智慧公厕是一种借助物联网、互联网、大数据、云计算、自动化控制等技术整…

umi项目配置之项目构建时配置umirc.ts

对于 umi 中能使用的自定义配置&#xff0c;你可以使用项目根目录的 .umirc.ts 文件或者 config/config.ts&#xff0c;值得注意的是这两个文件功能一致&#xff0c;仅仅是存在目录不同&#xff0c;2 选 1 &#xff0c;.umirc.ts 文件优先级较高 umi 的配置文件是一个正常的 n…

PHP黑魔法之md5绕过

php本身是一种弱语言,这个特性决定了它的两个特点: 输入的参数都是当作字符串处理变量类型不需要声明,大部分时候都是通过函数进行类型转化php中的判断有两种: 松散比较:只需要值相同即可,类型不必相同,不通类型比较会先转化为同类型,比如全数字字符串和数字比较,会比…

Windows snmp++获取本地主机信息

编译snmp的包 调用snmp.lib实现信息获取_哔哩哔哩_bilibili 代码&#xff1a; #include <iostream> #include <libsnmp.h> #include <vector> #include <fstream> #include <string> #include "snmp_pp/snmp_pp.h" //#define _NO_L…

高清SDI串行数字接口采集卡与传输编码器

随着科技的快速发展&#xff0c;我们正处于一个数字化、信息化的时代&#xff0c;各式各样的设备正成为人们工作和生活中必不可少的伙伴。今天&#xff0c;我要向大家介绍的是一款具有革命性意义的视频采集卡——LCC262。这款由灵卡技术团队精心打造的产品&#xff0c;集合了多…

在阿里云服务器上安装MySQL

目录 一、先卸载不需要的环境 1.关闭MySQL服务 2.查看安装包以及卸载安装包 3.依次卸载所有包 4. 获取mysql官⽅yum源 二、安装&#xff08;密钥过期解决方法&#xff09; 三、启动并进入 关于MySQL MySQL是一个广泛使用的开源关系型数据库管理系统&#xff08;RDBMS&…

金三银四面试题(二十七):适配器模式知多少?

什么是适配器模式 适配器模式&#xff08;Adapter Pattern&#xff09;是一种结构型设计模式&#xff0c;它允许将一个类的接口转换为客户期望的另一个接口。通过适配器&#xff0c;原本不兼容的接口可以一起工作&#xff0c;从而提高系统的灵活性和可扩展性。 关键元素&…

开发测试必须知道的 10种 常见软件架构模式

你是否想知道企业大规模系统是如何设计的? 在软件开发开始之前&#xff0c;我们必须选择一个合适的架构&#xff0c;能提供所需的功能和质量特性。因此&#xff0c;在将架构应用到我们的设计之前&#xff0c;我们应该了解各种不同架构的特点。 01 什么是架构模式 根据维基百…

parallelsdesktop19密钥激活 PD19虚拟机完整图文安装教程

Parallels Desktop 19 &#xff08;简称 PD 19)是最新发布的 macOS 平台的 windows 虚拟机&#xff0c;本文是使用 Parallels Desktop 19 虚拟机安装 Windows 的详细图文破解安装教程。 一下载安装 Parallels Desktop 软件下载完成后打开&#xff0c;双击打开 安装.dmg Para…

【多模态】30、Monkey | 支持大尺寸图像输入的多任务多模态大模型

文章目录 一、背景二、方法2.1 Enhancing Input Resolution2.2 Multi-level Description Generation2.3 Multi-task Training 三、效果3.1 Image Caption3.2 General VQA3.3 Scene Text-centric VQA3.4 Document-oriented VQA3.5 消融实验3.6 可视化 论文&#xff1a;Monkey : …

【核弹】我的第一款IDEA插件

SuperHotSwap 插件名称叫做&#xff1a;SuperHotSwap&#xff08;超级热更新&#xff09; 开发初心&#xff1a;旨在做出一款最便捷的IDEA热更新插件&#xff0c;减少用户操作步骤&#xff0c;提供零配置的可视化操作更新。 为什么要写这个插件&#xff1a; 每次改一下Mappe…