linuxC消息队列 mq_open() mq_send() mq_receive() mq

消息队列读和写两个进程不需要同时出现 (参考命名管道mkfifo)

Linux有POSIX和System V 两种消息队列

POSIX消息队列打开消息队列mq_open() 成功返回一个消息队列描述符

#include <fcntl.h>
#include <sys/stat.h>
#include <mqueue.h>mqd_t mq_open(const char* name, int oflag, mode_t mode, struct mq_attr* attr);

name: 由“/”开头、空字符"\0"结尾、中间最多包含255个不是“/”字符的字符串
oflag：访问此消息队列的模式，如O_RDONLY、O_CREAT(此时可加入O_EXCL)、OWRONLY、WRDWR
oflag值为O_CREAT需要后2个形参；mode为权限，与open()的mode一样；attr表示消息队列的性质，值为NULL表示新建消息队列为默认设置

attr结构体

struct mq_attr {long mq_flags; //值为O_NONBLOCK 表示马上返回不等待long mq_maxmsg; //包含的最大消息数量long mq_msgsize; //一条消息最大长度，单位字节long mq_curmsgs; //新建队列无意思 表示队列中消息队列数量
}

消息队列发送mq_send()、接收mq_receive() 信息

#include <mqueue.h>int mq_send(mqd_t mqdes, const char* msg_ptr, size_t msg_len, unsigned msg_prio);
ssize_t mq_receive(mqd_t mqdes, char* msg_ptr, size_t msg_len, unsigned* msg_prio);

mqdes: 消息队列描述符

msg_ptr: 发送/接收消息的缓冲区指针

msg_len: 发送消息长度 / 接收信息缓冲区长度

msg_prio: 消息的优先等级及用来存储消息优先等级的指针

mq_notify() 进程在获得新消息时得到通知，无需等待或轮询。消息队列特有

#include <mqueue.h>
//mqdes 消息队列描述符
int mq_notify(mqd_t mqdes, const struct sigevent* sevp);

sevp结构

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 withnotification */void       (*sigev_notify_function) (union sigval);/* Function used for threadnotification (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) */
};

linuxC消息队列 mq_open() mq_send() mq_receive() mq_notify()相关推荐

Linux IPC POSIX 消息队列
模型: #include<mqueue.h> #include <sys/stat.h> #include <fcntl.h> mq_open() //创建/获取消 ...
unix iorp等待队列_FreeRTOS+POSIX之消息队列API详解
FreeRTOS+POSIX概述可移植操作系统接口(Portable Operating System Interface,缩写为POSIX)是IEEE为要在各种UNIX操作系统上运行软件,而定义A ...
linux阻塞线程等待唤醒,linux – POSIX消息队列 – mq_send线程唤醒命令
有人可以向我解释消息队列如何处理唤醒多个线程在单个消息队列中被阻止? 我的情况是我有多个作者阻止完整的消息队列,每个发布优先级等于线程的消息优先.我想确保他们按优先顺序叫醒和发布, 但是我的应用 ...
linux进程间通信：POSIX 消息队列 ----异步通信
在上一篇中linux进程间通信:POSIX 消息队列我们知道消息队列中在消息个数达到了队列所能承载的上限,就会发生消息的写阻塞. 阻塞式的通信影响系统效率,进程之间在通信收到阻塞时并不能去做其他事情, ...
linux进程间通信：POSIX 消息队列
文章目录基本介绍相关编程接口编程实例消息队列通信实例消息队列属性设置实例基本介绍关于消息队列的基本介绍,前面在学习system V的消息队列时已经有过了解,linux进程间通信:syst ...
进程通信学习笔记(Posix消息队列)
在某个进程往一个队列写入消息之前,并不需要另外有个进程在该队列上等待消息的到达,这跟管道和FIFO是相反的,对于后两者来说,除非读出者已存在,否则先有写入者是没有意义的 1.mq_open.mq_cl ...
Linux的进程间通信-消息队列
Linux的进程间通信-消息队列微博ID:orroz 微信公众号:Linux系统技术前言 Linux系统给我们提供了一种可以发送格式化数据流的通信手段,这就是消息队列.使用消息队列无疑在某些场景的 ...
Linux进程间通信四 Posix 消息队列简介与示例
目录 1. Posix 消息队列简介 2. API接口 2.1 创建或打开消息队列 2.2 发送消息 2.3 接收消息 2.4 获取.设置消息队列属性 2.5 关闭消息队列 2.6 删除消息队列 2. ...
POSIX 消息队列基础知识复习，以及相关例程
1.1 Posix消息队列 1.1.1 消息队列的创建和删除 1.1.1.1 mq_open( ) #include<mqueue.h> mqd_tmq_ ...

linuxC消息队列 mq_open() mq_send() mq_receive() mq_notify()

linuxC消息队列 mq_open() mq_send() mq_receive() mq_notify()相关推荐

最新文章

热门文章