2. 主动器(Proactor)
(1)Proactor需要调用者定义一个异步执行的操作,例如,socket的异步读/写;
(2)执行异步操作,异步事件处理器将异步请求交给操作系统就返回了,让操作系统去完成具体的操作,操作系统在完成操作之后,会将完成事件放入一个完成事件队列。
(3)异步事件分离器会检测完成事件,若检测到完成事件,则从完成队列中取出完成事件,并通知应用程序注册的完成事件处理函数去处理;
(4)完成事件处理函数处理异步操作的结果。
下面是一个基于boost::asio的异步服务器:
#include "stdafx.h" #include <boost/asio.hpp> #include <boost/bind/placeholders.hpp> #include <boost/bind/bind.hpp> #include <boost/system/error_code.hpp> #include <boost/smart_ptr/enable_shared_from_this.hpp> using namespace boost::asio; namespace { typedef boost::asio::io_service IoService; typedef boost::asio::ip::tcp TCP; std::string make_daytime_string() { using namespace std; time_t now = std::time(NULL); return ctime(&now); } class tcp_connection : public boost::enable_shared_from_this<tcp_connection> { public: typedef boost::shared_ptr<tcp_connection> pointer; static pointer create(IoService& io_service) { return pointer(new tcp_connection(io_service)); } TCP::socket& socket() { return socket_; } void start() { message_ = make_daytime_string(); boost::asio::async_write( socket_, boost::asio::buffer(message_), boost::bind(&tcp_connection::handle_write, shared_from_this(), boost::asio::placeholders::error, boost::asio::placeholders::bytes_transferred)); } private: tcp_connection(IoService& io_service) : socket_(io_service) { } void handle_write(const boost::system::error_code& /*error*/, size_t /*bytes_transferred*/) { printf("write data!!!"); } TCP::socket socket_; std::string message_; }; class tcp_server { public: tcp_server(IoService& io_service) : acceptor_(io_service, TCP::endpoint(TCP::v4(), 10000)) { start_accept(); } private: void start_accept() { tcp_connection::pointer new_connection = tcp_connection::create(acceptor_.get_io_service()); acceptor_.async_accept( new_connection->socket(), boost::bind(&tcp_server::handle_accept, this, new_connection, boost::asio::placeholders::error)); } void handle_accept(tcp_connection::pointer new_connection, const boost::system::error_code& error) { if (!error) { new_connection->start(); start_accept(); //继续监听,否则io_service将认为没有事件处理而结束运行 } } TCP::acceptor acceptor_; }; } // tcp_connection与tcp_server封装后 void test_asio_asynserver() { try { IoService io_service; tcp_server server(io_service); // 只有io_service类的run()方法运行之后回调对象才会被调用 io_service.run(); } catch (std::exception& e) { std::cerr << e.what() << std::endl; } } int main() { test_asio_asynserver(); return 0; }
有连接时需要写入数据,但是写入数据并不是由用户写入的,而是把需要写入的数据提交给了系统,由系统择机写入,堆栈如下:
总结两者,可以看出Reactor采用的是同步IO,主动器采用的是异步IO。个人认为简单来说,同步IO是发出了请求,不管阻塞还是非阻塞,都需要调用者主动去check调用的结果;而异步IO是由被调用者通知调用者来处理结果。