c++udp多线程实例

在C++中，UDP（用户数据报协议）通常用于需要快速、不可靠的数据传输的应用场景，比如在线游戏或实时通讯。当涉及到多线程处理UDP数据包时，你可以创建一个单独的线程来监听和处理每个接收到的连接。下面是一个简单的多线程UDP服务器的例子：

#include <iostream>
#include <boost/asio.hpp> // 使用Boost.Asio库来简化网络编程

class UdpServer {
public:
    void start_server(int port) {
        io_service.run();
    }

private:
    boost::asio::io_service io_service;
    boost::asio::ip::udp::socket socket(io_service);
    std::thread server_thread;

    void handle_received(const boost::system::error_code& error, size_t bytes_transferred) {
        if (!error) {
            char buffer[1024];
            std::string message(buffer, bytes_transferred);
            std::cout << "Received: " << message << std::endl;
            // 这里可以添加对消息的处理逻辑，并在另一个线程中发送回复
            process_message(message);
        }
    }

    void process_message(const std::string& message) {
        // 创建一个新的线程来处理消息
        std::thread processing_thread(process_message_helper, message);
        processing_thread.detach(); // 防止主线程阻塞
    }

private:
    void process_message_helper(const std::string& message) {
        // 在这里编写处理消息的具体代码，例如保存到数据库或转发给其他服务等
    }
};

int main() {
    int port = 12345;
    UdpServer server;
    server.socket.open(boost::asio::ip::udp::v4());
    server.socket.bind({boost::asio::ip::udp::endpoint<boost::asio::ip::udp::v4>(boost::asio::ip::udp::v4(), port)});
    server.socket.set_option(boost::asio::ip::udp::socket::receive_buffer_size(65536)); // 设置接收缓冲区大小

    server.server_thread = std::thread(&UdpServer::start_server, &server, port);

    // 等待服务器启动
    while (not server.io_service.is_running()) {}

    // 开始接收并处理UDP数据
    server.socket.async_read_some(
        boost::asio::buffer(buffer, sizeof(buffer)),
        server.handle_received
    );

    return 0;
}