C++ 함수는 네트워크 프로그래밍에서 메시지 대기열을 어떻게 처리합니까?

boost::asio::io_service io_service;

// 创建消息队列
boost::asio::message_queue queue(io_service);

// 发送消息
queue.send(boost::asio::buffer(message));

// 接收消息
boost::array<char, 1024> buffer;
std::size_t len = queue.receive(boost::asio::buffer(buffer));

#include <boost/asio.hpp>

// 服务端
void server() {
    boost::asio::io_service io_service;
    boost::asio::message_queue queue(io_service);

    // 从队列接收消息
    for (;;) {
        boost::array<char, 1024> buffer;
        std::size_t len = queue.receive(boost::asio::buffer(buffer));

        // 处理接收到的消息
        // ...
    }
}

// 客户端
void client() {
    boost::asio::io_service io_service;
    boost::asio::message_queue queue(io_service);

    // 向队列发送消息
    queue.send(boost::asio::buffer("Hello, server!"));
}

int main() {
    server();
    client();

    return 0;
}