01.消息队列

消息队列提供了一个从一个进程向另外一个进程发送一块数据的方法 每个数据块都被认为是有一个类型，接收者进程接收的数据块可以有不同的类型值

发送方将消息放入队列，接收方从队列中取出消息

发送方和接收方不需要同时在线，消息可以存储在队列中，等待接收方处理

消息队列也有自己的属性

代码语言：javascript代码运行次数：0运行复制

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 creation or last                                 modification by msgctl() */    unsigned long msg_cbytes; /* # of bytes in queue */    msgqnum_t msg_qnum;       /* # number of messages in queue */    msglen_t msg_qbytes;      /* Maximum # of bytes in queue */    pid_t msg_lspid;          /* PID of last msgsnd(2) */    pid_t msg_lrpid;          /* PID of last msgrcv(2) */};

---

System V 消息队列接口

System V 消息队列是 UNIX 系统提供的一种 IPC 机制，主要接口包括：

(1) ftok • 功能：生成消息队列的键值（key_t）。 • 原型：

代码语言：javascript代码运行次数：0运行复制

key_t ftok(const char *pathname, int proj_id);

• 参数： • pathname：文件路径。 • proj_id：项目 ID。 • 返回值：生成的键值。

(2) msgget • 功能：创建或获取消息队列。 • 原型：

代码语言：javascript代码运行次数：0运行复制

int msgget(key_t key, int msgflg);

• 参数： • key：消息队列的键值。 • msgflg：标志位（如 IPC_CREAT、IPC_EXCL）。 • 返回值：消息队列的标识符（msqid）。

(3) msgsnd • 功能：向消息队列发送消息。 • 原型：

代码语言：javascript代码运行次数：0运行复制

int msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg);

• 参数： • msqid：消息队列标识符。 • msgp：指向消息结构的指针。 • msgsz：消息的大小。 • msgflg：标志位（如 IPC_NOWAIT）。

消息结构通常定义如下：

代码语言：javascript代码运行次数：0运行复制

struct Message {    long mtype;       // 消息类型（必须为 long 类型）    char mtext[100];  // 消息内容（可以是任意类型）};

消息类型必须为 long 类型 消息内容，可以是字符数组、结构体等

(4) msgrcv • 功能：从消息队列接收消息。 • 原型：

代码语言：javascript代码运行次数：0运行复制

ssize_t msgrcv(int msqid, void *msgp, size_t msgsz, long msgtyp, int msgflg);

• 参数： • msqid：消息队列标识符。 • msgp：指向消息结构的指针。 • msgsz：消息的大小。 • msgtyp：消息类型。 • msgflg：标志位（如 IPC_NOWAIT）。

(5) msgctl • 功能：控制消息队列（如删除队列、获取状态等）。 • 原型：

代码语言：javascript代码运行次数：0运行复制

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

• 参数： • msqid：消息队列标识符。 • cmd：控制命令（如 IPC_RMID、IPC_STAT）。 • buf：指向 msqid_ds 结构的指针。

---

代码语言：javascript代码运行次数：0运行复制

dyx@dyx-VMware-Virtual-Platform:~/bitcode$ ipcs--------- 消息队列 -----------键        msqid      拥有者  权限     已用字节数 消息      ------------ 共享内存段 --------------键        shmid      拥有者  权限     字节     连接数  状态      --------- 信号量数组 -----------键        semid      拥有者  权限     nsems     

02.信号量

首先进行几个概念的理解：

多个执行流（进程），能看到的一份资源：共享资源被保护起来的共享资源 - 临界资源 —同步和互斥来保护互斥：任何时刻只能有一个进程在访问共享资源资源被访问，朴素的认识就是通过代码访问—代码=访问共享资源的代码+不访问共享资源的代码临界区是指访问临界资源的代码段。在临界区内，线程或进程会访问或修改共享资源

代码语言：javascript代码运行次数：0运行复制

#include std::mutex mtx;int shared_variable = 0;void increment() {    mtx.lock(); // 加锁    shared_variable++; // 临界区    mtx.unlock(); // 解锁}

信号量是用来保护共享资源，实现资源的互斥访问，信号量的核心思想是通过一个计数器来管理资源的可用数量

申请信号量的本质就是对资源的预定机制

它通过 原子操作 来控制资源的分配和释放，确保多个线程或进程能够安全地访问共享资源。信号量的核心思想是：

计数器： • 信号量维护一个非负整数计数器，表示当前可用资源的数量。 • 当计数器大于 0 时，表示资源可用；当计数器为 0 时，表示资源不可用。 原子操作： • 信号量的操作（P 操作和 V 操作）是原子的，即这些操作在执行过程中不会被中断。 • 原子性确保了多个线程或进程在访问信号量时不会发生竞争条件。 阻塞与唤醒： • 当线程或进程请求资源时（P 操作），如果计数器为 0，则线程或进程会被阻塞，直到资源可用。 • 当线程或进程释放资源时（V 操作），如果有等待的线程或进程，则唤醒其中一个。

---

信号量与共享资源之间的交互通过 P 操作 和 V 操作 实现。以下是信号量与共享资源的交互过程：

P 操作（Wait 或 Acquire） • 功能：请求资源。 • 实现： • 计数器减 1。 • 如果计数器小于 0，则当前线程或进程被阻塞，直到计数器大于 0。 • 伪代码：代码语言：javascript代码运行次数：0运行复制

P(semaphore):    semaphore--    if semaphore < 0:        block()

V 操作（Signal 或 Release） • 功能：释放资源。 • 实现： • 计数器加 1。 • 如果有等待的线程或进程，则唤醒其中一个。 • 伪代码：代码语言：javascript代码运行次数：0运行复制

V(semaphore):    semaphore++    if semaphore <= 0:        wakeup()

假设有一个共享资源（如打印机），使用信号量来管理其访问：

初始化信号量： • 信号量计数器初始化为 1（表示资源可用）。

代码语言：javascript代码运行次数：0运行复制

semaphore = 1;

线程 A 请求资源： • 执行 P 操作，计数器减 1。 • 计数器变为 0，资源被线程 A 占用。

代码语言：javascript代码运行次数：0运行复制

P(semaphore); // semaphore = 0

线程 B 请求资源： • 执行 P 操作，计数器减 1。 • 计数器变为 -1，线程 B 被阻塞。

代码语言：javascript代码运行次数：0运行复制

P(semaphore); // semaphore = -1

线程 A 释放资源： • 执行 V 操作，计数器加 1。 • 计数器变为 0，唤醒线程 B。

代码语言：javascript代码运行次数：0运行复制

V(semaphore); // semaphore = 0

线程 B 占用资源： • 线程 B 被唤醒，占用资源。 • 计数器仍为 0，表示资源被线程 B 占用。

线程 B 释放资源： • 执行 V 操作，计数器加 1。 • 计数器变为 1，资源可用。

代码语言：javascript代码运行次数：0运行复制

V(semaphore); // semaphore = 1

---

和共享内存，消息队列一样，必须先让不同的进程看到同一个计数器

意味着信号量也是一个公共资源

System V 信号量接口

(1) semget • 功能：创建或获取信号量集。 • 原型：

代码语言：javascript代码运行次数：0运行复制

int semget(key_t key, int nsems, int semflg);

• 参数： • key：信号量集的键值。 • nsems：信号量集中的信号量数量。 • semflg：标志位（如 IPC_CREAT、IPC_EXCL）。 • 返回值：成功返回信号量集的标识符，失败返回 -1。

(2) semop • 功能：执行信号量操作（P 操作或 V 操作）。 • 原型：

代码语言：javascript代码运行次数：0运行复制

int semop(int semid, struct sembuf *sops, size_t nsops);

• 参数： • semid：信号量集的标识符。 • sops：指向 sembuf 结构数组的指针。 • nsops：操作的数量。 • 返回值：成功返回 0，失败返回 -1。

(3) semctl • 功能：控制信号量集（如初始化、删除、获取状态等）。 • 原型：

代码语言：javascript代码运行次数：0运行复制

int semctl(int semid, int semnum, int cmd, ...);

• 参数： • semid：信号量集的标识符。 • semnum：信号量的索引。 • cmd：控制命令（如 IPC_RMID、SETVAL）。 • ...：可选参数，通常是一个 union semun 结构。 • 返回值：成功返回 0 或其他值（取决于 cmd），失败返回 -1。

---

示例：

代码语言：javascript代码运行次数：0运行复制

#include #include #include int main() {    key_t key = ftok("semfile", 65);    int semid = semget(key, 1, 0666 | IPC_CREAT);    // 初始化信号量值为 1    semctl(semid, 0, SETVAL, 1);    struct sembuf sb;    sb.sem_num = 0;    sb.sem_op = -1; // P 操作    sb.sem_flg = 0;    semop(semid, &sb, 1);    std::cout << "Critical section" << std::endl;    sb.sem_op = 1; // V 操作    semop(semid, &sb, 1);    // 删除信号量    semctl(semid, 0, IPC_RMID);    return 0;}

---

03.OS对system V ipc的管理

不管是共享内存，消息队列还是信号量，他们调用接口都为xxxget，xxxctl

IPC 标识符 操作系统为每个 IPC 资源分配一个唯一的 标识符（ID），用于标识和管理该资源。标识符的类型包括： • 消息队列标识符（msqid）：用于标识消息队列。 • 共享内存标识符（shmid）：用于标识共享内存段。 • 信号量标识符（semid）：用于标识信号量集。

标识符的生成方式： • 通过 ftok 函数生成键值（key_t），然后使用 msgget、shmget 或 semget 创建或获取 IPC 资源。

---

资源管理结构 操作系统为每种 IPC 资源维护一个 管理结构，用于存储资源的属性和状态。以下是常见的管理结构：消息队列管理结构

• msqid_ds： • 存储消息队列的属性，如权限、消息数量、最后操作时间等。 • 示例：

代码语言：javascript代码运行次数：0运行复制

```cppstruct msqid_ds {    struct ipc_perm msg_perm; // 权限信息    time_t msg_stime;        // 最后发送时间    time_t msg_rtime;        // 最后接收时间    time_t msg_ctime;        // 最后修改时间    unsigned long msg_cbytes; // 当前字节数    msgqnum_t msg_qnum;      // 当前消息数量    msglen_t msg_qbytes;     // 最大字节数    pid_t msg_lspid;         // 最后发送进程的 PID    pid_t msg_lrpid;         // 最后接收进程的 PID};```

共享内存管理结构

• shmid_ds： • 存储共享内存段的属性，如大小、权限、附加进程数等。 • 示例：

代码语言：javascript代码运行次数：0运行复制

```cppstruct shmid_ds {    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;          // 创建进程的 PID    pid_t shm_lpid;          // 最后操作进程的 PID    shmatt_t shm_nattch;     // 当前附加进程数};```

信号量管理结构

• semid_ds： • 存储信号量集的属性，如权限、信号量数量、最后操作时间等。 • 示例：

代码语言：javascript代码运行次数：0运行复制

```cppstruct semid_ds {    struct ipc_perm sem_perm; // 权限信息    time_t sem_otime;        // 最后操作时间    time_t sem_ctime;        // 最后修改时间    unsigned short sem_nsems; // 信号量数量};```

---

资源权限 每种 IPC 资源都有一个 权限结构（ipc_perm），用于控制资源的访问权限。权限结构包括： • 所有者用户 ID（uid）：资源的所有者。 • 所有者组 ID（gid）：资源的所有者组。 • 创建者用户 ID（cuid）：资源的创建者。 • 创建者组 ID（cgid）：资源的创建者组。 • 权限模式（mode）：资源的访问权限（如读、写、执行）。

---

资源生命周期 IPC 资源的生命周期包括：创建：通过 msgget、shmget 或 semget 创建资源。使用：进程通过标识符访问资源。修改：通过 msgctl、shmctl 或 semctl 修改资源属性。删除：通过 msgctl、shmctl 或 semctl 删除资源。

---

操作系统维护一个 ​全局的 IPC 资源表，用于存储所有 IPC 资源的信息。每种 IPC 资源（消息队列、共享内存、信号量）都有自己的资源表，表中的每一项对应一个具体的 IPC 资源

# linux  # 操作系统  # ai  # lsp  # red  # JavaScript  # 标识符  # 结构体  # union  # 指针  # 接口  # signal  # 线程  # unix  # 信号量  # 键值  # 返回值  # 多个  # 自己的  # 都有  # 其中一个  # 互斥  # 有一个  # 访问权限 

相关栏目： 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571 】

相关推荐： Bootstrap CSS布局之列表  Laravel如何操作JSON类型的数据库字段？（Eloquent示例）  微信小程序 闭包写法详细介绍  南京网站制作费用,南京远驱官方网站？  Laravel怎么清理缓存_Laravel optimize clear命令详解  Laravel怎么实现模型属性的自动加密  HTML透明颜色代码怎么让图片透明_给img元素加透明色的技巧【方法】  Laravel如何优雅地处理服务层_在Laravel中使用Service层和Repository层  如何获取PHP WAP自助建站系统源码？  Laravel数据库迁移怎么用_Laravel Migration管理数据库结构的正确姿势  Laravel如何配置中间件Middleware_Laravel自定义中间件拦截请求与权限校验【步骤】  JS中页面与页面之间超链接跳转中文乱码问题的解决办法  千库网官网入口推荐 千库网设计创意平台入口  Laravel怎么进行浏览器测试_Laravel Dusk自动化浏览器测试入门  google浏览器怎么清理缓存_谷歌浏览器清除缓存加速详细步骤  手机网站制作与建设方案,手机网站如何建设？  什么是javascript作用域_全局和局部作用域有什么区别？  如何用花生壳三步快速搭建专属网站？  Laravel怎么做数据加密_Laravel内置Crypt门面的加密与解密功能  Android使用GridView实现日历的简单功能  如何用狗爹虚拟主机快速搭建网站？  如何在腾讯云服务器上快速搭建个人网站？  如何用美橙互联一键搭建多站合一网站？  敲碗10年！Mac系列传将迎来「触控与联网」双革新  laravel怎么用DB facade执行原生SQL查询_laravel DB facade原生SQL执行方法  html5如何实现懒加载图片_ intersectionobserver api用法【教程】  三星网站视频制作教程下载,三星w23网页如何全屏？  香港服务器WordPress建站指南：SEO优化与高效部署策略  Laravel Fortify是什么，和Jetstream有什么关系  绝密ChatGPT指令：手把手教你生成HR无法拒绝的求职信  如何登录建站主机？访问步骤全解析  邀请函制作网站有哪些,有没有做年会邀请函的网站啊？在线制作，模板很多的那种？  Laravel Sail是什么_基于Docker的Laravel本地开发环境Sail入门  网站制作软件有哪些,制图软件有哪些？  Laravel如何使用Livewire构建动态组件？（入门代码）  如何用AI帮你把自己的生活经历写成一个有趣的故事？  Python文件流缓冲机制_IO性能解析【教程】  高防服务器：AI智能防御DDoS攻击与数据安全保障  WordPress 子目录安装中正确处理脚本路径的完整指南  Python自动化办公教程_ExcelWordPDF批量处理案例  如何在服务器上三步完成建站并提升流量？  Google浏览器为什么这么卡 Google浏览器提速优化设置步骤【方法】  Laravel如何发送系统通知？（Notification渠道示例）  Laravel如何创建自定义Facades？（详细步骤）  Linux系统命令中tree命令详解  Laravel如何创建自定义中间件？（Middleware代码示例）  BootStrap整体框架之基础布局组件  ,网页ppt怎么弄成自己的ppt？  Laravel怎么返回JSON格式数据_Laravel API资源Response响应格式化【技巧】  长沙企业网站制作哪家好,长沙水业集团官方网站？