c++ - Boost套接字在断开连接时不会抛出EOF

Question

我正在使用 Boost 库为我的一个 C++ 项目编写一个简单的下载服务。我想要的是在下载时如果我的连接中断，我应该停止下载。我读过不同的地方，当连接断开时套接字返回 EOF 错误，Boost 套接字也是如此。但我的问题是，当连接断开时，boost socket 不会抛出 EOF，而是保持连接状态，一旦连接恢复，它就会从停止的地方恢复下载。我不想恢复，我想退出，这样我就可以自己恢复了。问题是当连接断开时，为什么 boost socket 没有抛出 EOF 错误。以下是我的示例代码。我也尝试过使用异步实现，我也尝试过使用 socket.read_some 函数但行为相同。

std::string responseString = "";

try {
    // === Send HTTP Request to get Proxy End Point
    std::string apiPath = "/qtproject/archive/qt/4.0/" + filename;
    boost::asio::io_service io_service;

    // Get a list of endpoints corrosponding to the server name
    tcp::resolver resolver(io_service);
    tcp::resolver::query query(serverip, serverport);
    tcp::resolver::iterator endpoint_iterator = resolver.resolve(query);

    // Try each endpoint untill we successfully establish a connection.
    tcp::socket socket(io_service);
    boost::asio::connect(socket, endpoint_iterator);

    boost::system::error_code error = boost::asio::error::host_not_found;
    boost::asio::streambuf request;
    std::ostream request_stream(&request);
    request_stream << "GET " << apiPath << " HTTP/1.0\r\n";
    request_stream << "Host: " << serverip << "\r\n";
    request_stream << "Accept: */*\r\n";
    request_stream << "Connection: close\r\n\r\n";

    // Send the request
    boost::asio::write(socket, request);

    // === Read Server Response
    boost::asio::streambuf response;
    boost::asio::read_until(socket, response, "\r\n");

    // Check that response is OK.
    std::istream response_stream(&response);
    std::string http_version;
    response_stream >> http_version;
    unsigned int status_code;
    response_stream >> status_code;
    std::string status_message;
    std::getline(response_stream, status_message);
    if (!response_stream || http_version.substr(0, 5) != "HTTP/") {
        std::cout << " Bad Server Response " << std::endl;
    }
    if (status_code != 200) {
        std::cout << "Bad Status Code = " << status_code << std::endl;
    }
    // Read the response headers, which are terminated by a blank line.
    //boost::asio::read_until(socket, response, "\r\n\r\n");
    //boost::system::error_code error; //boost::asio::buffer(data, sizeof data)
    unsigned char data[1024];
    socket.read_some(boost::asio::buffer(data, sizeof(data)), error);

    // Process the response headers.
    std::string header;
    while (std::getline(response_stream, header) && header != "\r");

    ofstream image;
    std::string filepath = "/home/farshad/TBD/" + filename;
    image.open(filepath.c_str());

    // Read until EOF, writing data to output as we go.
    int downloadedSize = 0;
    int readSize = 0;
    while ( (readSize = socket.read_some(boost::asio::buffer(data, sizeof(data)), error)) )
    {
            // When the connection is broken it keeps in this while loop, 
            // where I am expecting it to throw EOF error. Once connection is back, 
            // it resumes from the same while loop.
        downloadedSize += readSize;
        std::cout << "Data Read = " << downloadedSize <<  " Bytes\n";
        //memset(data, 0x0, sizeof(data));
        //image << &response;
        //std::cout << "Downloaded = " << (downloadedSize) << " Bytes\n";
    }

    //std::cout << "File Size = " << image.gcount() << std::endl;
    image.close();
    if (error != boost::asio::error::eof)
      throw boost::system::system_error(error);
    else if ( error == boost::asio::error::eof  ) {
        std::cout << "End of file approached";
        throw boost::system::system_error(error);
    }
}
catch ( std::exception& e)
{
    std::cout << "Exception: " << e.what() << std::endl;
}
catch ( ... )
{
    std::cout << "HURRAY: We got error" << std::endl;
}

更新断线自然是有人拔网线，或者是ISP导致的网络连接断开。

Answer 1

总结:按设计工作。 HTTP 在应用程序级别需要超时。

当数据包超时时连接中断。在尝试传输之前，无法检测到电缆已断开的事实。如果网络断开但在下一次传输尝试之前再次连接，则连接不会断开，因为它适用于所有传输并且没有理由认为它已断开。

当有 传输且网络断开连接时，连接仍可能需要几分钟才能断开，因为超时时间相当长，因为网络不 promise 任何特定性能。因此，如果您断开电缆连接，但在服务器超时之前再次连接，传输将继续。因为故障是暂时的，而 TCP 就是为处理这些故障而设计的。这是必须的，因为即使一切正常，数据包偶尔也会丢失。

这仍然只适用于传输端。接收端不会检测到连接断开。当您断开网络连接时并保持断开状态，服务器可能会在几分钟后得出连接断开的结论。但它不能告诉客户端，客户端没有传输，所以它找不到自己。因此，客户端将一直坐在那里等待数据永远。它不会再收到任何数据，因为服务器放弃了，但除非它尝试写入，否则它不会发现，但它没有。

因此你必须有计时器，如果你在一段时间内没有收到更多数据(通常超时大约为 5-10 分钟)，你必须关闭连接并自己声明错误。计时器应在每个收到的 block 中重置，因为传输可能需要比超时时间更长的时间。

请注意，上面没有一个点说明任何关于 boost 的内容。这些是 TCP/IP 的属性，其行为对于它的任何接口(interface)和它的任何实现都是相同的。另请注意，TCP/IP 有一个“keepalive”选项，它会导致系统(自动，无需您进一步干预)定期发送空数据包以检查连接是否断开，使用该选项您将在读取时收到 eof。但是，该选项不适用于 HTTP。它通常用于长时间保持连接并且可能长时间没有流量的协议(protocol)，如 imap 或 ssh，但对于 HTTP，接收超时是首选解决方案。