备忘使用

1. #include <boost/bind.hpp> 
2. #include <boost/asio.hpp> 
3. #include <boost/thread.hpp> 
4. using boost::asio::io_service; 
5. using boost::asio::ip::tcp; 
6. using boost::system::error_code; 
7. using boost::asio::deadline_timer; 
8. using boost::asio::buffer; 
9.  
10. class MyNet 
11. { 
12. public: 
13.     void Accept(unsigned short port, boost::function<void ()> fun) 
14.     { 
15.         _pAcceptor = new tcp::acceptor(_ios, tcp::endpoint(tcp::v4(), port)); 
16.         _pTimer = new deadline_timer(_ios); 
17.      _pClentSkt = new tcp::socket(_ios); 
18.         _pAcceptor->async_accept(*_pClentSkt, 
19.         boost::bind(&MyNet::AcceptHandle, this,  
20.          boost::asio::placeholders::error, //传递错误码
21. fun//传递一个函数指针
22. )); 
23.         _ios.reset(); //充值事件循环状态
24.         if (_ios.run() == 0) //启动事件循环
25.         { 
26.          throw std::runtime_error("io_service run return 0."); 
27.         } 
28.     } 
29.     void Send(const string& data) 
30.     { 
31.      _pClentSkt->write_some(buffer(data, data.size())); 
32.     } 
33.     string Recv() 
34.     {
35.         _ret = _pClentSkt->read_some(buffer(_buf, 1024)); 
36.         return string(_buf, _ret); 
37.     } 
38.     void Close() 
39.     { 
40.         _mutex.lock(); 
41.         _pAcceptor->close(); 
42.         _pClentSkt->shutdown(tcp::socket::shutdown_both); 
43.         _pClentSkt->close(); 
44.         _ios.stop(); 
45.         _mutex.unlock(); 
46.     } 
47.     string GetClientIp() 
48.     {//获得客户端的ip 
49.         boost::asio::ip::tcp::endpoint ep = _pClentSkt->remote_endpoint(); 
50.         return ep.address().to_string(); 
51.     } 
52.     unsigned short GetPort() 
53.     {//获得监控的端口
54.         return _pAcceptor->local_endpoint().port(); 
55.     } 
56.     static unsigned short GetLocalValidPort() 
57.     {//随机过去一个本机的可用端口
58.         io_service ios; 
59.         tcp::acceptor acceptor(ios, tcp::endpoint(tcp::v4(), 0)); 
60.         tcp::acceptor::endpoint_type et = acceptor.local_endpoint(); 
61.         return et.port(); 
62.     } 
63.     static string GetLocalIp() 
64.     {//获取本机ip
65.         boost::asio::io_service io_service; 
66.         tcp::resolver resolver(io_service); 
67.         tcp::resolver::query query(boost::asio::ip::host_name(), ""); 
68.         tcp::resolver::iterator iter = resolver.resolve(query); 
69.         tcp::resolver::iterator end; // End marker. 
70.         if (iter != end) 
71.         { 
72.             tcp::endpoint ep = *iter; 
73.          return ep.address().to_string(); 
74.      } 
75.     } 
76.     ~MyNet(void) 
77.     { 
78.         delete _pTimer; 
79.         delete _pAcceptor; 
80.         delete _pClentSkt; 
81.     } 
82. protected: 
83.     void AcceptHandle(const error_code& error, boost::function<void ()> fun) 
84.     {//异步接收连接的回调函数
85.         if (error) 
86.             return; 
87.         //传递进来的函数指针fun未用到，本来是为了启动此函数的线程，boost::thread trd(fun); 
88.     } 
89.  
90. private: 
91.     io_service _ios; 
92.     tcp::acceptor* _pAcceptor; 
93.     tcp::socket* _pClentSkt; 
94.     tcp::socket* _pClentTmp; 
95.     deadline_timer* _pTimer; 
96.     char _buf[1024]; 
97.     size_t _ret; 
98.     static string _ip; 
99.     boost::mutex _mutex; 
100. };