Boost ASIO套接字读取N个字节不多不少并等待它们到来或超时异常？

Question

基于 示例 创建一个简单的 TCP 服务器，但仍然不明白如何创建一个可以读取一定数量字节的套接字，如果没有足够的字节，则等待。我需要这不是异步操作。

#include <iostream>
#include <boost/asio.hpp>

#ifdef _WIN32
#include "Windows.h"
#endif

using namespace boost::asio::ip;
using namespace std;

int main(){
    int m_nPort = 12345;
    boost::asio::io_service io_service;
    tcp::acceptor acceptor(io_service, tcp::endpoint(tcp::v4(), m_nPort));

    cout << "Waiting for connection..." << endl;

    tcp::socket socket(io_service);
    acceptor.accept(socket);
    cout << "connection accepted" << endl;
    try
    {
        socket.send(boost::asio::buffer("Start sending me data\r\n"));
    }
    catch(exception &e)
    {
        cerr << e.what() << endl; //"The parameter is incorrect" exception
    }
}

如何接收 10000 个字节并执行直到所有 10000 个字节到达或 1000 毫秒超时并抛出异常？

Answer 1

Boost 1.47.0 刚刚为 basic_socket_iostream，即 expires_at 和 expires_from_now 方法。

这是一个基于您的代码片段的示例：

#include <iostream>
#include <boost/asio.hpp>

using namespace boost::asio::ip;
using namespace std;

int main(){
    int m_nPort = 12345;
    boost::asio::io_service io_service;
    tcp::acceptor acceptor(io_service, tcp::endpoint(tcp::v4(), m_nPort));

    cout << "Waiting for connection..." << endl;

    tcp::iostream stream;
    acceptor.accept(*stream.rdbuf());
    cout << "Connection accepted" << endl;
    try
    {
        stream << "Start sending me data\r\n";

        // Set timeout in 5 seconds from now
        stream.expires_from_now(boost::posix_time::seconds(5));

        // Try to read 12 bytes before timeout
        char buffer[12];
        stream.read(buffer, 12);

        // Print buffer if fully received
        if (stream) // false if read timed out or other error
        {
            cout.write(buffer, 12);
            cout << endl;
        }
    }
    catch(exception &e)
    {
        cerr << e.what() << endl;
    }
}

这个程序在 Linux 上适用于我。

请注意，我并不提倡您使用超时来代替带有截止时间计时器的异步操作。由您决定。我只是想表明 basic_socket_iostream 可以实现超时。

Answer 2

如何超时并抛出异常？

一般来说，在使用异步方法时，您只会遇到超时和可取消性。有一些特定于平台的方法可以解决此问题，这些方法已在之前的 问题。我强烈建议您使用异步方法进行研究，这将使理解逻辑变得更加容易。

也就是说，您可以通过使用下面的异步方法来呈现同步接口。这是在阻塞 TCP 客户端超时 由 Asio 库提供的示例。但请注意，由于其控制反转和 lambda 函数的使用，该示例并不完全简单（尽管有很好的注释）。我建议您在尝试此类操作之前直接研究使用异步方法。

如何接收10000字节？

使用async_read 免费功能，备注部分准确描述了您所需要的

备注

此重载相当于调用：

boost::asio::async_read(
    s、缓冲器、
    升压::asio::transfer_all(),
    处理程序）；

其中缓冲区大小为 10,000 字节。