【Linux】进程间通信——System V消息队列和信号量

一、消息队列

1.1 概念

进程间通信的原理是让不同进程看到同一份资源，资源种类的不同就决定了通信方式的差异。如果用管道通信，则资源是文件缓冲区；如果用共享内存，则资源是内存块

消息队列是由操作系统提供的资源，其本质就是内核中存放通信数据块的一个队列，可供两个进程进行双向通信。

两个要进行通信的进程以数据块的形式发送数据，数据块被链入到消息队列中，并发送给目标进程

如果两个进程的数据块被存放到一个消息队列中，如何区分数据块是自己发送的还是对方进程发给自己的呢？所以数据块需要有自己的类型，根据类型来进行区分。

系统中存在这么多进程，因此肯定也有不止一个消息队列。既然消息队列由OS提供，那么OS必定要对消息队列进行管理。所以内核中除了有队列的结构外，一定需要其他的数据结构对消息队列进行描述和组织。

消息队列的内核结构体：

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) */
};

细心的人可能已经发现了，消息队列的内核结构体，与我们之前讲的共享内存的内核结构体十分类似，特别是它们都有一个ipc_perm结构体：

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 */
};

其中存放了key等非常重要的信息，说明消息队列和共享内存一样，都有自己的key来标识自己在系统中的唯一性

1.2 API介绍和使用

如果有读者阅读过我前面讲共享内存的文章 【Linux】进程间通信——System V共享内存_共享内存进程间通信-CSDN博客

本文讲的消息队列和信号量与前面提到的共享内存同属于System V进程间通信方式，其内核结构体、API定义和使用方式都十分相似，大家可以对比一下

（1）msgget

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>int msgget(key_t key, int msgflg);

msgget函数用于创建消息队列，若创建成功会返回msqid，即消息队列标识符； 创建失败返回-1

其中：

  • key：类型为key_t，内核中标识消息队列的唯一标识符，需要用户生成
  • msgflg：标志位。其中IPC_CREAT表示如果申请的消息队列不存在就创建，存在就获取并返回；IPC_CREAT|IPC_EXCL表示如果申请的消息队列不存在就创建，存在就出错并返回 

在前面讲共享内存时，用于创建共享内存的函数shmget中也有参数key和权限位flg，而用于创建消息队列的函数中也有这两个参数，并且用法也是相同的。都有系统中标识唯一性的key，都返回用户层标识唯一性的标识符。

而这里的key，也是通过ftok函数生成的，关于ftok函数我们在讲共享内存时已经讲过了。

可以看出，消息队列的接口和共享内存的接口是非常类似的，很多概念都是共通的

（2）msgctl

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>int msgctl(int msqid, int cmd, struct msqid_ds *buf);

msgctl函数用于控制消息队列，和共享内存的shmctl函数也是非常类似，类似到我甚至可以直接把讲共享内存时的原话修改一下放到这篇文章中

其中：

  • msqid自然就是在创建消息队列时返回的标识符了
  • cmd：需要做的操作。IPC_STAT为获取消息队列属性；IPC_SET为设置消息队列的权限相关属性；IPC_RMID为删除消息队列并释放队列中的所有消息
  • buf：类型为msqid_ds，即消息队列的内核结构体。IPC_RMID操作中可设置为nullptr

（3）msgsnd

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>int msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg);

这里开始就与共享内存有所不同了，共享内存需要挂接到进程的地址空间上，不用时再去掉关联；而消息队列则是向指定消息队列中发送数据块或接收数据块

其中：

  • msgp：数据块的起始地址
  • msgsz：数据块大小
  • msgflg：0为阻塞状态，若消息队列空间满则阻塞；IPC_NOWAIT为消息队列满则返回

但是说了这么多，这数据块到底长啥样？我们怎么创建一个数据块？

struct msgbuf {long mtype;       /* message type, must be > 0 */char mtext[1];    /* message data */
};

这就是我们的数据块结构体，其中mtype是数据块的类型（必须大于0），mtext是消息的内容

但是为什么字符数组mtext大小只有1呢？实际上在使用时，这个结构体是需要用户自己定义的，只需要保证第一个字段是long类型第二个字段是消息内容即可，消息的大小由用户决定

所以未来我们想用消息队列发一个消息，只需要定义一个数据块结构体，然后创建对象，填充对应字段，并向msgsnd函数中传入该对象的指针即可。

（4）msgrcv

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>ssize_t msgrcv(int msqid, void *msgp, size_t msgsz, long msgtyp, int msgflg);

有发就有收，msgrcv函数用于从消息队列中读取数据块

其中：

  • msgtyp：要读取的数据块类型，为0则读取消息队列的第一条消息，大于0则读取消息队列中第一条和msgtyp相同类型的消息，小于0则读取消息队列中所有类型不大于msgtyp的绝对值的消息中类型最小的消息
  • msgflg：0为阻塞状态；IPC_NOWAIT代表如果消息队列中没有指定类型的数据块则立刻返回并设置错误码为ENOMSG；MSG_EXCEPT代表当msgtyp大于0时读取队列中与msgtyp相同的第一条消息；MSG_NOERROR代表如果消息文本长度超过msgsz则截断该文本

（5）查看系统中的消息队列

通过命令 ipcs -q 查看当前所有消息队列

通过命令 ipcrm -q msgid 删除指定消息队列

二、信号量

2.1 概念

前文提到，共享内存不具有任何的保护机制，也就是说如果我们不加保护，当一个进程没有完整的把内容写入时，另一方就开始读取，可能会导致数据的收发方出现数据不一致问题

像这种类似的不被保护的共享资源，被多个执行流同时访问时，都可能会出现这类问题。例如我们过年抢回家的车票时，车票的余量也是共享资源，如果不加以保护，则可能会导致余票变为负数的情况（抢到车票后车票余量需要减少，这两步是分开的，所以可能导致同时抢到票的用户数量大于车票的余量，但仍然判断抢票成功）

其中一个解决方案是通过加锁来实现对共享资源的互斥访问，即任何时刻只允许一个执行流访问共享资源。

对于这类被多个执行流共享的，但通过某种方式保证其互斥访问的共享资源称为临界资源。例如管道也是一种临界资源。在整个程序的所有代码中，可能只有一小部分的代码访问了临界资源，这部分代码就称为临界区。

说了这么多，到底什么是信号量呢？

信号量（Semaphore）本质就是一个计数器，用于记录临界资源中资源的数量。临界资源能被分为多少份，则信号量为几。

例如我们要看电影，自然需要先买票，只有买了票，我们才能够拥有使用电影院座位的资格。而电影院的剩余票数需要用一个计数器记录，每卖出一张票，则计数器减一，当计数器为0时就说明票已经卖光了。

电影院中的座位就是许多共享资源，而买票就是对这些座位的预定机制。也就是说，要具有访问共享资源的权限，首先就得申请计数器。但申请了计数器，并不代表一定访问共享资源，就像我只是买了电影票，我已经有了使用该座位的资格，不管我去不去看电影这个座位都是我的。计数器可以有效保证进入共享资源的执行流的数量，申请计数器就等同于“买票”。

而这个计数器，就叫做信号量！

有了信号量，我们就可以保证共享资源不会同时被多个执行流同时访问，避免了数据不一致问题

假设我们的信号量初始值为1，也就是将共享资源看作一个整体，则说明同一时间内只有一个执行流能够申请到信号量并具有访问共享资源的资格，实际上我们就实现了互斥。这种值只可能为1或0的信号量叫做二元信号量，其本质上就相当于一把锁。

到这里，大家可能还有一些疑惑。信号量既然是一个计数器，那和进程间通信又有什么关系呢？实际上进程间通信并不仅仅是进行数据的来往，进程间的协同也是进程间通信的一部分。

问题又来了，既然进程要申请信号量，信号量不也是共享资源吗？既然信号量要保证共享资源的安全，首先得保证自己是安全的。因此信号量的申请（P）和释放（V）操作都是原子的，即只有没做和做完了两种状态，不存在“正在做”的情况。

拓展：我们能否用一个变量来代替信号量完成计数操作呢？不行！因为减少变量的值，这个操作并不是安全的。

在编程语言层面，看上去我们可以用一条语句完成减操作，但是变成汇编后则有多条语句。进程在执行这些汇编语句的过程中随时可能会被切换，存在风险

更多细节可以阅读：Linux下信号量的P.V操作如何保证其原子性_51CTO博客_信号量 Linux

我们来看看信号量的内核结构体：

struct semid_ds {struct ipc_perm sem_perm;  /* Ownership and permissions */time_t          sem_otime; /* Last semop time */time_t          sem_ctime; /* Last change time */unsigned long   sem_nsems; /* No. of semaphores in set */
};

同样，其内部也包含了ipc_perm结构体，这说明什么？信号量也有自己的key。也再次证明，同为System V进程间通信方式，共享内存、消息队列和信号量具有很多相似之处

2.2 API介绍和使用

（1）semget

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/sem.h>int semget(key_t key, int nsems, int semflg);

semget函数用于创建一个信号量（集），如果成功将会返回该信号量集的semid，失败返回-1并设置错误码

其中：

  • 参数key和共享内存、消息队列一样，一般通过ftok函数生成
  • nsems：信号量集需要的信号量数目，大部分情况下为1
  • semflg：还是和前面一样，标志位。其中IPC_CREAT表示如果申请的信号量集不存在就创建，存在就获取并返回；IPC_CREAT|IPC_EXCL表示如果申请的信号量集不存在就创建，存在就出错并返回

（2）semctl

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/sem.h>int semctl(int semid, int semnum, int cmd, ...);

semctl函数用于控制信号量集，成功会根据cmd返回一个非负值，失败返回-1并设置错误码 

如果需要，第四个参数通常被设置为union semun arg，其结构如下：

union semun {int              val;    /* SETVAL的值 */struct semid_ds *buf;    /* 用于IPC_STAT, IPC_SET的缓冲区 */unsigned short  *array;  /* 用于GETALL, SETALL的数组 */struct seminfo  *__buf;  /* IPC_INFO的缓冲区(Linux特有) */
};

 其中：

  • semid：信号量集id
  • semnum：指定当前信号量集的某一个信号量，类似于下标
  • cmd：要进行的操作，例如SETVAL为将指定信号量的值设置为arg.val；IPC_RMID为删除信号量集，删除操作则不需要传入arg参数；SETALL为设置信号量集中信号量的值为arg.array内部的值

（3）semop

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/sem.h>int semop(int semid, struct sembuf *sops, unsigned nsops);

semop函数用于设置信号量的值，成功返回0，失败返回-1并设置错误码

关于sops参数，struct sembuf的结构如下：

struct sembuf{unsigned short sem_num;  /* semaphore number */short          sem_op;   /* semaphore operation */short          sem_flg;  /* operation flags */
};

其中：

  • sem_num为指定信号量在信号量集中的编号，如果在创建信号量集时nsems参数设置为1，则这里填0即可
  • sem_op：若该值为正数则为释放信号量操作，sem_op的值会加到信号量的值上；值为负数则为申请信号量操作，若信号量的值不足以支撑该申请操作且sem_flg不为IPC_NOWAIT，则阻塞；若sem_op值为0，且sem_flg不为IPC_NOWAIT，则进程阻塞直到信号量的值变为0
  • sem_flg：若设置为IPC_NOWAIT且信号的某个操作无法正常进行时，则进程不会阻塞，而是出错并返回；若设置为IPC_UNDO，则当进程异常终止没有释放信号量时，由操作系统释放，避免了因进程未释放信号量导致其他进程无法申请的问题

nsops参数指定了需要修改的信号量个数，即sops数组中的元素个数，一般我们只需要对一个信号量进行设置，所以设置为1即可

完.

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

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

相关文章

postman自动化实战总结

postman自动化实战总结

Postman实战总结 简介 本次实战内容主要包括如下几点&#xff1a; l 背景介绍 l Postman使用&#xff0c;侧重于自动化实现&#xff0c;基础使用不做介绍 l 可视化Newman介绍 l 框架特色 l 实战中的坑 背景 随着国内软件技术的高速发展&#xff0c;越来越多的手工测试…
阅读更多...
解决谷歌浏览器在安卓手机上的常见问题

解决谷歌浏览器在安卓手机上的常见问题

在使用安卓手机浏览网页时&#xff0c;谷歌浏览器无疑是许多用户的首选。然而&#xff0c;在使用过程中&#xff0c;用户可能会遇到一些常见问题&#xff0c;如搜索图片困难、缓存积累过多导致浏览器卡顿&#xff0c;以及无法下载视频等。本文将针对这些问题&#xff0c;提供详…
阅读更多...
【Linux】详解Linux下的工具（内含yum指令和vim指令）

【Linux】详解Linux下的工具（内含yum指令和vim指令）

文章目录 前言1. Linux下软件安装的方式2. yum2.1 软件下载的小知识2.2 在自己的Linux系统下验证yum源的存在2.3 利用yum指令下载软件2.4 拓展yum源&#xff08;针对于虚拟机用户&#xff09; 3. vim编辑器3.1 vim是什么&#xff1f;3.2 如何打开vim3.2 vim各模式下的讲解3.2.1…
阅读更多...
【C语言】猜数字小游戏

【C语言】猜数字小游戏

&#x1f602;个人主页: 起名字真南 &#x1f923;个人专栏:【数据结构初阶】 【C语言】 【C】 目录 1 随机数的生成1.1 rand1.2 srand1.3 time1.4 设置随机数范围 2 猜数字游戏实现 前言&#xff1a;我们学习完前面的循环以后可以写一个猜数字小游戏 1 随机数的生成 想要完成…
阅读更多...
新生培训 day1 C语言基础 顺序 分支 循环 数组 字符串 函数

新生培训 day1 C语言基础 顺序 分支 循环 数组 字符串 函数

比赛地址 b牛客竞赛_ACM/NOI/CSP/CCPC/ICPC算法编程高难度练习赛_牛客竞赛OJ C语言数据类型 字符 整型数 int 2e9 long long 9e18 浮点数 代码示例 /** Author: Dduo * Date: 2024-10-8* Description: 新生培训day1 */ #include <stdio.h>int main() {// 定义变量in…
阅读更多...
QT-空窗口主窗口对话框

QT-空窗口主窗口对话框

1. QMainWindow QMainWindow 用来创建主窗口 主窗口包含&#xff1a; 标题栏&#xff08;Window title&#xff09;、菜单栏&#xff08;MenuBar&#xff09;、工具栏&#xff08;ToolBar&#xff09;、状态栏&#xff08;StatusBar&#xff09;、停靠部件&#xff08;DockWid…
阅读更多...
Ansible学习之ansible-pull命令

Ansible学习之ansible-pull命令

想要知道ansible-pull是用来做什么的&#xff0c;就需要了解Ansible的工作模&#xff0c;Ansible的工作模式有两种&#xff1a; push模式 push推送&#xff0c;这是Ansible的默认模式&#xff0c;在主控机上编排好playbook文件&#xff0c;push到远程主机上来执行。pull模式 p…
阅读更多...
RISC-V知识点目录

RISC-V知识点目录

分支预测 分支预测概述https://blog.csdn.net/zhangshangjie1/article/details/136947089?sharetypeblogdetail&sharerId136947089&sharereferPC&sharesourcezhangshangjie1&spm1011.2480.3001.8118分支指令的方向预测https://blog.csdn.net/zhangshangjie1/a…
阅读更多...
如何革新源代码保密？七大方法教你应对！

如何革新源代码保密？七大方法教你应对！

在数字化时代&#xff0c;源代码的安全保密对于企业而言至关重要&#xff0c;它不仅关系到企业的核心竞争力&#xff0c;还涉及到知识产权的保护。源代码一旦泄露&#xff0c;可能会给企业带来无法估量的损失。因此&#xff0c;采取有效的源代码保密措施&#xff0c;是每个企业…
阅读更多...
【电路】1.3 电功率和能量

【电路】1.3 电功率和能量

1.3 电功率和能量 电是一种能量存在形式。 1.3.1 电压的定义 将单位正电荷由A点移动至B点&#xff0c;电场力所做的功是 w w w&#xff0c;则 u A B d w d q u_{AB}\frac{dw}{dq} uAB​dqdw​&#xff0c; w w w是功&#xff0c; q q q是电荷量从A到B&#xff0c;沿着任意路…
阅读更多...
D3.js中国地图可视化

D3.js中国地图可视化

1、项目介绍 该项目来自Github&#xff0c;基于D3.js中国地图可视化。 D3.js is a JavaScript library for manipulating documents based on data. It uses HTML, SVG, and CSS to display data. The full name of D3 is "Data-Driven Documents," which means it a…
阅读更多...
C++11--列表初始化和声明

C++11--列表初始化和声明

统一的列表初始化 { } 初始化 C11引入了统一的 列表初始化&#xff08;Uniform Initialization&#xff09;&#xff0c;这是一种使用大括号 { } 初始化变量和对象的新语法&#xff0c;旨在简化初始化过程并提高代码的可读性和一致性。 这种初始化方式适用于几乎所有类型&am…
阅读更多...
轻松掌握IP代理服务器设置方法，网络冲浪更自如

轻松掌握IP代理服务器设置方法，网络冲浪更自如

在数字化时代&#xff0c;互联网就像是一片浩瀚的海洋&#xff0c;而IP代理服务器就如同我们在这片海洋中航行的指南针。通过使用代理IP&#xff0c;我们可以更方便地访问全球网络资源&#xff0c;提升网络安全性。本文将为您详细介绍IP代理服务器的设置方法&#xff0c;让您在…
阅读更多...
Library介绍（四）

Library介绍（四）

标准单元描述 标准单元主要由以下几个部分构成&#xff0c;分别是引脚电容、power、timing组成。其中引脚电容主要包含input/output pin的电容值。 power主要包含每个pin的leakage power和internal power。 timing主要包括cell的input pin到output pin的rise delay和fall del…
阅读更多...
人才画像系统是什么?有哪些功能和作用？

人才画像系统是什么?有哪些功能和作用？

人才画像系统是一种先进的人力资源管理工具&#xff0c;它运用大数据和人工智能技术对员工的多方面特征进行深度分析。系统通过汇聚个人的教育背景、工作经验、技能掌握、性格特质及行为数据等信息&#xff0c;结合数据挖掘和机器学习算法&#xff0c;构建出每位员工的数字化“…
阅读更多...
Spring Boot：打造下一代医院管理系统

Spring Boot：打造下一代医院管理系统

3系统分析 3.1可行性分析 通过对本医院管理系统实行的目的初步调查和分析&#xff0c;提出可行性方案并对其一一进行论证。我们在这里主要从技术可行性、经济可行性、操作可行性等方面进行分析。 3.1.1技术可行性 本医院管理系统采用JAVA作为开发语言&#xff0c;Spring Boot框…
阅读更多...
【漏洞复现】网动统一通信平台/网动统一通信平台ActiveUC存在任意文件下载

【漏洞复现】网动统一通信平台/网动统一通信平台ActiveUC存在任意文件下载

》》》产品描述《《《 网动统一通信平台是采用统一的通信界面&#xff0c;将VoIP电话系统、电子邮件等多种沟通方式融合的企业IT平台。 》》》漏洞描述《《《 网动统一通信平台是采用统一的通信界面&#xff0c;将VoIP电话系统、电子邮件等多种沟通方式融合的企业IT平台。网动统…
阅读更多...
原生input实现时间选择器用法

原生input实现时间选择器用法

2024.10.08今天我学习了如何用原生的input&#xff0c;实现时间选择器用法&#xff0c;效果如下&#xff1a; 代码如下&#xff1a; <div><input id"yf_start" type"text"> </div><script>$(#yf_start).datepicker({language: zh…
阅读更多...
【Maven】依赖管理，Maven仓库，Maven核心功能

【Maven】依赖管理，Maven仓库，Maven核心功能

Maven 是一个项目管理工具&#xff0c;基于 POM&#xff08;Project Object Model&#xff0c;项目对象模型&#xff09;的概念&#xff0c;Maven 可以通过一小段描述信息来管理项目的构建&#xff0c;报告和文档的项目管理工具软件 大白话&#xff1a;Maven 是一个项目管理工…
阅读更多...
初始爬虫12（反爬与反反爬）

初始爬虫12（反爬与反反爬）

学到这里&#xff0c;已经可以开始实战项目了&#xff0c;多去爬虫&#xff0c;了解熟悉反爬&#xff0c;然后自己总结出一套方法怎么做。 1.服务器反爬的原因 服务器反爬的原因 总结&#xff1a; 1.爬虫占总PV较高&#xff0c;浪费资源 2.资源被批量抓走&#xff0c;丧失竞争力…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023