Linux C++多線程與消息隊列的集成

在Linux環境下，C++多線程與消息隊列的集成可以通過以下步驟實現：

1. 引入頭文件 首先，需要引入相關的頭文件。對于多線程，我們需要使用<thread>庫；對于消息隊列，我們需要使用<fcntl.h>、<sys/stat.h>和<mqueue.h>庫。

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

2. 創建消息隊列 使用mqueue_open()函數創建一個消息隊列。該函數需要傳遞隊列的名稱、權限標志和消息隊列的屬性。

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

mq = mqueue_open("/my_queue", O_CREAT | O_RDWR, 0644, &attr);
if (mq == (mqd_t)-1) {
    perror("mqueue_open");
    exit(1);
}

3. 發送消息到消息隊列 使用mq_send()函數將消息發送到消息隊列。該函數需要傳遞消息隊列的描述符、消息指針、消息長度和優先級。

char *message = "Hello, World!";
if (mq_send(mq, message, strlen(message) + 1, 0) == -1) {
    perror("mq_send");
    exit(1);
}

4. 從消息隊列接收消息 使用mq_receive()函數從消息隊列接收消息。該函數需要傳遞消息隊列的描述符、消息指針、消息長度和優先級。

char buffer[100];
unsigned int priority;
if (mq_receive(mq, buffer, sizeof(buffer), &priority) == -1) {
    perror("mq_receive");
    exit(1);
}

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

5. 關閉消息隊列 使用mq_close()函數關閉消息隊列。該函數需要傳遞消息隊列的描述符。

if (mq_close(mq) == -1) {
    perror("mq_close");
    exit(1);
}

6. 刪除消息隊列 使用mq_unlink()函數刪除消息隊列。該函數需要傳遞隊列的名稱。

if (mq_unlink("/my_queue") == -1) {
    perror("mq_unlink");
    exit(1);
}

7. 多線程示例 以下是一個簡單的多線程示例，其中一個線程負責發送消息到消息隊列，另一個線程負責從消息隊列接收消息。

void sender(mqd_t mq) {
    char *message = "Hello, World!";
    if (mq_send(mq, message, strlen(message) + 1, 0) == -1) {
        perror("mq_send");
        exit(1);
    }
}

void receiver(mqd_t mq) {
    char buffer[100];
    unsigned int priority;
    if (mq_receive(mq, buffer, sizeof(buffer), &priority) == -1) {
        perror("mq_receive");
        exit(1);
    }
    std::cout << "Received message: " << buffer << std::endl;
}

int main() {
    mqd_t mq;
    struct mq_attr attr;
    attr.mq_flags = 0;
    attr.mq_maxmsg = 10;
    attr.mq_msgsize = 100;
    attr.mq_curmsgs = 0;

    mq = mqueue_open("/my_queue", O_CREAT | O_RDWR, 0644, &attr);
    if (mq == (mqd_t)-1) {
        perror("mqueue_open");
        exit(1);
    }

    std::thread sender_thread(sender, mq);
    std::thread receiver_thread(receiver, mq);

    sender_thread.join();
    receiver_thread.join();

    if (mq_close(mq) == -1) {
        perror("mq_close");
        exit(1);
    }

    if (mq_unlink("/my_queue") == -1) {
        perror("mq_unlink");
        exit(1);
    }

    return 0;
}

這個示例展示了如何在Linux環境下使用C++多線程與消息隊列進行集成。你可以根據自己的需求對這個示例進行修改和擴展。