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。

相关文章

JAVA系统中Spring Boot应用程序的配置文件application.yml使用详解

JAVA系统中Spring Boot应用程序的配置文件application.yml使用详解

《JAVA系统中SpringBoot应用程序的配置文件application.yml使用详解》：本文主要介绍JAVA系统中SpringBoot应用程序的配置文件application.yml的... 目录文件路径文件内容解释1. Server 配置2. Spring 配置3. Logging 配置4. Ma
阅读更多...
利用Python编写一个简单的聊天机器人

利用Python编写一个简单的聊天机器人

《利用Python编写一个简单的聊天机器人》这篇文章主要为大家详细介绍了如何利用Python编写一个简单的聊天机器人,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 使用 python 编写一个简单的聊天机器人可以从最基础的逻辑开始，然后逐步加入更复杂的功能。这里我们将先实现一个简单的
阅读更多...
mac中资源库在哪? macOS资源库文件夹详解

mac中资源库在哪? macOS资源库文件夹详解

《mac中资源库在哪?macOS资源库文件夹详解》经常使用Mac电脑的用户会发现，找不到Mac电脑的资源库，我们怎么打开资源库并使用呢？下面我们就来看看macOS资源库文件夹详解... 在 MACOS 系统中，「资源库」文件夹是用来存放操作系统和 App 设置的核心位置。虽然平时我们很少直接跟它打交道，但了
阅读更多...
关于Maven中pom.xml文件配置详解

关于Maven中pom.xml文件配置详解

《关于Maven中pom.xml文件配置详解》pom.xml是Maven项目的核心配置文件,它描述了项目的结构、依赖关系、构建配置等信息,通过合理配置pom.xml,可以提高项目的可维护性和构建效率... 目录1. POM文件的基本结构1.1 项目基本信息2. 项目属性2.1 引用属性3. 项目依赖4. 构
阅读更多...
Rust 数据类型详解

Rust 数据类型详解

《Rust数据类型详解》本文介绍了Rust编程语言中的标量类型和复合类型,标量类型包括整数、浮点数、布尔和字符,而复合类型则包括元组和数组,标量类型用于表示单个值,具有不同的表示和范围,本文介绍的非... 目录一、标量类型（Scalar Types）1. 整数类型（Integer Types）1.1 整数字
阅读更多...
Java操作ElasticSearch的实例详解

Java操作ElasticSearch的实例详解

《Java操作ElasticSearch的实例详解》Elasticsearch是一个分布式的搜索和分析引擎,广泛用于全文搜索、日志分析等场景,本文将介绍如何在Java应用中使用Elastics... 目录简介环境准备1. 安装 Elasticsearch2. 添加依赖连接 Elasticsearch1. 创
阅读更多...
Redis缓存问题与缓存更新机制详解

Redis缓存问题与缓存更新机制详解

《Redis缓存问题与缓存更新机制详解》本文主要介绍了缓存问题及其解决方案,包括缓存穿透、缓存击穿、缓存雪崩等问题的成因以及相应的预防和解决方法,同时,还详细探讨了缓存更新机制,包括不同情况下的缓存更... 目录一、缓存问题1.1 缓存穿透1.1.1 问题来源1.1.2 解决方案1.2 缓存击穿1.2.1
阅读更多...
PyTorch使用教程之Tensor包详解

PyTorch使用教程之Tensor包详解

《PyTorch使用教程之Tensor包详解》这篇文章介绍了PyTorch中的张量（Tensor）数据结构,包括张量的数据类型、初始化、常用操作、属性等,张量是PyTorch框架中的核心数据结构,支持... 目录1、张量Tensor2、数据类型3、初始化（构造张量）4、常用操作5、常用属性5.1 存储（st
阅读更多...
Python 中 requests 与 aiohttp 在实际项目中的选择策略详解

Python 中 requests 与 aiohttp 在实际项目中的选择策略详解

《Python中requests与aiohttp在实际项目中的选择策略详解》本文主要介绍了Python爬虫开发中常用的两个库requests和aiohttp的使用方法及其区别,通过实际项目案... 目录一、requests 库二、aiohttp 库三、requests 和 aiohttp 的比较四、requ
阅读更多...
VUE动态绑定class类的三种常用方式及适用场景详解

VUE动态绑定class类的三种常用方式及适用场景详解

《VUE动态绑定class类的三种常用方式及适用场景详解》文章介绍了在实际开发中动态绑定class的三种常见情况及其解决方案,包括根据不同的返回值渲染不同的class样式、给模块添加基础样式以及根据设... 目录前言1.动态选择class样式（对象添加：情景一）2.动态添加一个class样式（字符串添加：情
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2