C++在Linux中的消息队列使用

在Linux中，C++可以使用POSIX消息队列来处理进程间通信（IPC）

首先，需要包含相应的头文件：

#include <iostream>
#include <fcntl.h>
#include <sys/stat.h>
#include <mqueue.h>
#include <cstring>

接下来，创建一个消息队列：

mqd_t mq;
struct mq_attr attr;
attr.mq_flags = 0;
attr.mq_maxmsg = 10;
attr.mq_msgsize = 256;
attr.mq_curmsgs = 0;

mq = mq_open("/my_queue", O_CREAT | O_RDWR, 0644, &attr);
if (mq == (mqd_t)-1) {
    std::cerr << "Failed to create message queue" << std::endl;
    exit(1);
}

这里，mq_open函数用于创建或打开一个消息队列。第一个参数是队列的名称，第二个参数是标志位，第三个参数是权限，第四个参数是消息队列的属性指针。

发送消息到消息队列：

const char *message = "Hello, World!";
if (mq_send(mq, message, strlen(message) + 1, 0) == -1) {
    std::cerr << "Failed to send message" << std::endl;
    exit(1);
}

从消息队列接收消息：

char buffer[256];
unsigned int priority;
if (mq_receive(mq, buffer, 256, &priority) == -1) {
    std::cerr << "Failed to receive message" << std::endl;
    exit(1);
}

std::cout << "Received message: " << buffer << std::endl;

关闭消息队列：

if (mq_close(mq) == -1) {
    std::cerr << "Failed to close message queue" << std::endl;
    exit(1);
}

删除消息队列：

if (mq_unlink("/my_queue") == -1) {
    std::cerr << "Failed to delete message queue" << std::endl;
    exit(1);
}

将以上代码片段组合在一起，即可实现C++在Linux中使用消息队列的基本功能。注意，这里的示例代码没有进行错误处理和资源释放，实际应用中需要根据具体情况进行处理。