【ARM-Linux篇】POSIX消息队列

System V消息队列POSIX 消息队列
主
要
函
数		#include <sys/msg.h>
int msgget(key_t key, int oflag)
int msgsnd(int msqid, const
void * ptr, size_t length, int flag)
ssize_t msgrcv (int msqid, void
*ptr, size_t length, long type, int
flag)
int msgctl(int msqid, int cmd,
struct msqid_ds *buf)		#include <mqueue.h>
mqd_t mq_open(const char *name, int oflag,mode_t mode, struct mq_attr attr );
int mq_close(mqd_t mqdes);//
int mq_unlink(const char *name);
int mq_getattr(mqd_t mqdes, struct mq_attr *attr);
int mq_setattr(mqd_t mqdes, struct mq_attr *attr,struct mq_attr *oattr);
int mq_send(mqd_t mqdes, const char *ptr, size_t len, unsigned int prio);
ssize_t mq_receive(mqd_t mqdes, char *ptr, size_t len, unsigned int *prio);
int mq_notify(mqd_t mqdes, const struct sigevent *notification);
基
本
用
法		1.创建或获取消息队列：使用msgget()函数来创建或获取一个消息队列。该函数接受一个键（key）和一个标志（flag）作为参数。如果键的值为IPC_PRIVATE或当前没有消息队列与给定键相关联，将会创建一个新的消息队列。标志位可以用来指定权限组合。
2. 往消息队列中放入消息：使用msgsnd()函数来往一个消息队列中放入一个消息。该函数接受四个参数，分别为消息队列标识符、指向消息的指针、消息的大小以及标志位。成功放入消息后，该函数返回0，否则返回-1并设置errno来表示错误原因。
3. 从消息队列中读取消息：使用msgrcv()函数来从一个消息队列中读取一个消息。该函数接受五个参数，分别为消息队列标识符、指向消息的指针、消息的最大大小、消息的类型以及标志位。成功读取消息后，该函数返回读取到的消息的大小，否则返回-1并设置errno来表示错误原
因。
4. 控制消息队列：使用msgctl()函数来对一个消息队列进行控制操
作，如删除、设置权限等。该函
数接受三个参数，分别为消息队
列标识符、操作命令以及一个可
选的参数。

1.创建或打开消息队列：使用mqd_t mq_open(const char *name,int oflag,mode_t mode,struct mq_attr*attr);函数来创建或打开一个消息队列。该函数接受队列名称、打开标志以及可选的权限和属性作为参数。如果队列不存在且指定了创建标志，将会创建一个新的消息队列。成功创建或打开后，函数返回一个
消息队列描述符（mqd_t）。
2. 发送消息：使用int mq_send(mqd_t mqdes,const char *msg_ptr,size_t msg_len,unsigned int msg_prio);函数来发送一个消息到指定的消息队列。该函数接受消息队列描述符、指向消息的指针以及消
息的大小作为参数。发送消息时，可以指定消息的优
先级，较高的优先级数值表示较高的优先级。成功发
送后，函数返回0，否则返回-1并设置errno来表示错
误原因。
3. 接收消息：使用ssize_t mq_receive(mqd_t
mqdes, char *mdg_ptr,size_t msg_len,unsigned int
*msg_prio);函数来从指定的消息队列中接收一个消息。该函数接受消息队列描述符、指向接收缓冲区的指针以及缓冲区的最大大小作为参数。接收消息时，可以选择按优先级接收，也可以选择非阻塞接收。成功接收后，函数返回接收到的消息的大小，否则返回-1并设置errno来表示错误原因。
4. 关闭消息队列：使用int mq_close(mqd_t mqdes);函数来关闭一个已打开的消息队列。该函数接受消息队列描述符作为参数。关闭消息队列后，相关的资源将被释放。
5. 删除消息队列：使用int mq_unlink(const char*name);函数来删除一个已存在的消息队列。该函数接受队列名称作为参数。删除一个消息队列将会移除与之关联的所有消息和状态.
2、3步可以改成下面的6、7、8步，支持异步通知:
6. 设置异步通知：使用int mq_notify(mqd_t
mqdes,const struct sigevent *notification);函数来注册一个进程以接收异步通知。该函数接受消息队列描述符、一个指向sigevent结构的指针以及一个通知标志作为参数。在sigevent结构中，可以设置当消息到达时要发送的信号或者要调用的回调函数。通过设置用int mq_notify(mqd_t mqdes,const struct
sigevent *notification);，当消息队列从空变为非空时，已注册的进程将收到一个信号或触发一个回调函数，以异步地通知该进程。

7. 发送消息：使用int mq_send(mqd_t mqdes,const char *msg_ptr,size_t msg_len,unsigned int  msg_prio);函数来发送一个消息到指定的消息队列。该函数接受消息队列描述符、指向消息的指针以及消息的大小作为参数。发送消息时，可以指定消息的优
先级，较高的优先级数值表示较高的优先级。成功发送后，函数返回0，否则返回-1并设置errno来表示错误原因。
8.处理异步通知：当有新消息到达时，已注册的进程将收到一个信号或触发一个回调函数。在信号处理函数或回调函数中，可以执行相关的操作来处理新到达的消息。例如，可以调用ssize_t mq_receive(mqd_t mqdes, char *mdg_ptr,size_t msg_len,unsigned int
*msg_prio);来接收并处理消息。

Notes:

1. mqd_t mq_open(const char *name, int oflag, mode_t mode, struct mq_attr *attr) 中oflag和mode 参数说明

•参数oflag：同int open(const char *pathname, int flags, mode_t mode);函数的的oflag类似有
O_RDONLY、O_RDWR， O_WRONLY，除此之外还有 O_CREAT、O_EXCL（如果 O_CREAT 指定，但name 不存在，就返回错误），O_NONBLOCK（以非阻塞方式打开消息队列，在正常情况下mq_receive和mq_send 函数会阻塞的地方，使用该标志打开的消息队列会返回 EAGAIN 错误）。
•参数mode：同int open(const char *pathname, int flags, mode_t mode);函数的mode参数，用于指定权限位， 比如0644权限

2. 关于 struct mq_attr属性结构体：

struct mq_attr
{
        long mq_flags;//阻塞标志， 0(阻塞)或O_NONBLOCK
        long mq_maxmsg;//最大消息数
        long mq_msgsize;//每个消息最大大小
        long mq_curmsgs;//当前消息数
};

3. mq_notiy函数的使用注意事项：

a. 注册撤销：当通知被发送给它的注册进程时，其注册会被撤销。这意味着，如果希望继续接收通知，进程必须再次调用 mq_notify 以重新注册。
b. 空队列与数据到来：消息机制触发条件是，在消息队列为空的情况下有数据到来才会触发。当消息队列不为空时，即使有新的数据到来也不会触发通知。
c. 阻塞与通知：只有当没有任何线程阻塞在该队列的 mq_receive 调用的前提下，通知才会发出。这意味着，如果有线程正在等待接收消息，通知可能不会被发送。 

4. struct sigevent和sigval_t sigev_val 的定义如下：

union sigval { /* Data passed with notification */
        int sival_int; /* Integer value */
        void *sival_ptr; /* Pointer value */
};
struct sigevent {
        int sigev_notify; /* Notification method */
        int sigev_signo; /* Notification signal */
        union sigval sigev_value;
                                /* Data passed with notification */
        void (*sigev_notify_function) (union sigval);
                                /* Function used for thread
                                notification (SIGEV_THREAD) */
        void *sigev_notify_attributes;
                                /* Attributes for notification thread
                                (SIGEV_THREAD) */
        pid_t sigev_notify_thread_id;
                                /* ID of thread to signal
                                (SIGEV_THREAD_ID); Linux-specific */

}; 

a. sigev_notify取值：
•SIGEV_NONE：这个值表示不需要任何通知。当sigev_notify被设置为这个值时，即使事件发生了，也不会有任何通知发送到进程。
•SIGEV_SIGNAL：事件发生时，将sigev_signo指定的信号发送给指定的进程；
•SIGEV_THREAD：事件发生时，内核会（在此进程内）以sigev_notify_attributes为线程属性创建一个线程，并让其执行sigev_notify_function，并以sigev_value为其参数
b. sigev_signo: 在sigev_notify=SIGEV_SIGNAL时使用，指定信号类别, 例如SIGUSR1、SIGUSR2 等
c.sigev_value: sigev_notify=SIGEV_SIGEV_THREAD时使用，作为sigev_notify_function的参数, 当发送信号时,这个值会传递给信号处理函数。 

示例代码1:使用阻塞方式读写 

#include <stdio.h>
#include <mqueue.h>
#include <pthread.h>
#include <string.h>
#include <errno.h>
#include <unistd.h>#if 0
mqd_t mq_open(const char *name, int oflag,mode_t mode, struct mq_attr attr );
int mq_close(mqd_t mqdes);
int mq_send(mqd_t mqdes, const char *ptr, size_tlen, unsigned int prio);
ssize_t mq_receive(mqd_t mqdes, char *ptr, size_tlen, unsigned int *prio);
int mq_unlink(const char *name);
struct mq_attr
{long mq_flags;//阻塞标志， 0(阻塞)或O_NONBLOCKlong mq_maxmsg;//最大消息数long mq_msgsize;//每个消息最大大小long mq_curmsgs;//当前消息数
};
#endif#define QUEQUE_NAME "/test_queue"
#define MESSAGE "mqueque,test!"void *sender_thread(void *arg)
{//发送消息mqd_t mqd = *(mqd_t *)arg;int send_size = -1;char message[] = MESSAGE;printf("sender thread message=%s,mqd=%d\n",message,mqd);send_size = mq_send(mqd,message,strlen(message)+1,0);if(-1 == send_size){if(errno == EAGAIN){printf("message queque is full!\n");}else{perror("mq_send");}}return NULL;        
}void *receiver_thread(void *arg)
{mqd_t mqd = *(mqd_t *)arg;ssize_t receiver_size = -1;//接收消息char buffer[256];printf("Receive thread start\n");receiver_size = mq_receive(mqd,buffer,sizeof(buffer),NULL);printf("receive thread message=%smqd=%d,receiver_size=%ld\n",buffer,mqd,receiver_size);return NULL;
}int main(int argc,char *argv[])
{pthread_t sender,receiver;//创建消息队列mqd_t mqd = -1;struct mq_attr attr;attr.mq_flags = 0;attr.mq_maxmsg = 10;attr.mq_msgsize = 256;attr.mq_curmsgs = 0;mqd = mq_open(QUEQUE_NAME,O_CREAT | O_RDWR,0666,&attr);if(mqd == (mqd_t)-1){perror("mq_open");return -1;}if(pthread_create(&sender,NULL,sender_thread,(void*)&mqd) != 0){perror("pthread_create sender");return -1;}if(pthread_create(&receiver,NULL,receiver_thread,(void*)&mqd) != 0){perror("pthread_create receiver");return -1;}pthread_join(sender,NULL);pthread_join(receiver,NULL);mq_close(mqd);//mq_unlink(QUEQUE_NAME);return 0;
}

  示例2： 使用mq_notify sigev_notify = SIGEV_THREAD异步通知的方式实现

#include <stdio.h>
#include <mqueue.h>
#include <pthread.h>
#include <string.h>
#include <errno.h>
#include <unistd.h>
#include <signal.h>
#include <stdlib.h>// 定义消息队列名称和要发送的消息内容
#define QUEQUE_NAME "/test_queue"
#define MESSAGE "mqueque,test!"void *sender_thread(void *arg)
{// 获取消息队列描述符mqd_t mqd = *(mqd_t *)arg;int send_size = -1;char message[] = MESSAGE;// 打印发送消息的信息printf("sender thread message=%s, mqd=%d\n", message, mqd);// 发送消息send_size = mq_send(mqd, message, strlen(message) + 1, 0);if (send_size == -1) {if (errno == EAGAIN) {printf("message queue is full!\n");} else {perror("mq_send");}}return NULL;
}void notify_thread(union sigval arg)
{// 获取消息队列描述符mqd_t mqd = *((mqd_t *)arg.sival_ptr);char buffer[256];ssize_t recv_size = -1;memset(buffer, 0, sizeof(buffer));printf("notify_thread start, mqd=%d\n", mqd);// 接收消息recv_size = mq_receive(mqd, buffer, sizeof(buffer), NULL);printf("notify_thread receive_size=%ld, buffer=%s\n", recv_size, buffer);if (recv_size == -1) {if (errno == EAGAIN) {printf("message queue is empty!\n");} else {perror("mq_receive");exit(1);}}// 重新注册通知struct sigevent sev;sev.sigev_notify = SIGEV_THREAD;sev.sigev_value.sival_ptr = arg.sival_ptr;sev.sigev_notify_function = notify_thread;if (mq_notify(mqd, &sev) == -1) {perror("mq_notify");exit(1);}
}int main(int argc, char *argv[])
{pthread_t sender;mqd_t mqd = -1;// 设置消息队列属性struct mq_attr attr;attr.mq_flags = 0;attr.mq_maxmsg = 10;attr.mq_msgsize = 256;attr.mq_curmsgs = 0;// 创建消息队列mqd = mq_open(QUEQUE_NAME, O_CREAT | O_RDWR, 0666, &attr);if (mqd == (mqd_t)-1) {perror("mq_open");return -1;}// 设置消息队列通知struct sigevent sev;sev.sigev_notify = SIGEV_THREAD;sev.sigev_value.sival_ptr = &mqd;sev.sigev_notify_function = notify_thread;if (mq_notify(mqd, &sev) == -1) {perror("mq_notify");mq_close(mqd);mq_unlink(QUEQUE_NAME);return -1;}// 创建发送消息的线程if (pthread_create(&sender, NULL, sender_thread, (void*)&mqd) != 0) {perror("pthread_create sender");mq_close(mqd);mq_unlink(QUEQUE_NAME);return -1;}// 等待发送线程结束pthread_join(sender, NULL);// 等待一段时间以接收消息sleep(5);// 关闭并删除消息队列mq_close(mqd);mq_unlink(QUEQUE_NAME);return 0;
}

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

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

相关文章

算法设计与分析期末复习题

算法设计与分析期末复习题

一&#xff1a;程序阅读分析题&#xff08;共40分&#xff09; 1.&#xff08;8分&#xff09;阅读“算法1”&#xff0c;分析算法1的功能、时间复杂度。 答案&#xff1a;经典的汉诺塔问题&#xff0c;其目标是将 n 个不同大小的盘子从柱子 A 移动到柱子 C&#xff0c;借助柱…
阅读更多...
停车场控制机系统哪家好？捷顺捷曜分体式车场控制机有哪些功能亮点？

停车场控制机系统哪家好？捷顺捷曜分体式车场控制机有哪些功能亮点？

停车场控制机为现代城市提供了许多便利和好处。首先&#xff0c;它能够自动记录车辆进出的时间&#xff0c;便于车主和管理人员进行费用计算。其次&#xff0c;通过车牌识别技术&#xff0c;提高了车辆进出的效率&#xff0c;减少了排队等待时间。此外&#xff0c;控制机还可以…
阅读更多...
商讯杂志商讯杂志社商讯编辑部2024年第10期目录

商讯杂志商讯杂志社商讯编辑部2024年第10期目录

案例分享 基于胜任素质的干部选拔和梯队建设体系探讨——以A区卫生健康系统为例 康文雁; 1-4 “家庭五险一金”对居民商业保险购买存在挤出效应——基于江苏省徐州、淮安、泰州三市的实证研究 李炳毅; 5-8 人口老龄化背景下促进徐州市经济高质量发展的探究 李艳秋;…
阅读更多...
Python学习笔记12：进阶篇(二)，类的继承与组合

Python学习笔记12：进阶篇(二)，类的继承与组合

类的继承 我们在编写一系列的类的时候&#xff0c;会发现这些类很相似&#xff0c;但是又有各自的特点和行为。在编写这些类的时候&#xff0c;我们可以把相同的部分抽象成一个基类&#xff0c;然后根据其他不同的特点和行为&#xff0c;抽象出子类&#xff0c;继承这个基类。…
阅读更多...
上海AI Lab推出8B模型，奥数成绩媲美GPT-4

上海AI Lab推出8B模型，奥数成绩媲美GPT-4

只用1/200的参数&#xff0c;就能让大模型拥有和GPT-4一样的数学能力&#xff1f; 复旦大学和上海AI实验室的研究团队刚刚研发出了一款具有超强数学能力的模型。 这款模型名为MCTSr&#xff0c;以Llama 3为基础&#xff0c;参数量只有8B&#xff0c;却在奥赛级别的题目上取得了…
阅读更多...
Nuxt快速学习开发 -- Nuxt3配置

Nuxt快速学习开发 -- Nuxt3配置

Nuxt配置 nuxt.config.ts文件位于 Nuxt 项目的根目录下&#xff0c;可以覆盖或扩展应用程序的行为 使用可组合项&#xff0c;这些变量会暴露给应用程序 //nuxt.config.ts import { fileURLToPath } from "url"; ​ export default defineNuxtConfig({alias: {//配置…
阅读更多...
Java线程池基本概念

Java线程池基本概念

全局和局部线程池 全局线程池 在Spring框架中&#xff0c;全局线程池如ThreadPoolTaskExecutor通常是作为Spring Bean存在的&#xff0c;它们的生命周期由Spring容器管理。当Spring容器关闭时&#xff0c;这些线程池也会被适当地清理和关闭。因此&#xff0c;开发者通常不需要手…
阅读更多...
DDD架构和微服务初步实现

DDD架构和微服务初步实现

本次记录的是微服务的初步认识和DDD架构的初步实现和思路&#xff0c;在之前的发布里&#xff0c;对Javaweb进行了一次小总结&#xff0c;还有一些东西&#xff0c;不去详细理解说明了&#xff0c;下面开始我对微服务的理解。 什么是微服务&#xff1f; 在刚刚开始学习的时候…
阅读更多...
Study--Oracle-03-数据库常规操作

Study--Oracle-03-数据库常规操作

一路走来&#xff0c;所有遇到的人&#xff0c;帮助过我的、伤害过我的都是朋友&#xff0c;没有一个是敌人。 一、oracle 版本及主要功能 二、数据安装完成后常用操作SQL 1、检查数据库监听状态 监听的常用命令 启动&#xff1a;[oracleoracle u01]$ lsnrctl stop 停止&am…
阅读更多...
2024信息系统、信号处理与通信技术国际会议（ICISPCT2024)

2024信息系统、信号处理与通信技术国际会议（ICISPCT2024)

2024信息系统、信号处理与通信技术国际会议&#xff08;ICISPCT2024) 会议简介 2024国际信息系统、信号处理与通信技术大会&#xff08;ICISPCT2024&#xff09;将在青岛隆重开幕。本次会议旨在汇聚全球信息系统、信号处理和通信技术领域的专家学者&#xff0c;共同探索行业…
阅读更多...
【记录46】【案例】echarts 柱状图

【记录46】【案例】echarts 柱状图

echarts环境4.1.0 <template><div id"threefour"></div> </template> <script> import * as echarts from "echarts" export default {name:"",components:{},data(){return {}},methods:{getdata(){var myChart…
阅读更多...
《平衡小车控制系统》电子设计大赛校赛感悟

《平衡小车控制系统》电子设计大赛校赛感悟

我们学校举行了一次电子设计大赛选拔赛&#xff0c;虽然我们在测试的时候全部都可以完成&#xff0c;最后考核的时候因为方案选择问题以及各种设计逻辑等原因没能成功晋级&#xff0c;但我能从这次备赛中学到很多东西&#xff0c;遂分享一下&#xff0c;与广大网友交流经验。&a…
阅读更多...
英伟达发布开源模型Nemotron-4 340B

英伟达发布开源模型Nemotron-4 340B

&#x1f680; 英伟达发布开源模型Nemotron-4 340B 摘要&#xff1a;英伟达最新发布的开源模型Nemotron-4 340B&#xff0c;可能彻底改变大语言模型&#xff08;LLM&#xff09;训练方式。该模型支持多种自然语言和编程语言&#xff0c;使用9万亿个token训练&#xff0c;高达9…
阅读更多...
Day 26：2288. 价格减免

Day 26：2288. 价格减免

Leetcode 2288. 价格减免 句子 是由若干个单词组成的字符串&#xff0c;单词之间用单个空格分隔&#xff0c;其中每个单词可以包含数字、小写字母、和美元符号 ‘$’ 。如果单词的形式为美元符号后跟着一个非负实数&#xff0c;那么这个单词就表示一个 价格 。 例如 “$100”、…
阅读更多...
Windows系统部署本地SQL_Server指引

Windows系统部署本地SQL_Server指引

Windows系统部署本地SQL_Server指引 此指引文档环境为Windows10系统&#xff0c;部署SQL_Server 2019为例&#xff0c;同系列系统软件安装步骤类似。 一、部署前准备&#xff1b; 下载好相关镜像文件&#xff1b;设备系统启动后&#xff0c;将不必要的软件停用&#xff0c;避…
阅读更多...
【Linux】shell——条件判断test，各种运算符，expr

【Linux】shell——条件判断test，各种运算符，expr

条件判断——test 真——0 假——1 test expression or [ expression ] 整数运算符 字符串运算符 -z 长度是否为0 -n 长度是否不为0 str1 str2 str1 ! str2 补 &&-->逻辑与&#xff0c;前面为真后面才会执行 || -->逻辑或&#xff0c;前面为假后面才…
阅读更多...
VirtFuzz：一款基于VirtIO的Linux内核模糊测试工具

VirtFuzz：一款基于VirtIO的Linux内核模糊测试工具

关于VirtFuzz VirtFuzz是一款功能强大的Linux内核模糊测试工具&#xff0c;该工具使用LibAFL构建&#xff0c;可以利用VirtIO向目标设备的内核子系统提供输入测试用例&#xff0c;广大研究人员可以使用该工具测试Linux内核的安全性。 工具要求 1、Rust&#xff1b; 2、修补的Q…
阅读更多...
线代的学习（矩阵）

线代的学习（矩阵）

1.矩阵的乘法 矩阵实现满足&#xff1a;内标相等 矩阵相乘之后的结果&#xff1a;前行后列 需要注意&#xff1a;1.矩阵的乘法不具有交换律&#xff1a;AB!BA 2.矩阵的乘法满足分配律&#xff1a;A(BC) AB AC 抽象逆矩阵求逆矩阵 方法1.凑定义法、 方法2.长除法 数字型矩阵…
阅读更多...
算法金 | 一个强大的算法模型：t-SNE ！！

算法金 | 一个强大的算法模型：t-SNE ！！

大侠幸会&#xff0c;在下全网同名「算法金」 0 基础转 AI 上岸&#xff0c;多个算法赛 Top 「日更万日&#xff0c;让更多人享受智能乐趣」 t-SNE&#xff08;t-Distributed Stochastic Neighbor Embedding&#xff09;是一种用于降维和数据可视化的非线性算法。它被广泛应用于…
阅读更多...
LeetCode 算法：合并两个有序链表 c++

LeetCode 算法：合并两个有序链表 c++

原题链接&#x1f517;&#xff1a;合并两个有序链表 难度&#xff1a;简单⭐️ 题目 将两个升序链表合并为一个新的 升序 链表并返回。新链表是通过拼接给定的两个链表的所有节点组成的。 示例 1&#xff1a; 输入&#xff1a;l1 [1,2,4], l2 [1,3,4] 输出&#xff1a;…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023