- Java 双重比较
- java - 比较器与 Apache BeanComparator
- Objective-C 完成 block 导致额外的方法调用?
- database - RESTful URI 是否应该公开数据库主键?
我正在实现一个访问 REST 端点然后开始处理 SSE stream 的客户端并在事件发生时对其进行监控。为此,我将 Boost::Beast 版本 124 与 Boost 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));
}
我的问题是:
http::string_body
更适合 response_parser
和 response
的类型?read_event
处理程序被调用时,它如何访问 async_read_some
检索到的内容?是否应该从缓冲区中取出?最佳答案
我会先回答你的问题,然后再解释。
是的,您想要读取 header 然后调用 read_some(或读取,见下文)直到解析器从 is_complete() 返回 true。但是,在您的代码中,我注意到您正在混契约(Contract)步和异步调用(read_header 后跟 async_read_some)。最好只使用一种模型而不是混合使用它们。
出于您的目的,您可能需要 buffer_body 而不是 string_body。文档中有一个示例说明如何执行此操作 ( http://www.boost.org/doc/libs/1_66_0/libs/beast/doc/html/beast/using_http/parser_stream_operations/incremental_read.html )
您所指的“缓冲区”是传递给 HTTP 流操作的动态缓冲区参数。虽然此缓冲区将保存消息数据,但它不供应用程序检查。此缓冲区用于保存流算法可以读取的当前消息末尾之后的附加数据(这在 http://www.boost.org/doc/libs/1_66_0/libs/beast/doc/html/beast/using_http/message_stream_operations.html#beast.using_http.message_stream_operations.reading 中有解释)。使用 buffer_body 时,您将通过检查消息正文来访问内容
http::response_parser::get() 将为您提供访问正在读入的消息的权限。
最适合您的解决方案是像示例中那样使用 buffer_body,提供一个内存区域以指向它,然后在循环中调用 read 或 async_read。每次缓冲区满时,读取都会返回错误 beast::http::error::need_buffer
,表明需要进一步调用。
希望这对您有所帮助!
关于c++ - 使用 boost::beast 异步处理流式 HTTP,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/48588627/
Beast::ssl_stream和beast::net::ssl::stream有什么不同?什么时候使用每一种都合适?我看到了两者被以相同方式使用的例子。
我观察到从 Beast.1.0.0-b66(使用 Boost.1.64.0)迁移到 Boost.1.67.0.Beast(即集成 Beast进入 boost )。毫无疑问我做错了什么,但我无法想象是什
我正在使用boost::beast从websocket读取数据到std::string。我密切关注boost 1.71.0中的websocket_sync_client.cpp示例,但有一个更改-I
我正在尝试将 boost beast http 库用于 HTTP 客户端。当我使用模拟服务器时,它可以正常工作,但是当我尝试连接到真实服务器时,boost::beast::http::read抛出一个
我从this example开始,所以不会发布所有代码。我的目标是下载大文件而不阻塞我的主线程。第二个目标是获取通知,以便我可以更新进度条。我的代码确实有两种工作方式。首先是只是ioc.run();并
我有我的 C++ 程序。主线程创建一个新线程,专用于处理 websocket。这个新线程使用例如 boost beast 的 async_read() 调用进行读写。它很像 https://www.b
d:\boost\boost\beast\core\detail\ostream.hpp(263): error C2955: 'boost::beast::detail::ostream_helpe
我正在尝试与远程服务器建立 websocket 连接,但出现以下错误:WebSocket 握手被远程端拒绝 我正在关注这个例子:https://www.boost.org/doc/libs/1_70_
我正在阅读 Boost.Beast 文档,我正在尝试在我的代码中使用速率限制: io_context context; tcp::resolver resolver(context); b
我正在尝试向我们网络上需要凭据的设备发送 HTTP 请求。例如,在网络浏览器中,有效的请求是: http://mylogin:myPassword@10.11.2.118/axis-cgi/virtu
我找到了很多展示如何将 boost::beast::multi_buffer 的内容复制到字符串的示例,但是如何将字符串的内容分配给先前在类实例中创建的 multi_buffer? 如果我的类中有示例
我正在使用 boost/beast 库连接到 websocket,并将数据写入 beast::flat_buffer。我的问题是我无法从 buffer 获取数据。我有一个可以写入的线程安全 chann
我正在开发一个 http 解析器,看起来 boost.beast 是一个不错的解析器。但是,我仍然有一些问题: *** 假设已经通过 boost.asio 套接字接收到 HTTP 请求 POST 数据
Beast websocket 示例将数据存储在多缓冲区中: The implementation uses a sequence of one or more character arrays of
使用 boost::beast( https://www.boost.org/doc/libs/1_66_0/libs/beast/example/websocket/client/sync-ssl/
我不是很熟悉 boost::asio 的基础知识。我正在处理连接到 Web 服务器并读取响应的任务。响应在随机时间段抛出,即在生成响应时。 为此,我使用了 boost::beast 库,它包含在 bo
在 C++ 中使用 boost/beast websockets 我已经阅读了有关不支持非阻塞读取的 beast websockets 的问题,以及无法检查数据是否可用的事实,并且在单独的线程中进行读
我正在尝试异步的 Boost Beast 示例 web socket server - client 我正在运行服务器和客户端,如下所示, server.exe 127.0.0.1 4242 1 cl
我正在尝试设计一个系统,我正在创建一个树状结构,用户可以订阅树的任何分支。例如:如果一棵树看起来像 A--B--C | D 这里A是B的父级,B是C和D的父级现在,一个
我们有一个完全同步的应用程序,并且永远是因为它基本上是一个命令行解释器,用于向我们的硬件发送低级命令,并且您不能同时向硬件发送两个命令。对于此配置,我将只有 1 个客户端套接字以同步方式运行,一个命令
我是一名优秀的程序员,十分优秀!