从网络队列中读取多个数据报

Question

我正在使用 Boost ASIO 和 UDP 将数据报从一个点传输到另一个点。

• 我的发件人每 500 毫秒发送一个数据报
• 我的接收器监听传入的数据，然后使用它。接收方使用async_receive_from接收数据

在某些情况下，接收器可能需要超过 500 毫秒的时间来处理数据。发送方不会停止发送数据。

当前行为：
发送的数据报在操作系统网络队列中排队。当我执行async_receive_from 时，我会得到下一个要使用的 UDP 数据报。

想要的行为：
发送的数据报在操作系统网络队列中排队。当我执行接收时，我得到了所有的数据报。那么队列是空的。我不知道队列中有多少数据报，也不知道它们的大小。

是否有可能最好使用 Boost::ASIO 和 async_receive_from 来实现这样的目标？如果没有：是否有其他库可以做这样的事情？

如果提供了另一种解决方案：我正在使用 Linux 和 Windows，如果您的解决方案是可移植的，那就太好了。

Answer 1

如果可能，最好的方法是使用多个线程。以下是我制作的一段类似的代码，本质上与您想要的类似。

void Session::handle_read(const boost::system::error_code& error, size_t bytes_transferred)
{
    static int count = 0;
    std::cout << "reading..." << std::endl;
    //std::string sClientIp = socket().remote_endpoint().address().to_string();
    if (!error)
    {
        // This is one place where you can put your thread call.
        try
        {
            // Will have async_read_some reading on the socket and call handle_read when something is transfered
            socket_.async_read_some(boost::asio::buffer(dataRx, max_length),
                boost::bind(&Session::handle_read, this,
                boost::asio::placeholders::error,
                boost::asio::placeholders::bytes_transferred));
        }
        catch(std::exception& e)
        {
            std::cout << "Read some failed: " << e  << std::endl;
        }
    }
    else if(error == boost::asio::error::eof)
    {
        std::cout << "There was an error in handle_read" << std::endl;
        delete this;
    }
    else
    {
        std::cout << "some error" << std::endl;
    }
}

在handle_read 内部，您需要一种方法来创建一个处理数据的线程，该线程将独立于主线程运行。如果对如何处理有任何困惑，请告诉我。