linux 进程 消息队列

// 发送方代码
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <fcntl.h>
#include <sys/stat.h>
#include <mqueue.h>

#define QUEUE_NAME "/test_queue"
#define MSG_CONTENT "Hello, World!"
#define MSG_PRIORITY 1

int main() {
    mqd_t mq;
    struct mq_attr attr;
    char buffer[100];

    // 设置队列属性
    attr.mq_flags = 0;
    attr.mq_maxmsg = 10;
    attr.mq_msgsize = 100;
    attr.mq_curmsgs = 0;

    // 创建队列
    mq = mq_open(QUEUE_NAME, O_CREAT | O_RDWR, 0644, &attr);
    if (mq == -1) {
        perror("mq_open");
        exit(1);
    }

    // 发送消息
    if (mq_send(mq, MSG_CONTENT, strlen(MSG_CONTENT) + 1, MSG_PRIORITY) == -1) {
        perror("mq_send");
        mq_close(mq);
        exit(1);
    }

    printf("Message sent: %s
", MSG_CONTENT);

    // 关闭队列
    mq_close(mq);
    return 0;
}

// 接收方代码
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <fcntl.h>
#include <sys/stat.h>
#include <mqueue.h>

#define QUEUE_NAME "/test_queue"

int main() {
    mqd_t mq;
    char buffer[100];

    // 打开队列
    mq = mq_open(QUEUE_NAME, O_RDONLY);
    if (mq == -1) {
        perror("mq_open");
        exit(1);
    }

    // 接收消息
    if (mq_receive(mq, buffer, 100, NULL) == -1)