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内存分配与JVM参数详解(推荐)

Java内存分配与JVM参数详解(推荐)

《Java内存分配与JVM参数详解(推荐)》本文详解JVM内存结构与参数调整,涵盖堆分代、元空间、GC选择及优化策略,帮助开发者提升性能、避免内存泄漏,本文给大家介绍Java内存分配与JVM参数详解,... 目录引言JVM内存结构JVM参数概述堆内存分配年轻代与老年代调整堆内存大小调整年轻代与老年代比例元空
阅读更多...
Python中注释使用方法举例详解

Python中注释使用方法举例详解

《Python中注释使用方法举例详解》在Python编程语言中注释是必不可少的一部分,它有助于提高代码的可读性和维护性,：本文主要介绍Python中注释使用方法的相关资料,需要的朋友可以参考下... 目录一、前言二、什么是注释？示例：三、单行注释语法：以 China编程# 开头，后面的内容为注释内容示例：示例：四
阅读更多...
mysql表操作与查询功能详解

mysql表操作与查询功能详解

《mysql表操作与查询功能详解》本文系统讲解MySQL表操作与查询,涵盖创建、修改、复制表语法,基本查询结构及WHERE、GROUPBY等子句,本文结合实例代码给大家介绍的非常详细,感兴趣的朋友跟随... 目录01.表的操作1.1表操作概览1.2创建表1.3修改表1.4复制表02.基本查询操作2.1 SE
阅读更多...
MySQL中的锁机制详解之全局锁,表级锁,行级锁

MySQL中的锁机制详解之全局锁,表级锁,行级锁

《MySQL中的锁机制详解之全局锁,表级锁,行级锁》MySQL锁机制通过全局、表级、行级锁控制并发,保障数据一致性与隔离性,全局锁适用于全库备份,表级锁适合读多写少场景,行级锁(InnoDB)实现高并... 目录一、锁机制基础：从并发问题到锁分类1.1 并发访问的三大问题1.2 锁的核心作用1.3 锁粒度分
阅读更多...
MySQL数据库中ENUM的用法是什么详解

MySQL数据库中ENUM的用法是什么详解

《MySQL数据库中ENUM的用法是什么详解》ENUM是一个字符串对象,用于指定一组预定义的值,并可在创建表时使用,下面：本文主要介绍MySQL数据库中ENUM的用法是什么的相关资料,文中通过代码... 目录mysql 中 ENUM 的用法一、ENUM 的定义与语法二、ENUM 的特点三、ENUM 的用法1
阅读更多...
MySQL count()聚合函数详解

MySQL count()聚合函数详解

《MySQLcount()聚合函数详解》MySQL中的COUNT()函数,它是SQL中最常用的聚合函数之一,用于计算表中符合特定条件的行数,本文给大家介绍MySQLcount()聚合函数,感兴趣的朋... 目录核心功能语法形式重要特性与行为如何选择使用哪种形式？总结深入剖析一下 mysql 中的 COUNT
阅读更多...
一文详解Git中分支本地和远程删除的方法

一文详解Git中分支本地和远程删除的方法

《一文详解Git中分支本地和远程删除的方法》在使用Git进行版本控制的过程中,我们会创建多个分支来进行不同功能的开发,这就容易涉及到如何正确地删除本地分支和远程分支,下面我们就来看看相关的实现方法吧... 目录技术背景实现步骤删除本地分支删除远程www.chinasem.cn分支同步删除信息到其他机器示例步骤
阅读更多...
Go语言数据库编程GORM 的基本使用详解

Go语言数据库编程GORM 的基本使用详解

《Go语言数据库编程GORM的基本使用详解》GORM是Go语言流行的ORM框架,封装database/sql,支持自动迁移、关联、事务等,提供CRUD、条件查询、钩子函数、日志等功能,简化数据库操作... 目录一、安装与初始化1. 安装 GORM 及数据库驱动2. 建立数据库连接二、定义模型结构体三、自动迁
阅读更多...
mysql中的服务器架构详解

mysql中的服务器架构详解

《mysql中的服务器架构详解》：本文主要介绍mysql中的服务器架构,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录1、背景2、mysql服务器架构解释3、总结1、背景简单理解一下mysqphpl的服务器架构。2、mysjsql服务器架构解释mysql的架
阅读更多...
ModelMapper基本使用和常见场景示例详解

ModelMapper基本使用和常见场景示例详解

《ModelMapper基本使用和常见场景示例详解》ModelMapper是Java对象映射库,支持自动映射、自定义规则、集合转换及高级配置（如匹配策略、转换器）,可集成SpringBoot,减少样板... 目录1. 添加依赖2. 基本用法示例：简单对象映射3. 自定义映射规则4. 集合映射5. 高级配置匹
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2