本文主要是介绍[16 使用C++11开发一个简单的通信程序(Proactor模式)] 16.3 asio的基本用法，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
asio的异步操作过程如下：(asio的全称为Asynchronous input and output（异步输入输出）的缩写)
图16-7 asio的异步操作过程
(1)应用程序发起了一个异步请求(异步读或写)，需要提供socket或异步操作完成函数。
(2)asio的io_object对象会将这个异步请求交给操作系统，由操作系统完成该请求。
(3)调用io-service::run等待异步事件的完成。
(4)操作系统完成异步操作后，将异步操作的结果返回给io_service。
(5)io_service将完成事件的结果回调到对应的完成函数并处理。
用户要发起一个异步操作需要做如下3件事：
(1)发起异步操作，如async_read，async_write，async_connect，这些异步接口需要一个回调函数。
(2)调用io_service::run处理异步事件，必须保证io_service::run不退出，因为io_service通过一个循环去处理这些异步操作事件。一个简单办法是使用io_service::work，保证io_service一直运行。
(3)处理异步操作完成事件，回调函数处理。
16.3.1 异步connect
async_connect的基本用法：
asio::io_service io_service;
// 创建socket
aiso::ip::tcp::socket socket(io_service);
// 发起异步连接
boost::asio::async_connect(socket, server_address, connect_handler);
// 启动事件循环
io_service.run();connect_handler的简单实现如下：
void connect_handler(const boost::system::error_code& error)
{if (error) {cout << error.message() << endl;// 异常处理return;}// do sth.
}16.3.2 异步read
async_read和async_write需要一个boost::asio::buffer来作为数据读和写的缓冲区。
async_read的基本用法如下：
asio::io_service io_service;
asio::ip:tcp::socket socket(io_service);
std::string str = "test";
boost::asio::async_read(socket, boost::asio::buffer(str.c_str(), str.length()+1), read_handler);
io_service.run();void read_handler(const boost::system::error_code& error)
{if (error) {cout << error.message() << endl;// 异常处理return;}// do sth.
}16.3.3 异步write
注意：不能连续调用异步发送接口async_write。
async_write内部不断调用async_write_some，直到所有的数据发送完成为止。如果第一次调用async_write发送一个较大的包，马上又再调用async_write发送一个很小的包。很可能第二个包先发完，第一个包还没发完，导致乱序问题。解决办法是用发送缓冲区控制发送。
异步发送的示例如下：
// 发送队列
std::list<Message> m_sendQueue;void AsyncWrite()
{auto msg = m_sendQueue.front();async_write(m_sock, buffer(msg.pData, msg.len), boost::bind(&HandleWrite, boost::asio::placeholders:error));
}void HandleWrite(boost:system::error_code& ec)
{if (!ec) {m_sendQueue.pop_front();if (!m_sendQueue.empty()) {AsyncWrite();}} else {HandleError(ec);if (!m_sendQueue.empty()) {m_sendQueue.clear();}}
}注意：发送数据(AsyncWrite)和io_service.run()必须在同一个线程里执行。
这篇关于[16 使用C++11开发一个简单的通信程序(Proactor模式)] 16.3 asio的基本用法的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
