Linux 进程间通信采用消息队列 传输大数据量 c++ 例程

Linux 中的消息队列（Message Queue，MQ）是一种进程间通信（Inter-Process Communication，IPC）机制，特别适合于处理大数据量的场景，因为它允许生产者和消费者在不同的进程中异步交换数据，并且可以避免阻塞线程。

在 C++ 中，使用 `boost::interprocess` 库可以方便地操作 Linux 的消息队列。以下是一个简单的例子：

#include <boost/interprocess/ipc/mapped_file.hpp>
#include <boost/interprocess/message_queue.hpp>

// 创建一个消息队列
std::string queue_name = "my_queue";
boost::interprocess::message_queue mq(
    boost::interprocess::open_or_create,
    boost::interprocess::get_default_key(),
    boost::interprocess::read_write_mode,
    boost::interprocess::queue_size(10));

// 定义一个数据结构用于存储大块数据
struct LargeData {
    // ... 大数据结构体定义
};

// 生产者函数
void producer(LargeData data) {
    boost::interprocess::message_queue::size_type msg_size = sizeof(data);
    std::vector<char> buffer(msg_size);
    memcpy(buffer.data(), &data, msg_size);
    if (mq.send(buffer)) {
        std::cout << "Producer sent data." << std::endl;
    } else {
        std::cerr << "Producer failed to send data." << std::endl;
    }
}

// 消费者函数
void consumer() {
    boost::interprocess::message_queue::size_type max_msg_size = boost::interprocess::message_queue::maximum_message_size();
    std::vector<char> received(max_msg_size);
    if (mq.receive(received)) {
        LargeData data;  // 解析接收到的数据到 LargeData 对象
        // ... 对数据进行处理
        std::cout << "Consumer received and processed data." << std::endl;
    } else {
        std::cerr << "Consumer failed to receive data." << std::endl;
    }
}

int main() {
    LargeData large_data;
    // ... 初始化并填充大型数据

    producer(large_data);
    consumer();

    return 0;
}