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。

相关文章

idea的终端(Terminal)cmd的命令换成linux的命令详解

idea的终端(Terminal)cmd的命令换成linux的命令详解

《idea的终端(Terminal)cmd的命令换成linux的命令详解》本文介绍IDEA配置Git的步骤：安装Git、修改终端设置并重启IDEA,强调顺序,作为个人经验分享,希望提供参考并支持脚本之... 目录一编程、设置前二、前置条件三、android设置四、设置后总结一、php设置前二、前置条件
阅读更多...
python中列表应用和扩展性实用详解

python中列表应用和扩展性实用详解

《python中列表应用和扩展性实用详解》文章介绍了Python列表的核心特性：有序数据集合,用[]定义,元素类型可不同,支持迭代、循环、切片,可执行增删改查、排序、推导式及嵌套操作,是常用的数据处理... 目录1、列表定义2、格式3、列表是可迭代对象4、列表的常见操作总结1、列表定义是处理一组有序项目的
阅读更多...
python使用try函数详解

python使用try函数详解

《python使用try函数详解》Pythontry语句用于异常处理,支持捕获特定/多种异常、else/final子句确保资源释放,结合with语句自动清理,可自定义异常及嵌套结构,灵活应对错误场景... 目录try 函数的基本语法捕获特定异常捕获多个异常使用 else 子句使用 finally 子句捕获所
阅读更多...
C++11范围for初始化列表auto decltype详解

C++11范围for初始化列表auto decltype详解

《C++11范围for初始化列表autodecltype详解》C++11引入auto类型推导、decltype类型推断、统一列表初始化、范围for循环及智能指针,提升代码简洁性、类型安全与资源管理效... 目录C++11新特性1. 自动类型推导auto1.1 基本语法2. decltype3. 列表初始化3
阅读更多...
SQL Server 中的 WITH (NOLOCK) 示例详解

SQL Server 中的 WITH (NOLOCK) 示例详解

《SQLServer中的WITH(NOLOCK)示例详解》SQLServer中的WITH(NOLOCK)是一种表提示,等同于READUNCOMMITTED隔离级别,允许查询在不获取共享锁的情... 目录SQL Server 中的 WITH (NOLOCK) 详解一、WITH (NOLOCK) 的本质二、工作
阅读更多...
springboot自定义注解RateLimiter限流注解技术文档详解

springboot自定义注解RateLimiter限流注解技术文档详解

《springboot自定义注解RateLimiter限流注解技术文档详解》文章介绍了限流技术的概念、作用及实现方式,通过SpringAOP拦截方法、缓存存储计数器,结合注解、枚举、异常类等核心组件,... 目录什么是限流系统架构核心组件详解1. 限流注解 (@RateLimiter)2. 限流类型枚举 (
阅读更多...
Java Thread中join方法使用举例详解

Java Thread中join方法使用举例详解

《JavaThread中join方法使用举例详解》JavaThread中join()方法主要是让调用改方法的thread完成run方法里面的东西后,在执行join()方法后面的代码,这篇文章主要介绍... 目录前言1.join()方法的定义和作用2.join()方法的三个重载版本3.join()方法的工作原
阅读更多...
Spring AI使用tool Calling和MCP的示例详解

Spring AI使用tool Calling和MCP的示例详解

《SpringAI使用toolCalling和MCP的示例详解》SpringAI1.0.0.M6引入ToolCalling与MCP协议,提升AI与工具交互的扩展性与标准化,支持信息检索、行动执行等... 目录深入探索 Spring AI聊天接口示例Function CallingMCPSTDIOSSE结束语
阅读更多...
C语言进阶(预处理命令详解)

C语言进阶(预处理命令详解)

《C语言进阶(预处理命令详解)》文章讲解了宏定义规范、头文件包含方式及条件编译应用,强调带参宏需加括号避免计算错误,头文件应声明函数原型以便主函数调用,条件编译通过宏定义控制代码编译,适用于测试与模块... 目录1.宏定义1.1不带参宏1.2带参宏2.头文件的包含2.1头文件中的内容2.2工程结构3.条件编
阅读更多...
PyTorch中的词嵌入层(nn.Embedding)详解与实战应用示例

PyTorch中的词嵌入层(nn.Embedding)详解与实战应用示例

《PyTorch中的词嵌入层(nn.Embedding)详解与实战应用示例》词嵌入解决NLP维度灾难,捕捉语义关系,PyTorch的nn.Embedding模块提供灵活实现,支持参数配置、预训练及变长... 目录一、词嵌入(Word Embedding)简介为什么需要词嵌入？二、PyTorch中的nn.Em
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2