我已经从this example开始，所以不会发布所有的代码。我的目标是下载一个大文件而不阻塞我的主线程。第二个目标是得到通知，这样我就可以更新进度条。我有几种方法来运行代码。第一种是只运行ioc.run();，让它去工作，我得到的文件下载。但我找不到无论如何启动会话没有阻止。
第二种方法我可以向下调用http::async_read_some，调用成功了，但是我不能得到一个我可以使用的响应。我不知道是否有一种方法可以传递一个捕获的lambda。#if 0..#else..#endif切换方法。我确信有一个简单的方法，但我就是看不到它。当我让它工作时，我会清理代码，比如设置本地文件名。谢谢。
std::size_t on_read_some(boost::system::error_code ec, std::size_t bytes_transferred)
{
if (ec);//deal with it...
if (!bValidConnection) {
std::string_view view((const char*)buffer_.data().data(), bytes_transferred);
auto pos = view.find("Content-Length:");
if (pos == std::string_view::npos)
;//error
file_size = std::stoi(view.substr(pos+sizeof("Content-Length:")).data());
if (!file_size)
;//error
bValidConnection = true;
}
else {
file_pos += bytes_transferred;
response_call(ec, file_pos);
}
#if 0
std::cout << "in on_read_some caller\n";
http::async_read_some(stream_, buffer_, file_parser_, std::bind(
response_call,
std::placeholders::_1,
std::placeholders::_2));
#else
std::cout << "in on_read_some inner\n";
http::async_read_some(stream_, buffer_, file_parser_, std::bind(
&session::on_read_some,
shared_from_this(),
std::placeholders::_1,
std::placeholders::_2));
#endif
return buffer_.size();
}最主要的，凌乱不过.....
struct lambda_type {
bool bDone = false;
void operator ()(const boost::system::error_code ec, std::size_t bytes_transferred) {
;
}
};
int main(int argc, char** argv)
{
auto const host = "reserveanalyst.com";
auto const port = "443";
auto const target = "/downloads/demo.msi";
int version = argc == 5 && !std::strcmp("1.0", argv[4]) ? 10 : 11;
boost::asio::io_context ioc;
ssl::context ctx{ ssl::context::sslv23_client };
load_root_certificates(ctx);
//ctx.load_verify_file("ca.pem");
auto so = std::make_shared<session>(ioc, ctx);
so->run(host, port, target, version);
bool bDone = false;
auto const lambda = [](const boost::system::error_code ec, std::size_t bytes_transferred) {
std::cout << "data lambda bytes: " << bytes_transferred << " er: " << ec.message() << std::endl;
};
lambda_type lambda2;
so->set_response_call(lambda);
ioc.run();
std::cout << "not in ioc.run()!!!!!!!!" << std::endl;
so->async_read_some(lambda);
//pseudo message pump when working.........
for (;;) {
std::this_thread::sleep_for(250ms);
std::cout << "time" << std::endl;
}
return EXIT_SUCCESS;
}我在class session中添加的内容
class session : public std::enable_shared_from_this<session>
{
using response_call_type = void(*)(boost::system::error_code ec, std::size_t bytes_transferred);
http::response_parser<http::file_body> file_parser_;
response_call_type response_call;
//
bool bValidConnection = false;
std::size_t file_pos = 0;
std::size_t file_size = 0;
public:
auto& get_result() { return res_; }
auto& get_buffer() { return buffer_; }
void set_response_call(response_call_type the_call) { response_call = the_call; }
2条答案
按热度按时间kd3sttzy1#
我已经更新了这个，因为我终于把它使用，我想旧的方法，我可以下载到一个文件或一个字符串。链接到如何asio工作，伟大的谈话。
CppCon 2016 Michael Caisse Asynchronous IO with BoostAsio
至于我对如何传递lambda的误解，下面是Adam Nevraumont的答案
有两种方法可以编译这个，使用一个类型来选择方法。两种方法都显示在
main的开头。你可以通过选择beast解析器的类型来构造一个文件下载器或字符串下载器。解析器没有相同的构造，所以使用了if constexpr编译时条件。我检查了一下，下载器的发布版本大约是1 K，所以它的工作量相当轻。在一个小字符串的情况下，你不必处理回调。要么传递一个空的lambda，要么添加类似如下的内容：这看起来是一个相当干净的方式来完成这项工作，所以我已经更新了这篇文章作为11/27/2202。
代码：
vm0i2vca2#
我强烈建议不要使用低级的
[async_]read_some函数，而不要使用http::response_parser<http::buffer_body>我确实有一个这样的例子--这个例子有点复杂，因为它还使用Boost Process来并发地解压缩正文数据，但不管怎样，它应该告诉你如何使用它：
如何使用多线程技术，一次连接就能从Internet上读取数据？
我想我可以给出更完整的代码，根据您的特定示例来定制它，但是也许上面的代码已经足够好了？还可以参见libs/beast/example/doc/http_examples.hpp中的“中继HTTP消息”，我将其用作“灵感”。
注意：缓冲区算法并不直观。我认为这是不幸的，不应该是必要的，所以请（非常）密切关注这些样本，以了解它是如何完成的。