2

我有一个 http 客户端执行 http::async_write() 并带有一个在 ssl::stream 上执行 http::async_read() 的回调。所有异步操作都包装在同一个显式链中。

简化的代码如下所示

http::async_write(
        *tcp_session_->tcp_stream(), *request,
        boost::asio::bind_executor(
            tcp_session_strand_,
            [request, this](
                boost::system::error_code ec,
                std::size_t /* bytes_transferred */) {
              if (ec) {
                return;
              }
              auto response_buffer =
                  std::make_shared<boost::beast::flat_buffer>();
              auto response = std::make_shared<HttpResponse>();
              http::async_read(
                  *tcp_session_->tcp_stream(), *response_buffer, *response,
                  boost::asio::bind_executor(
                      tcp_session_strand_,
                      [request, done, response_buffer, response](
                          boost::system::error_code ec,
                          std::size_t /*bytes_transferred*/) {
                        if (ec) {
                          // log error
                          return;
                        }
                      }));
            }));

我连续两次这样调用 async_write 。在执行第二次写入之前，我不会等待第一个 async_write 处理程序完成。

我看到的行为是。第一个 async_write 完成，然后第二个 async_write 完成，然后调用第一个 async_read 并出现错误：“操作已取消”。这重现非常一致，所以我假设 ssl::stream 不支持多个挂起的 http 请求。基本上，在发送下一个请求之前必须等待响应。

我的假设正确吗？我阅读了 ssl::stream 的文档，但它没有说明任何内容（只有异步操作必须由 strand 序列化）。

4

1 回答 1

1

根据Async_write 的Beast 文档：

此操作通过对流的 async_write_some 函数的零次或多次调用来实现，称为组合操作。程序必须确保该流在此操作完成之前不执行其他写入。

于 2020-05-31T23:11:22.287 回答