typedef int mqd_t; 
//实质上是 int 类型的别名。

/**
* @brief 消息队列的属性信息
* mq_flags 标记，对于 mq_open，忽略它，因为这个标记是通过前者的调用传递的
* mq_maxmgs 队列可以容纳的消息的最大数量
* mq_msgsize 单条消息的最大允许大小，以字节为单位
* mq_curmsgs 当前队列中的消息数量，对于 mq_open，忽略它
*/
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()) */
};

struct timespec {  
    time_t tv_sec;  // 秒  
    long   tv_nsec; // 纳秒  
};

#include <mqueue.h>  
#include <fcntl.h>  
#include <sys/stat.h>  
/**
* @brief 创建或打开一个已存在的 POSIX 消息队列，消息队列是通过名称唯一标识的。
 *
* @param name 消息队列的名称
* 命名规则：必须是以正斜杠/开头，以\0 结尾的字符串，中间可以包含若干字符，但
不能有正斜杠
* @param oflag 指定消息队列的控制权限，必须也只能包含以下三者之一
* O_RDONLY 打开的消息队列只用于接收消息
* O_WRONLY 打开的消息队列只用于发送消息
* O_RDWR 打开的消息队列可以用于收发消息
* 可以与以下选项中的 0 至多个或操作之后作为 oflag
* O_CLOEXEC 设置 close-on-exec 标记，这个标记表示执行 exec 时关闭文件描述符
* O_CREAT 当文件描述符不存在时创建它，如果指定了这一标记，需要额外提供 mode
和 attr 参数
* O_EXCL 创建一个当前进程独占的消息队列，要同时指定 O_CREAT，要求创建的消息
队列不存在，否则将会失败，并提示错误 EEXIST
* O_NONBLOCK 以非阻塞模式打开消息队列，如果设置了这个选项，在默认情况下收发
消息发生阻塞时，会转而失败，并提示错误 EAGAIN
* @param mode 每个消息队列在 mqueue 文件系统对应一个文件，mode 是用来指定消息
队列对应文件的权限的
* @param attr 属性信息，如果为 NULL，则队列以默认属性创建
* @return mqd_t 成功则返回消息队列描述符，失败则返回(mqd_t)-1，同时设置
errno 以指明错误原因
*/
mqd_t mq_open(const char *name, int oflag, mode_t mode, struct mq_attr *attr);

/**
* @brief 当 oflag 没有包含 O_CREAT 时方可调用
 *
* @param name 同上
* @param oflag 同上
* @return mqd_t 同上
*/
mqd_t mq_open(const char *name, int oflag);

#include <time.h>
#include <mqueue.h>
/**
* @brief 将 msg_ptr 指向的消息追加到消息队列描述符 mqdes 指向的消息队列的尾部。
如果消息队列已满，默认情况下，调用阻塞直至有充足的空间允许新的消息入队，或者达
到 abs_timeout 指定的等待时间节点，或者调用被信号处理函数打断。需要注意的是，
正如上文提到的，如果在 mq_open 时指定了 O_NONBLOCK 标记，则转而失败，并返回错误
EAGAIN。
* 
* @param mqdes 消息队列描述符
* @param msg_ptr 指向消息的指针
* @param msg_len msg_ptr 指向的消息长度，不能超过队列的 mq_msgsize 属性指定
的队列最大容量，长度为 0 的消息是被允许的
* @param msg_prio 一个非负整数，指定了消息的优先级，消息队列中的数据是按照优
先级降序排列的，如果新旧消息的优先级相同，则新的消息排在后面。
* @param abs_timeout 指向 struct timespec 类型的对象，指定了阻塞等待的最晚
时间。如果消息队列已满，且 abs_timeout 指定的时间节点已过期，则调用立即返回。
* @return int 成功返回 0，失败返回-1，同时设置 errno 以指明错误原因。
*/
int mq_timedsend(mqd_t mqdes, const char *msg_ptr, size_t msg_len, 
unsigned int msg_prio, const struct timespec *abs_timeout);

#include <time.h>
#include <mqueue.h>
/**
* @brief 从消息队列中取走最早入队且权限最高的消息，将其放入 msg_ptr 指向的缓
存中。如果消息队列为空，默认情况下调用阻塞，此时的行为与 mq_timedsend 同理。
* 
* @param mqdes 消息队列描述符
* @param msg_ptr 接收消息的缓存
* @param msg_len msg_ptr 指向的缓存区的大小，必须大于等于 mq_msgsize 属性指
定的队列单条消息最大字节数
* @param msg_prio 如果不为 NULL，则用于接收接收到的消息的优先级
* @param abs_timeout 阻塞时等待的最晚时间节点，同 mq_timedsend
* @return ssize_t 成功则返回接收到的消息的字节数，失败返回-1，并设置 errno
指明错误原因
*/
ssize_t mq_timedreceive(mqd_t mqdes, char *msg_ptr, size_t msg_len, unsigned int *msg_prio, const struct timespec *abs_timeout);

#include <mqueue.h>
/**
* @brief 清除 name 对应的消息队列，mqueue 文件系统中的对应文件被立即清除。消
息队列本身的清除必须等待所有指向该消息队列的描述符全部关闭之后才会发生。
* 
* @param name 消息队列名称
* @return int 成功返回 0，失败返回-1，并设置 errno 指明错误原因
*/
int mq_unlink(const char *name);

#include <time.h>
/**
* @brief 获取以 struct timespec 形式表示的 clockid 指定的时钟
* 
* @param clockid 特定时钟的标识符，常用的是 CLOCK_REALTIME，表示当前真实时
间的时钟
* @param tp 用于接收时间信息的缓存
* @return int 成功返回 0，失败返回-1，同时设置 errno 以指明错误原因
*/
int clock_gettime(clockid_t clockid, struct timespec *tp);

#include <time.h>
#include <mqueue.h>
#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <string.h>
int main(int agrc,char *argv[]){
    //设置消息属性
    struct mq_attr atter;
    atter.mq_maxmsg=10;
    atter.mq_msgsize=100;
    atter.mq_flags=0;
    atter.mq_curmsgs=0;

    //设置消息路径
    char *mq_name="/producer_mq";

    //创建消息队列
    mqd_t mqd=mq_open(mq_name,O_WRONLY | O_CREAT,0664,&atter);
    if(mqd==-1){
        perror("mq_open error");
        exit(EXIT_FAILURE);
    }

    char buffer[100];

    //创建时间结构体
    struct timespec time_info;

    while (1){
        memset(buffer,0,100);//清空缓冲区
        //读取输入
        ssize_t readCout=read(STDIN_FILENO,buffer,sizeof(buffer));
        //报错
        if (readCout==-1){
            perror("read error");
            continue;
        } else if(readCout==0){
            //ctrl+d 停止发送消息
            printf("EOF,exit\n");
            char eof = EOF;
            ssize_t sendRes=mq_timedsend(mqd,&eof,1,0,&time_info);
            if (sendRes==-1){
                perror("mq_timedsend error");
            }
            break;
        }
        int sendRes=mq_timedsend(mqd,buffer,strlen(buffer),0,&time_info);
        if (sendRes==-1){
            perror("mq_timedsend error");
        }
        printf("消息发送成功\n");
    }
    //关闭消息队列
    mq_close(mqd);
    return 0;
}

#include <time.h>
#include <mqueue.h>
#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <string.h>
using namespace std;
int main(int agrc,char *argv[]){
    //设置消息属性
    struct mq_attr atter;
    atter.mq_maxmsg=10;
    atter.mq_msgsize=100;
    atter.mq_flags=0;
    atter.mq_curmsgs=0;

    //设置消息路径
    char *mq_name="/producer_mq";

    //创建消息队列
    mqd_t mqd=mq_open(mq_name,O_RDONLY | O_CREAT,0664,&atter);
    if(mqd==-1){
        perror("mq_open error");
        exit(EXIT_FAILURE);
    }

    char buffer[100];

    //创建时间结构体
    struct timespec time_info;

    while (1){
        memset(buffer,0,100);//清空缓冲区
        clock_gettime(CLOCK_REALTIME,&time_info);
        time_info.tv_sec+=5;
        //读取消息队列
        ssize_t receiveRes= mq_timedreceive(mqd,buffer,sizeof(buffer),0,&time_info);
        //报错
        if (receiveRes==-1){
            perror("mq_timedreceive error");
            continue;
        }
        if(buffer[0]==EOF){
            printf("接收到EOF,退出\n");
            break;
        }else{
            printf("接收到生产者消息:%s\n",buffer);
        }
        printf("消息接收成功\n");
    }
    //关闭消息队列
    close(mqd);

    //删除消息队列
    mq_unlink(mq_name);
    return 0;
}