异步模式的服务器源码

//g++ -g async_tcp_server.cpp -o async_tcp_server -lboost_system
//#include 
#include 
#include 
#include 
#include using namespace std;
using namespace boost::asio;class server{private:io_service &ios;ip::tcp::acceptor acceptor;typedef boost::shared_ptr sock_ptr;public:server(io_service& io): ios(io),acceptor(ios, ip::tcp::endpoint(ip::tcp::v4(), 6688)){ start(); }void start(){sock_ptr sock(new ip::tcp::socket(ios));acceptor.async_accept(*sock, bind(&server::accept_handler, this, placeholders::error, sock));}void accept_handler(const boost::system::error_code& ec, sock_ptr sock){if(ec) return;cout << "client: ";cout << sock->remote_endpoint().address() << endl;sock->async_write_some(buffer("hello asio"), bind(&server::write_handler, this, placeholders::error));start(); //retry to accept the next quest ......}void write_handler(const boost::system::error_code&){cout << "send msg complete." << endl;}
};int main(){try{cout << "async tcp server start ......" << endl;io_service ios;server serv(ios);ios.run();}catch(std::exception& e){cout << e.what() << endl;}
}

异步模式的客户端源码

//g++ -g async_tcp_client.cpp -o async_tcp_client -lboost_system -lboost_date_time
//#include 
#include 
#include 
#include 
#include using namespace std;
using namespace boost::asio;class client{private:io_service& ios;ip::tcp::endpoint ep;typedef boost::shared_ptr sock_ptr;public:client(io_service& io): ios(io),ep(ip::address::from_string("127.0.0.1"), 6688){start();}void start(){sock_ptr sock(new ip::tcp::socket(ios));sock->async_connect(ep, bind(&client::conn_handler, this, placeholders::error, sock));}void conn_handler(const boost::system::error_code& ec, sock_ptr sock){if(ec)  return;cout << "receive from " << sock->remote_endpoint().address() << endl;boost::shared_ptr > str(new vector(100, 0));sock->async_read_some(buffer(*str), bind(&client::read_handler, this, placeholders::error, str));//sync timer block to control the client connection frequencydeadline_timer t(ios, boost::posix_time::seconds(5));t.wait();start(); //retry to connect in the next time}void read_handler(const boost::system::error_code& ec, boost::shared_ptr > str){if(ec) return;cout << &(*str)[0] << endl;}
};int main()
{try{cout << "client start ......" << endl;io_service ios;client cl(ios);ios.run();return 0;}catch(exception& e){cout << e.what() << endl;}
}

运行效果截图

参考文献

[1].罗剑锋, Boost程序库完全开发指南---深入C++"准"标准库