如何打开POSIX_MQUEUE

在POSIX（Portable Operating System Interface for uniX）系统中，消息队列（Message Queues, MQ）是一种用于进程间通信的数据结构。要打开一个POSIX消息队列，你需要以下几个步骤：

1. 首先，需要包含头文件`#include <msg.h>`，它定义了与消息队列操作相关的函数。

2. 定义队列标识符（key）。通常是一个整数，可以由应用程序选择，但建议保持唯一以便区分不同的队列。

3. 使用`mq_open()`函数打开队列。这个函数接受四个参数：
- `const char *name`: 消息队列的名字，如果不存在则会创建。
- `int flags`: 打开模式，如O_RDONLY（只读）、O_WRONLY（只写）或O_RDWR（读写），以及MQ_OPEN（首次打开）、MQ_CREATE（创建新队列）等标志。
- `mode_t permissions`: 权限模式，类似于文件权限，例如S_IRUSR（用户可读）+ S_IWUSR（用户可写）。
- `struct mq_attr FAR *msg_attr`: 可选的属性结构体，用于设置队列的最大大小、消息过期时间等。

示例代码片段：

#include <sys/msg.h>
#include <stdio.h>

int main() {
    const char *queue_name = "my_queue";
    int queue_key = 1234; // 一个特定的关键值
    struct mq_attr attr;
    memset(&attr, 0, sizeof(attr));
    attr.mq_maxmsg = 10; // 设置最大消息数
    attr.mq_msgsize = 100; // 设置每个消息的大小

    int msgqid = mq_open(queue_name, O_RDWR | O_CREAT, 0644, &attr);
    if (msgqid == -1) {
        perror("Error opening message queue");
        return 1;
    }

    printf("Message queue opened with id %d\n", msgqid);

    // ...接下来进行消息发送和接收...

    // 关闭队列时调用mq_close()
    if (mq_close(msgqid)) {
        perror("Error closing message queue");
    }

    return 0;
}