boost库asio详解8——几个TCP的简单例子

2024-06-15 03:18
文章标签 简单 详解 几个 tcp 例子 boost asio

本文主要是介绍boost库asio详解8——几个TCP的简单例子，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

摘于boost官网的几个例子, 做了点小修改, 笔记之.

同步客户端

[cpp] view plain copy print ?
  1. void test_asio_synclient()  
  2. {  
  3.     typedef boost::asio::io_service IoService;  
  4.     // 该命名空间下有几个常用类: accetpt, resolver, endpoint, socket  
  5.     typedef boost::asio::ip::tcp TCP;  
  6.   
  7.     try  
  8.     {  
  9.         IoService ios;  
  10.         boost::system::error_code error;  
  11.   
  12.         // 1. 用解释器的方法, 常用来解析域名, 如  
  13.         // query("www.163.com","80"), 也可以 query("www.163.com","telnet")  
  14.         // echo          7/tcp  
  15.         // ftp           21/tcp                 # File Transfer Protocol (Control)  
  16.         // telnet        23/tcp                 # Virtual Terminal Protocol  
  17.         // smtp          25/tcp                 # Simple Mail Transfer Protocol  
  18.         // time          37/tcp  timeserver     # Time  
  19. //      TCP::resolver resolver(ios);  
  20. //      TCP::resolver::query query("127.0.0.1", "10000");  
  21. //      TCP::resolver::iterator endpoint_iterator = resolver.resolve(query);  
  22. //      TCP::resolver::iterator end;  
  23. //      TCP::socket socket(ios);  
  24. //      socket.connect(*endpoint_iterator, error);  
  25.   
  26.         // 2. 用简便的方法  
  27.         TCP::socket socket(ios);  
  28.         TCP::endpoint endpoint(boost::asio::ip::address_v4::from_string("127.0.0.1"), 10000);  
  29.         socket.connect(endpoint, error);  
  30.   
  31.         // 这里要判断一下, 否则没有连上会通过.  
  32.         if (error)  
  33.             throw boost::system::system_error(error);  
  34.       
  35.         while(true)  
  36.         {  
  37.             // boost::array<char, 128> buf;  
  38.             std::vector<char> buf(128);  
  39.             size_t len = socket.read_some(boost::asio::buffer(buf), error);  
  40.   
  41.             // 这是也要判断一下, 否则服务端运行断开, 这里会出现死循环.  
  42.             if (error == boost::asio::error::eof)  
  43.                 break; // Connection closed cleanly by peer.  
  44.             else if (error)  
  45.                 throw boost::system::system_error(error); // Some other error.  
  46.               
  47.             // buf要注意控制大小。  
  48.             socket.write_some(boost::asio::buffer(buf, len), error);  
  49.         }  
  50.     }  
  51.     catch (std::exception& e)  
  52.     {  
  53.         PRINT_DEBUG(e.what());  
  54.     }  
  55. }  

同步服务端

[cpp] view plain copy print ?
  1. namespace  
  2. {  
  3.     std::string make_daytime_string()  
  4.     {  
  5.         using namespace std; // For time_t, time and ctime;  
  6.         time_t now = time(0);  
  7.         return ctime(&now);  
  8.     }  
  9. }  
  10.   
  11. void test_asio_synserver()  
  12. {  
  13.     typedef boost::asio::io_service IoService;  
  14.     typedef boost::asio::ip::tcp TCP;  
  15.   
  16.     try  
  17.     {  
  18.         IoService ios;  
  19.         /* 
  20.             *以下构造函数相当于以下步骤 
  21.             * basic_socket_acceptor<tcp> acceptor(io_service); 
  22.             * acceptor.open(tcp::v4()); 
  23.             * acceptor.bind(tcp::endpoint(13)); 
  24.             * acceptor.listen(0);//default  
  25.         */  
  26.         /* 
  27.             tcp::endpoint(端点)由以下三个部分组成 
  28.             1. IP地址(address, address_v4, address_v6) 
  29.             2. 端口号 
  30.             3. 协议版本 
  31.         */  
  32.         TCP::acceptor acceptor(ios, TCP::endpoint(TCP::v4(), 13));  
  33.         for (;;)  
  34.         {  
  35.             TCP::socket socket(ios);  
  36.             acceptor.accept(socket);  
  37.             std::string message = make_daytime_string();  
  38.   
  39.             boost::system::error_code ignored_error;  
  40.             boost::asio::write(socket,  
  41.                                boost::asio::buffer(message),   
  42.                                boost::asio::transfer_all(),   
  43.                                ignored_error);  
  44.             PRINT_DEBUG(message);  
  45.         }  
  46.     }  
  47.     catch (std::exception& e)  
  48.     {  
  49.         std::cout << e.what() << std::endl;  
  50.     }  
  51. }  

异步服务端

[cpp] view plain copy print ?
  1. namespace  
  2. {  
  3.     typedef boost::asio::io_service IoService;  
  4.     typedef boost::asio::ip::tcp TCP;  
  5.   
  6.     std::string make_daytime_string()  
  7.     {  
  8.         using namespace std;  
  9.         time_t now = std::time(NULL);  
  10.         return ctime(&now);  
  11.     }  
  12.   
  13.     class tcp_connection  
  14.         : public boost::enable_shared_from_this<tcp_connection>  
  15.     {  
  16.     public:  
  17.         typedef boost::shared_ptr<tcp_connection> pointer;  
  18.   
  19.         static pointer create(IoService& io_service)  
  20.         {  
  21.             return pointer(new tcp_connection(io_service));  
  22.         }  
  23.   
  24.         TCP::socket& socket()  
  25.         {  
  26.             return socket_;  
  27.         }  
  28.   
  29.         void start()  
  30.         {  
  31.             message_ = make_daytime_string();  
  32.   
  33.             boost::asio::async_write(  
  34.                 socket_,   
  35.                 boost::asio::buffer(message_),   
  36.                 boost::bind(&tcp_connection::handle_write,   
  37.                             shared_from_this(),   
  38.                             boost::asio::placeholders::error,   
  39.                             boost::asio::placeholders::bytes_transferred));  
  40.         }  
  41.     private:  
  42.         tcp_connection(IoService& io_service)  
  43.             : socket_(io_service)  
  44.         {  
  45.         }  
  46.   
  47.         void handle_write(const boost::system::error_code& /*error*/,  
  48.             size_t /*bytes_transferred*/)  
  49.         {  
  50.             PRINT_DEBUG("write data!!!");  
  51.         }  
  52.   
  53.         TCP::socket socket_;  
  54.         std::string message_;  
  55.     };  
  56.   
  57.     class tcp_server  
  58.     {  
  59.     public:  
  60.         tcp_server(IoService& io_service)  
  61.             : acceptor_(io_service, TCP::endpoint(TCP::v4(), 10000))  
  62.         {  
  63.             start_accept();  
  64.         }  
  65.     private:  
  66.         void start_accept()  
  67.         {  
  68.             tcp_connection::pointer new_connection =  
  69.                 tcp_connection::create(acceptor_.get_io_service());  
  70.               
  71.             acceptor_.async_accept(  
  72.                 new_connection->socket(),   
  73.                 boost::bind(&tcp_server::handle_accept,   
  74.                             this,   
  75.                             new_connection,   
  76.                             boost::asio::placeholders::error));  
  77.         }  
  78.   
  79.         void handle_accept(tcp_connection::pointer new_connection,  
  80.             const boost::system::error_code& error)  
  81.         {  
  82.             if (!error)  
  83.             {  
  84.                 new_connection->start();  
  85.                 start_accept();  
  86.             }  
  87.         }  
  88.   
  89.         TCP::acceptor acceptor_;  
  90.     };  
  91. }  
  92.   
  93. // tcp_connection与tcp_server封装后  
  94. void test_asio_asynserver()  
  95. {  
  96.     try  
  97.     {  
  98.         IoService io_service;  
  99.         tcp_server server(io_service);  
  100.   
  101.         // 只有io_service类的run()方法运行之后回调对象才会被调用  
  102.         io_service.run();  
  103.     }  
  104.     catch (std::exception& e)  
  105.     {  
  106.         std::cerr << e.what() << std::endl;  
  107.     }  
  108. }  

这篇关于boost库asio详解8——几个TCP的简单例子的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1062283。

相关文章

PHP轻松处理千万行数据的方法详解

PHP轻松处理千万行数据的方法详解

《PHP轻松处理千万行数据的方法详解》说到处理大数据集,PHP通常不是第一个想到的语言,但如果你曾经需要处理数百万行数据而不让服务器崩溃或内存耗尽,你就会知道PHP用对了工具有多强大,下面小编就... 目录问题的本质php 中的数据流处理：为什么必不可少生成器：内存高效的迭代方式流量控制：避免系统过载一次性
阅读更多...
MySQL的JDBC编程详解

MySQL的JDBC编程详解

《MySQL的JDBC编程详解》：本文主要介绍MySQL的JDBC编程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录前言一、前置知识1. 引入依赖2. 认识 url二、JDBC 操作流程1. JDBC 的写操作2. JDBC 的读操作总结前言本文介绍了mysq
阅读更多...
Redis 的 SUBSCRIBE命令详解

Redis 的 SUBSCRIBE命令详解

《Redis的SUBSCRIBE命令详解》Redis的SUBSCRIBE命令用于订阅一个或多个频道,以便接收发送到这些频道的消息,本文给大家介绍Redis的SUBSCRIBE命令,感兴趣的朋友跟随... 目录基本语法工作原理示例消息格式相关命令python 示例Redis 的 SUBSCRIBE 命令用于订
阅读更多...
使用Python批量将.ncm格式的音频文件转换为.mp3格式的实战详解

使用Python批量将.ncm格式的音频文件转换为.mp3格式的实战详解

《使用Python批量将.ncm格式的音频文件转换为.mp3格式的实战详解》本文详细介绍了如何使用Python通过ncmdump工具批量将.ncm音频转换为.mp3的步骤,包括安装、配置ffmpeg环... 目录1. 前言2. 安装 ncmdump3. 实现 .ncm 转 .mp34. 执行过程5. 执行结
阅读更多...
Python中 try / except / else / finally 异常处理方法详解

Python中 try / except / else / finally 异常处理方法详解

《Python中try/except/else/finally异常处理方法详解》：本文主要介绍Python中try/except/else/finally异常处理方法的相关资料,涵... 目录1. 基本结构2. 各部分的作用tryexceptelsefinally3. 执行流程总结4. 常见用法（1）多个e
阅读更多...
SpringBoot日志级别与日志分组详解

SpringBoot日志级别与日志分组详解

《SpringBoot日志级别与日志分组详解》文章介绍了日志级别（ALL至OFF）及其作用,说明SpringBoot默认日志级别为INFO,可通过application.properties调整全局或... 目录日志级别1、级别内容2、调整日志级别调整默认日志级别调整指定类的日志级别项目开发过程中，利用日志
阅读更多...
Java中的抽象类与abstract 关键字使用详解

Java中的抽象类与abstract 关键字使用详解

《Java中的抽象类与abstract关键字使用详解》：本文主要介绍Java中的抽象类与abstract关键字使用详解,本文通过实例代码给大家介绍的非常详细,感兴趣的朋友跟随小编一起看看吧... 目录一、抽象类的概念二、使用 abstract2.1 修饰类 => 抽象类2.2 修饰方法 => 抽象方法，没有
阅读更多...
MySQL8 密码强度评估与配置详解

MySQL8 密码强度评估与配置详解

《MySQL8密码强度评估与配置详解》MySQL8默认启用密码强度插件,实施MEDIUM策略（长度8、含数字/字母/特殊字符）,支持动态调整与配置文件设置,推荐使用STRONG策略并定期更新密码以提... 目录一、mysql 8 密码强度评估机制1.核心插件：validate_password2.密码策略级
阅读更多...
从入门到精通详解Python虚拟环境完全指南

从入门到精通详解Python虚拟环境完全指南

《从入门到精通详解Python虚拟环境完全指南》Python虚拟环境是一个独立的Python运行环境,它允许你为不同的项目创建隔离的Python环境,下面小编就来和大家详细介绍一下吧... 目录什么是python虚拟环境一、使用venv创建和管理虚拟环境1.1 创建虚拟环境1.2 激活虚拟环境1.3 验证虚
阅读更多...
详解python pycharm与cmd中制表符不一样

详解python pycharm与cmd中制表符不一样

《详解pythonpycharm与cmd中制表符不一样》本文主要介绍了pythonpycharm与cmd中制表符不一样,这个问题通常是因为PyCharm和命令行（CMD）使用的制表符（tab）的宽... 这个问题通常是因为PyCharm和命令行（CMD）使用的制表符（tab）的宽度不同导致的。在PyChar
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2