码迷,mamicode.com
首页 > 其他好文 > 详细

改进基于Boost.Asio的聊天服务

时间:2014-11-21 01:20:05      阅读:167      评论:0      收藏:0      [点我收藏+]

标签:style   blog   io   ar   color   os   sp   for   on   

  Boost.Asio是个非常易用的C++异步网络库,官网上有很详细文档和示例代码。其中一个示例是聊天服务,分成chat_message、chat_client、chat_server这么三个部分。chat_server的启动代码如下。

 1     if (argc < 2)
 2     {
 3       std::cerr << "Usage: chat_server <port> [<port> ...]\n";
 4       return 1;
 5     }
 6 
 7     boost::asio::io_service io_service;
 8 
 9     chat_server_list servers;
10     for (int i = 1; i < argc; ++i)
11     {
12       using namespace std; // For atoi.
13       tcp::endpoint endpoint(tcp::v4(), atoi(argv[i]));
14       chat_server_ptr server(new chat_server(io_service, endpoint));
15       servers.push_back(server);
16     }
17 
18     io_service.run();

  从中可以看出,输入多个端口号会启动多个chat_server,但只有一个io_service,也就是说多个chat_server中产生的异步任务handler被放入同一个任务队列(由唯一的io_service维护),这就相当于用一个线程同时处理多个聊天服务器,自然会对系统的性能产生影响。

  从io_service_pool这个示例中可以得到一点改进的启发,每个chat_server绑定一个io_service,每个io_service在一个独立的线程中运行,这样就能充分利用机器的多核性能,改进代码如下。

 1         if (argc < 2)
 2         {
 3             std::cerr << "Usage: chat_server <port> [<port> ...]\n";
 4             return 1;
 5         }
 6 
 7         typedef boost::shared_ptr<boost::asio::io_service> io_service_ptr;
 8         typedef std::list<io_service_ptr> io_service_list;
 9 
10         chat_server_list servers;
11         io_service_list services;
12         for (int i = 1; i < argc; ++i)
13         {
14             using namespace std; // For atoi.
15             tcp::endpoint endpoint(tcp::v4(), atoi(argv[i]));
16             io_service_ptr service(new boost::asio::io_service);
17             chat_server_ptr server(new chat_server(*service, endpoint));
18             services.push_back(service);
19             servers.push_back(server);
20         }
21 
22         std::vector<std::shared_ptr<std::thread> > threads;
23         for(auto service : services) 
24         {
25             auto run_func = [](const io_service_ptr& ptr) {
26                 return ptr->run();
27             };
28             std::function<std::size_t()> f = std::bind(run_func, service);
29             std::shared_ptr<std::thread> thread(new std::thread(f));
30             threads.push_back(thread);
31         }
32 
33         // Wait for all threads in the pool to exit.
34         for (std::size_t i = 0; i < threads.size(); ++i) {
35             threads[i]->join();
36         }    

 

改进基于Boost.Asio的聊天服务

标签:style   blog   io   ar   color   os   sp   for   on   

原文地址:http://www.cnblogs.com/crazychris/p/4111888.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!