《C++Boost库asio》第七篇 异步time时间服务器

dnfpk001

异步time时间服务器：
一次能连接多个客户端，处理多个客户端的事务

1. // 异步time时间服务器：
   
2. 
   
3. #include <boost/asio.hpp>
   
4. //#include <boost\bind.hpp>//老式写法
   
5. 
   
6. #include <iostream>
   
7. #include <string>
   
8. 
   
9. 
   
10. using boost::asio::ip::tcp;
    
11. 
    
12. std::string make_daytime_string()
    
13. {
    
14.         using namespace std;//For time_t, time and ctime;
    
15.                                                 //time_t now = time(0);
    
16.         auto now = time(nullptr);
    
17.         return ctime(&now); // 返回const char*
    
18. }
    
19. 
    
20. class tcp_connection : public std::enable_shared_from_this<tcp_connection> {
    
21. public :
    
22.         using pointer = std::shared_ptr<tcp_connection>;
    
23. 
    
24.         static pointer create(boost::asio::io_service &io_service) {
    
25.                 //std::make_shared
    
26.                 return pointer(new tcp_connection(io_service));
    
27.         }
    
28. 
    
29.         tcp::socket &socket() { return socket_; }
    
30. 
    
31.         void start() {
    
32.                 message_ = make_daytime_string();//返回当前时间
    
33. 
    
34.                 auto self = shared_from_this();
    
35. 
    
36. #if (0) //老式写法
    
37.                 boost::asio::async_write(//sync同步，async异步
    
38.                         socket_, boost::asio::buffer(message_),
    
39.                         boost::bind(
    
40.                                 &tcp_connection::handle_write,
    
41.                                 shared_from_this(),
    
42.                                 boost::asio::placeholders::error,
    
43.                                 boost::asio::placeholders::bytes_transferred));
    
44. #endif
    
45. 
    
46.                 boost::asio::async_write(
    
47.                         socket_, boost::asio::buffer(message_),
    
48.                         [self = std::move(self)](auto error, auto bytes_transferred){
    
49.                         self->handle_write(error,bytes_transferred);
    
50.                 });//用move不用引用是怕失效,同时省略掉一次拷贝
    
51.         }
    
52. 
    
53. private:
    
54.         tcp_connection(boost::asio::io_service &io_service) : socket_(io_service){}
    
55. 
    
56.         void handle_write(const boost::system::error_code & error, size_t bytes_transferred) {
    
57.                 std::cout << "write succ \n" << std::endl;
    
58.         }
    
59. 
    
60.         tcp::socket socket_;
    
61.         std::string message_;
    
62.        
    
63. };
    
64. 
    
65. class tcp_server {
    
66. public:
    
67.         tcp_server(boost::asio::io_service &io_service) : acceptor_(io_service, tcp::endpoint(tcp::v4(), 2001)) {// 绑定端口
    
68.                 start_accept();//等待新连接;
    
69.         }
    
70. 
    
71. private:
    
72.         void start_accept() {
    
73.                 //tcp_connection::pointer new_connection
    
74.                 auto new_connection = tcp_connection::create(acceptor_.get_io_service());
    
75.                 //异步的方式，开始接受客户端的连接，连接成功或失败进入回调
    
76. #if (0)
    
77.                 //老式的
    
78.                 acceptor_.async_accept(new_connection->socket(),
    
79.                         boost::bind(&tcp_server::handle_accept,
    
80.                                 this, new_connection,
    
81.                                 boost::asio::placeholders::error));
    
82. #endif
    
83.                 //新式的
    
84.                 acceptor_.async_accept(new_connection->socket(),
    
85.                         [this, new_connection](auto error)        {
    
86.                         this->handle_accept(new_connection, error);
    
87.                 });
    
88.         }
    
89. 
    
90.         void handle_accept(tcp_connection::pointer new_connection,
    
91.                 const boost::system::error_code &error) {
    
92.                 //new_connection是否连接已经成功的connection，error是否已经成功
    
93.                 if (!error) {
    
94.                         new_connection->start();
    
95.                 }
    
96. 
    
97.                 start_accept();
    
98.         }
    
99. 
    
100.         tcp::acceptor acceptor_;
     
101. };
     
102. 
     
103. int main()
     
104. {
     
105.         // 我们的程序和操作系统底层之间的一个相互传递的枢纽
     
106.         // 会把事件按照一定方式进行处理;
     
107.         boost::asio::io_service io;
     
108.        
     
109.         try
     
110.         {
     
111.        
     
112.                 tcp_server server(io);
     
113. 
     
114.                 io.run();
     
115. 
     
116.         }
     
117.         catch (std::exception &e)
     
118.         {
     
119.                 std::cerr << e.what() << std::endl;
     
120.         }
     
121.        
     
122. 
     
123.         std::cout << "mian finish run \n" << std::endl;// 提示下main函数已经结束了
     
124.         system("pause");// 让VS控制台程序不会一闪而过;
     
125.     return 0;
     
126. }
     

复制代码