C++ socket udp多线程

在C++中，使用socket进行UDP（用户数据报协议）通信时，如果需要处理多个并发连接，通常会涉及到多线程技术。以下是创建一个多线程UDP服务器的基本步骤：

1. **包含头文件**：
- `#include <iostream>`
- `#include <boost/asio.hpp>` (C++17以后，也可以使用`<boost/asio/ip/udp.hpp>`)
- `#include <thread>`

2. **设置异步套接字**：
- 初始化Boost.Asio库的异步IO服务（如`std::shared_ptr<boost::asio::io_service> io_service = std::make_shared<boost::asio::io_service>();`)
- 创建一个UDP套接字 (`boost::asio::ip::udp::endpoint endpoint`, 设置端口等)

3. **绑定和接受函数**：
- 定义一个接收函数，通过`accept`操作监听并处理新的客户端连接（`void handle_new_connection(const boost::system::error_code& error, boost::asio::ip::udp::socket socket)`）

4. **创建多线程**：
- 使用`std::thread`启动一个新的线程来处理每个新连接，将接受函数作为参数(`io_service->run();` 在主线程中运行，其他线程通过`io_service->post(handle_new_connection)`异步调用).

5. **发送和接收数据**：
- 在子线程的处理函数中，读取客户端的数据，并根据需求进行响应。

6. **线程安全**：
- 如果有共享资源或状态需要维护，记得使用互斥锁（如`std::mutex`）保证同步。

// 示例代码片段
void handle_new_connection(const boost::system::error_code& error, boost::asio::ip::udp::socket socket) {
    if (!error) {
        // 在这里处理接收到的消息
        boost::array<char, 256> buffer;
        boost::system::error_code ignored_error;
        size_t bytes_received = socket.receive(buffer, boost::asio::message_size(ignored_error), ignored_error);
        // 发送回复...
    }
    // 关闭连接
    socket.close();
}

int main() {
    // ...设定套接字...
    std::thread worker_thread(handle_new_connection, io_service);
    io_service.run(); // 运行主IO服务

    // 等待所有连接关闭后退出
    worker_thread.join();

    return 0;
}