使用 boost::asio::use_future 增强 asio:async_read()

打电话时asio::async_read()使用 future，有没有办法获取当 a 时传输的字节数boost:asio::error::eof出现异常？似乎在很多情况下，即使对等方断开连接，人们也希望传输数据。

例如：

namespace ba = boost::asio;

int32_t Session::read (unsigned char* pBuffer, uint32_t bufferSizeToRead)
{
   // Create a mutable buffer
   ba::mutable_buffer buffer (pBuffer, bufferSizeToRead);
   int32_t result = 0;

   // We do an async call using a future.  A thread from the io_context pool does the
   // actual read while the the thread calling this method will blocks on the 
   // std::future::get()
   std::future<std::size_t> future =
         ba::async_read(m_socket, buffer, ba::bind_executor(m_sessionStrand, ba::use_future));
   try
   {
      // We block the calling thread here until we get the results of the async_read_some()...
      result = future.get();
   }
   catch (boost::system::system_error &ex)  // boost::system::system_error
   {
      auto exitCode = ex.code().value();
      if ( exitCode == ba::error::eof )
      {
         log ("Connection closed by the peer");
      }
   }

   return results;  // This is zero if eof occurs
}

上面的代码示例代表了我们的问题。它旨在支持第三方库。库预计会发生阻塞调用。正在开发的新代码使用 ASIO 和最少数量的网络线程。期望的是这个第三方库调用session::read使用其专用线程，我们将调用调整为异步调用。网络调用必须是异步的，因为我们使用最少的线程支持来自不同库的许多此类调用。

出乎意料且后来发现的是 ASIO 将关闭的连接视为错误。没有未来，使用handler我们可以获得传输到发生断开连接的点的字节。但是，使用 future 会引发异常，并且传输的字节变得未知。

void handler (const boost::system::error_code& ec,
      std::size_t bytesTransferred );

1. 有没有办法在未来执行上述操作并传输字节？
2. 或者有一种替代方法，我们可以通过仍然使用asio::async_read或类似的。

我们的期望是，即使客户端关闭了连接，我们也可以获得传输的字节。我们很困惑，当使用 future 时，这似乎是不可能的。

这是期货的实施限制。

Modern async_result<>专业化（使用initiate成员方法）可以与as_tuple, e.g.:

ba::awaitable<std::tuple<boost::system::error_code, size_t>> a =
    ba::async_read(m_socket, buffer, ba::as_tuple(ba::use_awaitable));

或者，更典型的是：

auto [ec, n] = co_await async_read(m_socket, buffer, ba::as_tuple(ba::use_awaitable));

然而，相应的：

auto future = ba::async_read(m_socket, buffer, ba::as_tuple(ba::use_future));

目前不支持。可以说可以，但你必须创建自己的完成令牌，或者要求 Asio 开发人员添加支持use_future: https://github.com/chriskohlhoff/asio/issues https://github.com/chriskohlhoff/asio/issues

旁注：如果您构建m_socket来自m_sessioStrand执行人，您不需要bind_executor到股：

using Executor = net::io_context::executor_type;
struct Session {
    int32_t read(unsigned char* pBuffer, uint32_t bufferSizeToRead);

    net::io_context       m_ioc;
    net::strand<Executor> m_sessionStrand{m_ioc.get_executor()};
    tcp::socket           m_socket{m_sessionStrand};
};