Posix消息队列使用总结

Posix在线文档：

The Single UNIX Specification, Version 2 (opengroup.org)

Linux系统中提供了两种不同接口的消息队列：

  1. POSIX消息队列。POSIX为可移植的操作系统接口。
  2. System V消息队列。System V 是 AT&T 的第一个商业UNIX版本(UNIX System III)的加强。

其中，POSIX消息队列可移植性较强，使用较广。

Linux系统中提供的消息队列一般应用于进行间通信，但也可以用于线程间通信。

本文介绍POSIX消息队列应用于线程间通信。

相关API

Linux内核提供了一系列函数来使用消息队列：

/*** @brief 创建消息队列实例** Detailed function description** @param[in] name: 消息队列名称* @param[in] oflag：根据传入标识来创建或者打开一个已创建的消息队列- O_CREAT: 创建一个消息队列- O_EXCL: 检查消息队列是否存在，一般与O_CREAT一起使用- O_CREAT|O_EXCL: 消息队列不存在则创建，已存在返回NULL- O_NONBLOCK: 非阻塞模式打开，消息队列不存在返回NULL- O_RDONLY: 只读模式打开- O_WRONLY: 只写模式打开- O_RDWR: 读写模式打开* @param[in] mode：访问权限* @param[in] attr：消息队列属性地址** @return 成功返回消息队列描述符，失败返回-1，错误码存于error中*/
mqd_t mq_open(const char *name, int oflag,  mode_t mode, struct mq_attr *attr);/*** @brief 无限阻塞方式接收消息** Detailed function description** @param[in] mqdes: 消息队列描述符* @param[in] msg_ptr：消息体缓冲区地址* @param[in] msg_len：消息体长度，长度必须大于等于消息属性设定的最大值* @param[in] msg_prio：消息优先级** @return 成功返回消息长度，失败返回-1，错误码存于error中*/
mqd_t mq_receive(mqd_t mqdes, char *msg_ptr, size_t msg_len, unsigned *msg_prio);/*** @brief 指定超时时间阻塞方式接收消息** Detailed function description** @param[in] mqdes: 消息队列描述符* @param[in] msg_ptr：消息体缓冲区地址* @param[in] msg_len：消息体长度，长度必须大于等于消息属性设定的最大值* @param[in] msg_prio：消息优先级* @param[in] abs_timeout：超时时间** @return 成功返回消息长度，失败返回-1，错误码存于error中*/
mqd_t mq_timedreceive(mqd_t mqdes, char *msg_ptr, size_t msg_len, unsigned *msg_prio, const struct timespec *abs_timeout);/*** @brief 无限阻塞方式发送消息** Detailed function description** @param[in] mqdes: 消息队列描述符* @param[in] msg_ptr：待发送消息体缓冲区地址* @param[in] msg_len：消息体长度* @param[in] msg_prio：消息优先级** @return 成功返回0，失败返回-1*/
mqd_t mq_send(mqd_t mqdes, const char *msg_ptr, size_t msg_len, unsigned msg_prio);/*** @brief 指定超时时间阻塞方式发送消息** Detailed function description** @param[in] mqdes: 消息队列描述符* @param[in] msg_ptr：待发送消息体缓冲区地址* @param[in] msg_len：消息体长度* @param[in] msg_prio：消息优先级* @param[in] abs_timeout：超时时间** @return 成功返回0，失败返回-1*/
mqd_t mq_timedsend(mqd_t mqdes, const char *msg_ptr, size_t msg_len, unsigned msg_prio, const struct timespec *abs_timeout);/*** @brief 关闭消息队列** Detailed function description** @param[in] mqdes: 消息队列描述符** @return 成功返回0，失败返回-1*/
mqd_t mq_close(mqd_t mqdes);/*** @brief 分离消息队列** Detailed function description** @param[in] name: 消息队列名称** @return 成功返回0，失败返回-1*/
mqd_t mq_unlink(const char *name);

消息队列的名称类似于设备文件，mq_open通过名称打开对应的消息队列，然后返回一个消息队列描述符，之后的操作都是引用返回的描述符，类似于打开文件时返回的文件描述符。

其实和文件的打开、读写、关闭都非常类似。

​POSIX消息队列允许进程以消息的形式交换数据。 消息队列是使用mq_open创建和打开的；此函数返回消息队列描述符(mqd_t)，该描述符用于在以后的调用中引用打开的消息队列。每个消息队列由/somename形式的名称标识，该名称由一个初始斜杠组成，后跟一个或多个字符(都不是斜杠)。通过将相同的名称传递给mq_open，两个进程可以在同一队列上进行操作。 使用mq_send和mq_receive在队列之间来回传送消息。当进程使用完队列后，可以使用mq_close关闭该队列，而当不再需要该队列时，可以使用mq_unlink将其删除。可以使用mq_getattr和mq_setattr检索和修改队列属性(在某些情况下)。进程可以使用mq_notify请求异步通知消息到达先前为空的队列。 ​

消息队列可以认为是一个链表。进程（线程）可以往里写消息，也可以从里面取出消息。一个进程可以往某个消息队列里写消息，然后终止，另一个进程随时可以从消息队列里取走这些消息。这里也说明了，消息队列具有随内核的持续性，也就是系统不重启，消息队列永久存在。

几个主要函数可进一步参考：

mq_open

MQ_OPEN - Linux手册页-之路教程 (onitroad.com)

mq_send

MQ_SEND - Linux手册页-之路教程 (onitroad.com)

mq_receive

MQ_RECEIVE - Linux手册页-之路教程 (onitroad.com)

mq_close

MQ_CLOSE - Linux手册页-之路教程 (onitroad.com)

相关头文件如下：

#include <fcntl.h>           /* For O_* constants */
#include <sys/stat.h>        /* For mode constants */
#include <mqueue.h>

注意事项

参考：

POSIX 消息队列函数(mq_open、mq_getattr、mq_send、mq_receive)示例_mqreceivetest-CSDN博客

关于消息队列mq_open的属性参数

指向attr的struct mq_attr字段指定队列允许的最大消息数和最大消息大小。此结构定义如下：

struct mq_attr {

    long mq_flags;       /* Flags (ignored for mq_open()) */

    long mq_maxmsg;      /* Max. # of messages on queue */

    long mq_msgsize;     /* Max. message size (bytes) */

    long mq_curmsgs;     /* # of messages currently in queue(ignored for mq_open()) */

};

mq_maxmsg指的是容纳的消息数也就是消息队列的缓冲大小，msgsize指的是每个消息的大小；mq_maxmsg貌似并没有那么重要，因为消息队列是以流的形式来发送和接收的。两个参数的乘积，就是消息队列的总容量。

调用mq_open()时仅使用mq_maxmsg和mq_msgsize字段；其余字段中的值将被忽略。

如果attr为NULL，则使用默认属性创建队列。

关于消息队列名称

资料中说消息队列名称要写斜杠/开头，但是我看有的程序里并没有，而是一个单纯的字符串，为啥？

经过测试，在Linux 2.6.18中，所创建的POSIX消息队列不会在文件系统中创建真正的路径名。且POSIX的名字只能以一个’/’开头，名字中不能包含其他的’/’。

比如，不符合的情况：


报错

对应的错误如下：

另外需要注意以下几点：

1、

mq_receive() 的第三个参数表示读取消息的长度，不能小于能写入队列中消息的最大大小，即一定要大于等于该队列的 mq_attr 结构中 mq_msgsize 的大小。也就是最少要读一个消息。

2、

消息的优先级：它是一个小于 MQ_PRIO_MAX 的数，数值越大，优先级越高。 POSIX 消息队列在调用 mq_receive 时总是返回队列中最高优先级的最早消息。如果消息不需要设定优先级，那么可以在 mq_send 是置 msg_prio 为 0， mq_receive 的 msg_prio 置为 NULL。因为mq_send的优先级是以变量的形式传递的，而mq_receive是以指针的形式传递的。

3、

默认情况下mq_send和mq_receive是阻塞进行调用，可以通过mq_setattr来设置为O_NONBLOCK，如：

struct mq_attr new_attr;

mq_getattr(mqID, &new_attr);//获取当前属性

new_attr.mq_flags = O_NONBLOCK;//设置为非阻塞

mq_setattr(mqID, &new_attr, NULL)//设置属性

4、

mq_getattr用于获取当前消息队列的属性，mq_setattr用于设置当前消息队列的属性。其中mq_setattr中的oldattr用于保存修改前的消息队列的属性，可以为空。

mq_setattr可以设置的属性只有mq_flags，用来设置或清除消息队列的非阻塞标志。newattr结构的其他属性被忽略。mq_maxmsg和mq_msgsize属性只能在创建消息队列时通过mq_open来设置。mq_open只会设置该两个属性，忽略另外两个属性。mq_curmsgs属性只能被获取而不能被设置。

5、

mq_send和mq_recevie的第二个参数，也就是数据指针，是char *类型的，需要时做个强转。

6、

使用POSIX消息队列API的程序必须使用cc -lrt进行编译，以链接到实时库librt。

gcc pthread_5.c -o obj -lpthread -lrt

Linux编译命令-pthread & -lpthread - 邗影 - 博客园 (cnblogs.com)

linux的各种自带库-lz -lrt -lm -lc都是什么库_lm是什么库-CSDN博客

7、

消息队列无需init初始化，只用在第一次mq_open打开时创建即可。

8、

Posix消息队列就是先进先出，但是可以通过优先级来让紧急数据插队。

使用示例

常规示例代码如下： 

#include <stdio.h>
#include <pthread.h>
#include <stdlib.h>
#include <unistd.h>
#include <semaphore.h>
#include <fcntl.h>           /* For O_* constants */
#include <sys/stat.h>        /* For mode constants */
#include <mqueue.h>
#include <errno.h>#define MQ_NAME "/thisIsOneMqName"static void *thread_fun1(void *param)
{mqd_t mqfd;struct mq_attr attr;int count;attr.mq_maxmsg = 1;attr.mq_msgsize = sizeof(int);mqfd = mq_open(MQ_NAME, O_WRONLY | O_CREAT, 0666, &attr);if(mqfd < 0){printf("mq_open errno is %d\n", errno);exit(-1);}while(1){count += 10;mq_send(mqfd, (char *)&count, sizeof(int), 0);}return NULL;
}static void *thread_fun2(void *param)
{mqd_t mqfd;int count;mqfd = mq_open(MQ_NAME, O_RDONLY);if(mqfd < 0){printf("mq_open errno is %d\n", errno);exit(-1);}while(1){mq_receive(mqfd, (char *)&count, sizeof(int), NULL);printf("count is %d\n", count);if(count == 100){exit(0);}}return NULL;
}int main(int argc, char *argv[])
{pthread_t tid1, tid2;int ret;ret = pthread_create(&tid1, NULL, thread_fun1, NULL);if (ret < 0){printf("ERROR; return code from pthread_create() is %d\n", ret);exit(-1);}ret = pthread_create(&tid2, NULL, thread_fun2, NULL);if (ret < 0){printf("ERROR; return code from pthread_create() is %d\n", ret);exit(-1);}pthread_exit(NULL);
}

更多待补充

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

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

相关文章

[Python人工智能] 四十六.PyTorch入门 (1)环境搭建、神经网络普及和Torch基础知识

[Python人工智能] 四十六.PyTorch入门 (1)环境搭建、神经网络普及和Torch基础知识

从本专栏开始，作者正式研究Python深度学习、神经网络及人工智能相关知识。前文讲解合如何利用keras和tensorflow构建基于注意力机制的CNN-BiLSTM-ATT-CRF模型，并实现中文实体识别研究。这篇文章将介绍PyTorch入门知识。前面我们的Python人工智能主要以TensorFlow和Keras为主，…
阅读更多...
【Linux】进程间通信_4

【Linux】进程间通信_4

文章目录 七、进程间通信1. 进程间通信分类systeam V共享内存消息队列信号量 未完待续 七、进程间通信 1. 进程间通信分类 systeam V共享内存 进程间通信的本质就是让不同进程看到同一份资源。而systeam V是通过让不同的进程经过页表映射到同一块内存空间&#xff08;操作系…
阅读更多...
LED显示屏中什么是静态驱动？什么是扫描驱动？两者的区别是什么？

LED显示屏中什么是静态驱动？什么是扫描驱动？两者的区别是什么？

随着科技的飞速发展&#xff0c;LED显示屏作为现代信息显示技术的重要组成部分&#xff0c;正以其独特的优势引领着显示行业的革新。近日&#xff0c;LED显示屏市场呈现出蓬勃的发展态势&#xff0c;技术创新不断推动行业向前发展&#xff0c;让LED显示屏无论是在商场的广告牌、…
阅读更多...
苏东坡传-读书笔记一

苏东坡传-读书笔记一

太守的官衙位于杭州中心&#xff0c;但是苏东坡却喜欢在较为富有诗意的地方办公。他往往在葛岭下面有十三间房子的寿星院办公&#xff0c;因为那里风光如画。看公文不在寒碧轩&#xff0c;就在雨奇堂。我们记得雨奇堂是从苏东坡西湖诗“山色空濛雨亦奇”而得名的。在这里&#…
阅读更多...
04-Shell编程之正则表达式与文本处理器

04-Shell编程之正则表达式与文本处理器

4.1 正则表达式 4.1.1正则表达式概述 1.正则表达式的定义 正则表达式又称正规表达式&#xff0c;常规表达式。在代码中常简写为regex&#xff0c;regexp&#xff0c;或RE。正则表达式是使用一个字符来描述&#xff0c;匹配一系列符合某个句法规则的字符串&#xff0c;简单的…
阅读更多...
【现代操作系统】什么是操作系统

【现代操作系统】什么是操作系统

1.前言 现代计算机系统由一个或多个处理器、主存、磁盘、打印机、键盘、鼠标、显示器、网络接口以及各种其他输入/输出设备组成。一般而言&#xff0c;现代计算机系统是一个复杂的系统。如果每位应用程序员都不得不掌握系统的所有细节&#xff0c;那就不可能再编写代码了。而且…
阅读更多...
音视频入门基础：H.264专题（5）——FFmpeg源码中 解析NALU Header的函数分析

音视频入门基础：H.264专题（5）——FFmpeg源码中 解析NALU Header的函数分析

音视频入门基础&#xff1a;H.264专题系列文章&#xff1a; 音视频入门基础&#xff1a;H.264专题&#xff08;1&#xff09;——H.264官方文档下载 音视频入门基础&#xff1a;H.264专题&#xff08;2&#xff09;——使用FFmpeg命令生成H.264裸流文件 音视频入门基础&…
阅读更多...
SpringBoot-在配置文件中使用Profile

SpringBoot-在配置文件中使用Profile

Profile&#xff0c;译为“配置文件” 在这里的Spring Boot也是一样&#xff0c;我们可以配置很多个Profile&#xff0c;每个Profile都对应一整个完整的全局配置&#xff0c;激活哪个&#xff0c;那个对应的全局配置就生效&#xff0c;具体的配置&#xff1a; 1、properties格…
阅读更多...
漏洞挖掘 | 记一次edusrc--轻松拿下中危信息泄露

漏洞挖掘 | 记一次edusrc--轻松拿下中危信息泄露

1.前言 也是一次漏洞挖掘的思路分享 上次我们讲过了关于小程序方面的一些小思路&#xff0c;即关于抓包更改id号造成的一个信息泄露&#xff0c;但是在小程序上的信息泄露很难涉及到公民三要素这是一个痛点&#xff0c;今天就来分享一下一次edu挖掘时挖到的一个涉及公民三要素…
阅读更多...
【讲师招募】PowerData 2024数字经济开源行

【讲师招募】PowerData 2024数字经济开源行

【讲师招募】PowerData 2024数字经济开源行 活动信息讲师招募往期活动回顾 活动信息 2023&#xff0c;社区经过一年的发展&#xff0c;凝聚起了一批热爱数据、热爱开源的伙伴。 2024&#xff0c;社区计划在全国十个城市举办"数字经济-城市开源行"活动&#xff0c;连…
阅读更多...
2024年最新中级会计职称考试题库。

2024年最新中级会计职称考试题库。

46.甲将一汇票背书转让给乙&#xff0c;但该汇票上未记载乙的名称。其后&#xff0c;乙在该汇票被背书人栏内记载了自己的名称。根据《票据法》的规定&#xff0c;下列有关该汇票背书与记载效力的表述中&#xff0c;正确的是&#xff08;&#xff09;。 A.甲的背书无效&#x…
阅读更多...
Qt案例-ApplicationExamples-Calqlatr

Qt案例-ApplicationExamples-Calqlatr

项目 一个Qt Quick应用程序设计的横向和纵向设备&#xff0c;使用自定义组件&#xff0c;响应式布局和JavaScript的应用程序逻辑。 项目路径&#xff1a; Qt\Examples\Qt-6.7.1\demos 环境&#xff1a;Qt6.7.1 MSVC 2019 64位 项目目录&#xff1a; calqlatr--CMakeList.txt…
阅读更多...
三、用户中心项目笔记----后端多环境实战+原始部署

三、用户中心项目笔记----后端多环境实战+原始部署

后端多环境主要是修改&#xff1a; 依赖的环境地址 数据库地址 缓存地址 消息队列地址 项目端口号 服务器配置 后端怎么去区分不同的环境&#xff1f; 我们后端的SpringBoot项目&#xff0c;通过application.yml添加不同后缀来区分配置文件 application.yml就是公共的配置&a…
阅读更多...
Sam Altman：从少儿奇才到OpenAI掌舵人

Sam Altman：从少儿奇才到OpenAI掌舵人

自2022年底发布了ChatGPT以来&#xff0c;OpenAI及其首席执行官Sam Altman迅速成为科技界的焦点人物。Altman的崛起并非偶然&#xff0c;而是长期以来不断追求权力和创新的结果。本文将回顾Altman的成长历程&#xff0c;探索他如何一步步走向OpenAI的顶峰。 童年与教育背景 S…
阅读更多...
乌班图Ubuntu 24.04初始化MySQL报错error while loading shared libraries: libaio.so.1

乌班图Ubuntu 24.04初始化MySQL报错error while loading shared libraries: libaio.so.1

由于乌班图24.04 LTS已经发布了&#xff0c;因此准备新业务逐步往这上面迁移&#xff0c;毕竟支持有效期比22.04更长 准备在24.04上进行MySQL的初始化&#xff0c;因为习惯自定义安装存储目录&#xff0c;所以使用mysql-8.0.37-linux-glibc2.28-x86_64.tar.xz这个最新的二进制版…
阅读更多...
7款三维地球软件/框架:Google Earth SkylineGlobe,Cesium等

7款三维地球软件/框架:Google Earth SkylineGlobe,Cesium等

可视化大屏已经不满足于2D和3D展示了&#xff0c;开始向着星辰大海迈进了&#xff0c;本文介绍7款三维地球软件/开发框架&#xff0c;带各位老铁入个门。 1. Google Earth: 大名鼎鼎&#xff0c;Google Earth 是由 Google 开发的一款免费的虚拟地球软件。它提供了全球范围内的…
阅读更多...
【自然语言处理系列】手动安装和测试Spacy中en_core_web_sm模型的详细教程

【自然语言处理系列】手动安装和测试Spacy中en_core_web_sm模型的详细教程

摘要&#xff1a;本教程旨在为自然语言处理&#xff08;NLP&#xff09;初学者提供一个详细的指南&#xff0c;用于手动安装流行的NLP库Spacy及其英语模型en_core_web_sm。文章将逐步指导您如何安装Spacy库、查看其版本&#xff0c;确定并下载适合的en_core_web_sm模型版本&…
阅读更多...
HarmonyOS应用开发——Hello World

HarmonyOS应用开发——Hello World

下载 HUAWEI DevEco Studio: https://developer.harmonyos.com/cn/develop/deveco-studio/#download 同意&#xff0c;进入配置页面&#xff1a; 配置下载源以及本地存放路径&#xff0c;包括nodejs和ohpm: 配置鸿蒙SDK路径&#xff1a; 接受协议&#xff1a; 确认无误后&#…
阅读更多...
＜Linux＞ 缓冲区谁维护？

＜Linux＞ 缓冲区谁维护？

缓冲区是谁提供的&#xff1f; 来看一段代码 #include <stdio.h> #include <unistd.h> #include <stdlib.h> #include <string.h> int main() {const char *str1 "a";printf("%s", str1);const char *str2 "b";writ…
阅读更多...
C++并发之阻塞队列(block,queue)

C++并发之阻塞队列(block,queue)

目录 1 概述2 实现3 测试3 运行 1 概述 最近研究了C11的并发编程的线程/互斥/锁/条件变量&#xff0c;利用互斥/锁/条件变量实现一个支持多线程并发的阻塞队列&#xff0c;队列大小没有限制。 阻塞队列是一个模板类&#xff0c;有两个模块参数&#xff0c;参数1是元素类型&…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023