c++ - 关于多线程客户端的 BOOST 教程？

Question

<分区>

Answer 1

您提供的链接是关于如何使用 boost::asio 库的优秀指南。 一旦您了解它的工作原理，您将能够在没有多线程的情况下做您想做的事。

asio(异步IO)的思想是一旦io_service对象完成一个操作就回调你。每当你调用 aync_xxx 时，你都会向它传递一个函数指针(或仿函数)，一旦操作完成就会调用它。这样，您就不必在轮询 IO 上阻塞单独的线程。

例如，一旦完成，您想从服务器读取一条消息。调用 do_something(Message& msg)。这正是示例代码所做的。

因为 TCP 是一种基于流的协议(protocol)，没有自然的消息边界，您必须在其上定义自己的消息格式。在示例中，它为此目的定义了一个 chat_message 类。

要读取消息，客户端遵循这些步骤，每个步骤都是在先前的 async_xxx 操作完成后作为回调的结果触发的。它还依赖于这样一个事实，即仅当读取了指定的确切字节数或发生错误时，async_read 才完成。

1. 调用 async_connect，将 handle_connect 作为其回调传递。
2. handle_connect 调用 async_read，将 handle_read_header 作为其回调传递
3. handle_read_header 调用 async_read，将 handle_read_body 作为其回调传递。
4. handle_read_body 最终会调用 async_read，传递 handle_read_header 作为其回调，以便该过程为下一条消息重复自身。

请注意，在示例中，它在调用 async_read 之前在步骤 4 中执行了“cout.write...”。 您需要做的就是用您的 do_something(msg) 替换“cout.wirte..”部分。

写入部分遵循类似的回调链，唯一的区别是当没有更多消息可写入时链会中断，因此我们需要检查条件并重新启动它。