Boost Asio Windows_stream_handler - Async_read_some 不递归调用答案

【问题标题】：Boost Asio Windows_stream_handler - Async_read_some not called recursivelyBoost Asio Windows_stream_handler - Async_read_some 不递归调用
【发布时间】：2013-04-14 09:31:11
【问题描述】：

我正在使用 boost::asio::windows::stream_handle 并使用 async_read_some 方法从命名管道中递归读取数据。我为 async_read_some 方法关联了一个 read_handler。但是 async_read_some 处理程序只被调用一次，当新消息通过管道时它不会被进一步调用。通过反复试验方法，我将 read_handler 再次分配给 async_read_some 方法，现在它被正确调用了。但这是正确的做法吗，或者请提出一种从管道中获得持续响应的优雅方式。

boost::asio::io_service my_io_service; 
boost::asio::windows::stream_handle pipe( my_io_service);
boost::array<char, 4096> buffer;

void CPublishSubscribeLib::read_handler(const boost::system::error_code& ec, std::size_t bytes_transferred)
{
if(bytes_transferred > 0 )
pipe.async_read_some(boost::asio::buffer(buffer, 150), boost::bind(&CPublishSubscribeLib::read_handler, this, _1, _2));
}

先谢谢了！

【问题讨论】：

要么read_handler 被bytes_transferred == 0 调用，要么my_io_service::run 退出。

标签： boost boost-asio

【解决方案1】：

使用 Boost.Asio，单个异步操作可能只调用一次关联的处理程序，然后立即删除 Boost.Asio 创建的处理程序的所有副本。因此，如果async_read_some 操作只启动一次，那么ReadHandler 将只被调用一次。通过从同一操作的处理程序中启动操作来形成异步链是一种非常常见的模式。在这种情况下，从CPublishSubscribeLib::read_handler 内部发起async_read_some 操作是正常的。

【讨论】：

【解决方案2】：

回答您关于从管道获取连续数据流的正确方法的问题 - 当然，可以从内部调用 read_handler 来处理下一条消息。我在我的代码中这样做并且效果很好。要记住的重要一点是，您的 read_handler 所在的线程需要是响应式的。这意味着处理每条消息不应该花费太多时间。因此，许多人建议将消息简单地复制到缓冲区，然后将其存储在某种容器（队列、堆栈或向量）中保存消息，然后通知工作线程唤醒并处理消息。这是我在代码中采用的方法。但是，如果处理量很小和/或服务器不发送很多消息，您可能不需要在代码中执行此操作。如果您在将小消息从套接字复制到缓冲区时担心性能和内存碎片，那么您可以考虑分配一个大的环绕缓冲区来存储消息 .vs。在每条消息从堆中到达时为其分配空间。

【讨论】：