具有boost::beast的流HTTP的异步处理

Question

我正在实现一个客户机，它访问一个REST端点，然后开始处理一个SSE流并在事件发生时监视它们。为此，我使用Boost：：BeanVersion124withBoost 1.63，并试图使用async_read_some递增地读取响应的主体。

到目前为止，这是我的代码：

namespace http = boost::beast::http;

http::response_parser<http::string_body> sse_client::m_parser;
http::response<http::string_body> sse_client::m_response;
boost::beast::flat_buffer m_buffer;

void sse_client::monitor_sse()
{
    http::request<http::empty_body> req{http::verb::get, m_target, 11};
    req.set(http::field::host, m_host);
    req.set(http::field::user_agent, BOOST_BEAST_VERSION_STRING);
    req.set(http::field::accept, "text/event-stream");
    http::async_write(m_socket, req,
            std::bind(
                &sse_client::process_sse,
                shared_from_this(),
                std::placeholders::_1,
                std::placeholders::_2));
}

void sse_client::process_sse(boost::system::error_code ec, std::size_t byte_count)
{
    http::read_header(m_socket, m_buffer, m_parser);
    http::async_read_some(m_socket, m_buffer, m_parser,
            std::bind(
                &sse_client::read_event,
                shared_from_this(),
                std::placeholders::_1));
}

void sse_client::read_event(boost::system::error_code ec)
{
    // TODO: process event
    http::async_read_some(m_socket, m_buffer, m_parser,
            std::bind(
                &sse_client::read_event,
                shared_from_this(),
                std::placeholders::_1));
}

我的问题是：

1. 对于这个特定的用例，这是正确的方法吗？
2. 在response_parser和response中是否有比http::string_body更合适的类型？
3. 当调用read_event处理程序时，它如何访问async_read_some检索的内容？应该从缓冲器里拿出来吗？

Answer 1

我先回答你的问题，然后再解释。

1. 是的，您希望读取头部，然后调用read_some (或read，见下文)，直到解析器从is_complete()返回true为止。但是，在您的代码中，我注意到您正在混合同步调用和异步调用(read_header后面跟着async_read_some)。最好还是坚持一种模式，而不是混合它们。
2. 出于您的目的，您可能需要buffer_body而不是string_body。文档中有一个示例说明了如何做到这一点(read.html)
3. 您所指的“缓冲区”是传递给HTTP流操作的动态缓冲区参数。虽然此缓冲区将保存消息数据，但不应由应用程序进行检查。此缓冲区用于保存流算法可以读取的当前消息结束后的附加数据(这在operations.reading中有解释)。使用buffer_body时，您将通过检查消息正文来访问内容。

http::response_parser::get()将为您提供对正在读取的消息的访问。

最好的解决方案是使用buffer_body，如本例所示，提供一个内存区域来指向它，然后在循环中调用read或async_read。每次缓冲区满时，读取将与错误beast::http::error::need_buffer一起返回，这表明需要进一步调用。

希望这能有所帮助！