当前位置：首页 > news >正文

C++ asio网络编程(5)简单异步echo服务器

news 来源：原创 2025/7/19 13:14:56

上一篇文章:C++ asio网络编程(4)异步读写操作及注意事项

文章目录

前言
一、Session类
- 1.代码
- 2.代码详解
- 3.实现Session类
- - 1.构造函数
  - 2.handle_read
  - 3.介绍一下boost的封装函数和api
  - 4.handle_write
二、Server类
- 1.代码
- 2.代码思路详解
三、客户端
四、运行截图与流程图

前言

提示：这里可以添加本文要记录的大概内容：

前文已经介绍了异步操作的api，今天写一个简单的异步echo服务器，以应答为主
在这里插入图片描述

提示：以下是本篇文章正文内容，下面案例可供参考

一、Session类

Session类主要是处理客户端消息收发的会话类，为了简单起见，我们不考虑粘包问题，也不考虑支持手动调用发送的接口，只以应答的方式发送和接收固定长度(1024字节长度)的数据。

1.代码

#pragma once
#include<iostream>
#include<boost/asio.hpp>
using boost::asio::ip::tcp;class Session
{Session(boost::asio::io_context& ioc) :_socket(ioc){};tcp::socket& Socket(){return _socket;}void Start();//监听客户端的读写private://回调函数void handle_read(const boost::system::error_code& ec,size_t bytes_transferred);void handle_write(const boost::system::error_code& ec, size_t bytes_transferred);tcp::socket _socket;enum {max_length=1024};char _data[max_length];
};

2.代码详解

1.构造函数中传入一个上下文用来绑定socket
2.Start()用来监听客户端是否发来信息
3.回调函数中 handle_read 是读的回调函数，我们这里用上一个文章介绍的async_read_some
因为不会一次性读完，所以我们有第二个参数来显示已经读了多少数据
4.回调函数中的handle_write是写的回调函数，我们用boost::asio::async_write来一次性发送数据
5. _data用来接收客户端传递的数据
6. _socket为单独处理客户端读写的socket

3.实现Session类

1.构造函数

我们在构造函数中把数组初始化为0，然后直接调用读函数就行，他会一直等着，当用户发送数据，tcp底层有内容的时候，就会进行读

void Session::Start()
{memset(_data, 0, sizeof(_data));_socket.async_read_some(boost::asio::buffer(_data, max_length),std::bind(&Session::handle_read, this, placeholders::_1, placeholders::_2));
}

然后读了以后，我们要进行回调函数
这个回调函数的参数是两个的原因是因为源码中async_read_some要求了回调函数参数如下
在这里插入图片描述

2.handle_read

//读的回调函数
void Session::handle_read(const boost::system::error_code& ec, size_t bytes_transferred)
{if (ec)//0正确  1错误{cout << "read error" << endl;delete this;}else{cout << "server receivr data is "<<_data << endl;//将收到的数据发送回去boost::asio::async_write(_socket, boost::asio::buffer(_data, bytes_transferred),std::bind(&Session::handle_write,this, placeholders::_1, placeholders::_2));}
}

读完以后我们打印一下收到的数据
然后原封不动的将这个数据发送回去就行
我们用boost::asio::async_write来发送，这样可以保证数据一次性发送完，但其实用socket自带也都行，因为我们这样只做一个简单的应答式的而已，本身就不会出现长数据，只是一个模型而已，但这里用一个boost库自带的封装函数，就是为了介绍一下！！！！！！！！！！！！！！！！！！！！！

3.介绍一下boost的封装函数和api

在这里插入图片描述

参数列表有三个，第一个绑定socket，第二个传入的buffer，第三个std::bind

4.handle_write

在之前读完以后我们就准备将数据发送回去，所以就写，写的时候也调用我们这个回调函数，参数的原因与上面同理，查看源码即可

//写的回调函数
void Session::handle_write(const boost::system::error_code& ec, size_t bytes_transferred)
{ if (ec)//0正确  1错误{cout << "write error" << endl;delete this;}else{//发完了 就清除掉原先的memset(_data, 0, sizeof(_data));//继续读_socket.async_read_some(boost::asio::buffer(_data, bytes_transferred),std::bind(&Session::handle_read, this, placeholders::_1, placeholders::_2));}
}

二、Server类

这个用来管理客户端连接的，我们初始化一个监听器，当有客户端进行连接的时候，我们就内部new一个Session去单独服务这个客户端

1.代码

class Server
{
public:Server(boost::asio::io_context& ioc, short port);private:void start_accept();//监听连接void handle_accept(Session* new_session, const boost::system::error_code& ec);//当有连接的时候触发这个回调函数boost::asio::io_context& _ioc;//因为上下文不允许被复制 所以用引用tcp::acceptor _acceptor;
};

Server::Server(boost::asio::io_context& ioc, short port) :_ioc(ioc), _acceptor(ioc, tcp::endpoint(tcp::v4(), port))
{start_accept();
}void Server::start_accept()
{Session* new_session = new Session(_ioc);_acceptor.async_accept(new_session->Socket(),std::bind(&Server::handle_accept,this,new_session,placeholders::_1));
}void Server::handle_accept(Session* new_session, const boost::system::error_code& ec)
{if (!ec)//成功{new_session->Start();}else{delete new_session;}start_accept();//再次准备
}

2.代码思路详解

首先我们初始化一个上下文ioc准备好，因为创建一个socket连接需要这个东西
然后我们调用这个函数start_accept()
这个函数内部会创建一个Session准备好，相当于我提前准备一个服务员准备好
然后当监听器 _acceptor 被触发的时候，我们就调用回调函数(相当于一个房间),让之前准备好的服务员去服务这个客人

_acceptor.async_accept(new_session->Socket(),std::bind(&Server::handle_accept,this,new_session,placeholders::_1));

但是这里要提前绑定一个new_session这个参数，因为根据源码，回调函数的参数只能有一个，就是错误码

在这里插入图片描述
然后进入handle_accept函数，如果没有错误我们就调用这个创建的session去进行Start()
在Start中就会进行读写循环调用

三、客户端

客户端这么我们就不进行说明，因为今天做的是简单的异步echo模型，应答式的，并且客户端我们在第二节文章讲过了，用的客户端代码也是第二个文章的代码，所以就不进行说明

#include<boost/asio.hpp>
#include <iostream>
const int MAX_LENGTH = 1024;//表示发送和接收最大长度为1024字节
int main()
{while (1){try{//创建上下文服务boost::asio::io_context ios;//创建endpointboost::asio::ip::tcp::endpointremote_ep(boost::asio::ip::make_address("127.0.0.1"), 10086);//127.0.0.1是本机的回路地址 因为客户端和服务端在同一地址//服务器就是本机boost::asio::ip::tcp::socket sock(ios, remote_ep.protocol());boost::system::error_code error = boost::asio::error::host_not_found;sock.connect(remote_ep, error);if (error){std::cout << "connect failed,code is:" << error.value() <<"error message is" << error.message() << std::endl;return 0;}std::cout << "请输入需要发送的信息:";char request[MAX_LENGTH];std::cin.getline(request, MAX_LENGTH);size_t request_length = strlen(request);//获取实际要发送的数据长度//发送数据boost::asio::write(sock, boost::asio::buffer(request, request_length));char reply[MAX_LENGTH];//存储接收数据//用read读size_t reply_length = 0;boost::system::error_code ec;reply_length = sock.read_some(boost::asio::buffer(reply, MAX_LENGTH), ec);if (ec){std::cerr << "Read failed: " << ec.message() << std::endl;return 0;}std::cout << "回复:";std::cout.write(reply, reply_length);std::cout << "\n";}catch (std::exception& e){std::cerr << "Exception is: " << e.what() << std::endl;}}return 0;
}

四、运行截图与流程图

在这里插入图片描述
服务端接收完直接原文回给客户端就行
这里服务端报错 read error是因为客户端每发送一次就会断开连接，这是我们之前代码设定的

C++ asio网络编程(5)简单异步echo服务器

上一篇文章:C asio网络编程(4)异步读写操作及注意事项文章目录前言一、Session类1.代码2.代码详解3.实现Session类1.构造函数2.handle_read3.介绍一下boost的封装函数和api4.handle_write 二、Server类1.代码2.代码思路详解三、客户端四、运行截图与流程图前言提示&…...

编程日记 2025/7/19 13:14:56

VBA会被Python代替吗

VBA不会完全被Python取代、但Python在自动化、数据分析与跨平台开发等方面的优势使其越来越受欢迎、两者将长期并存且各具优势。 Python以其易于学习的语法、强大的开源生态系统和跨平台支持，逐渐成为自动化和数据分析领域的主流工具。然而，VBA依旧在Exc…...

编程日记 2025/7/19 4:02:38

在Web应用中集成Google AI NLP服务的完整指南：从Dialogflow配置到高并发优化

在当今数字化客服领域，自然语言处理(NLP)技术已成为提升用户体验的关键。Google AI提供了一系列强大的NLP服务，特别是Dialogflow，能够帮助开发者构建智能对话系统。本文将详细介绍如何在Web应用中集成这些服务，解决从模型训练到高并发处理的全套技术挑战。一、Dialogflow…...

编程日记 2025/7/19 1:09:20

Linux服务器连接SSH工具FinalShell安装使用支持Linux文件上传下载

前言记录连接Linux服务器SSH工具FinalShell，支持可视化上传下载及查看服务器负载状态安装使用安装地址官网下载:https://finalshell-ssh.com/ 通过网盘分享的文件：shell 链接: https://pan.baidu.com/s/1ZFcD_Js-r_lE3IV8wuuA5A?pwde72f 提取码:…...

编程日记 2025/7/19 12:34:21

【Java ee初阶】IP协议

网络层 IP 协议 1) 地址管理针对网络上的各种设备，所在的位置，进行描述和区分 > IP 地址 2) 路由选择网络结构非常复杂挑选出合适的路径 IP 协议的报文结构 ipv4 ipv6 其他版本没有大规模推广使用~~ IP 协议中，报头也是变长的&a…...

编程日记 2025/7/19 12:36:27

WSL-Ubuntu 中安装 Git LFS 记录

#记录工作一、问题背景在 Windows Subsystem for Linux（WSL）的 Ubuntu 环境下进行开发时，当我们需要管理 Git 仓库中的大文件，使用 Git LFS（Large File Storage）是一个很好的解决方案。但在执行git lfs…...

编程日记 2025/7/19 13:05:11

Ubuntu源码版comfyui的安装

Comfyui也出桌面版了，但是想让大家多个人都使用怎么办呢？也有方法，安装Linux版，启动后会生成个网页地址，打开就能用了。 1、先来看下本地安装环境配置： 系统：Ubuntu 22.04 内存：2…...

编程日记 2025/7/19 12:35:20

Clang实现C++文件分析，含Python实战

最近的项目，需要获取到C代码中的Git修改过的函数信息，决定通过抽象语法树AST的方式，分析出文件内容后，通过匹配git diff修改的行号信息得知是什么函数。了解到Clang 能够进行C、C代码的分析，记录一下。一、Clang AST…...

编程日记 2025/7/19 12:46:25

MFC listctrl修改背景颜色

在 MFC 中修改 ListCtrl 控件的行背景颜色，需要通过自绘（Owner-Draw）机制实现。以下是详细的实现方法： 方法一：通过自绘（Owner-Draw）实现步骤 1：启用自绘属性在对话框设计器中选…...

编程日记 2025/7/19 12:52:44

[Git]ssh模式每次提交都要输入密码

问题描述连接用的ssh，不是https。每次git提交都要输入密码，很麻烦。原因分析 ssh模式需要在git服务端保存密钥，不然每次都会校验用户的身份。解决方案 1.生成密钥进到用户路径下 C:\Users\szx\, 打开bash 生成密钥： s…...

编程日记 2025/7/19 12:45:27

请解释 React Native 的新架构（Fabric 和 TurboModules）与旧架构的主要区别

React Native 的新架构（Fabric 和 TurboModules）是对旧架构的重大革新，主要解决了旧架构在性能、线程模型和原生互操作性等方面的瓶颈。以下是新旧架构的核心区别： 1. 线程模型与异步通信旧架构： 三层线程模型&…...

编程日记 2025/7/19 12:26:50

大小端的判断方法

大小端（Endianness） 是计算机存储多字节数据（如整数、浮点数）时的两种不同方式，决定了字节在内存中的排列顺序。 1. 大端（Big-Endian） 高位字节存储在低地址，低位字节存储在高地址。…...

编程日记 2025/7/19 9:47:10

技术视界 | 青龙机器人训练地形详解（四）：复杂地形精讲之斜坡

在前几篇文章中，我们依次讲解了如何创建一个地形、如何将地形添加到训练环境中，并在上一期深入分析了复杂地形之一——台阶地形的创建方式与训练意义。本文将继续聚焦复杂地形训练中另一类代表性地形——斜坡（Slope）与金字塔斜坡&…...

编程日记 2025/7/10 4:53:07

典籍知识问答重新生成和消息修改Bug修改

1.Bug： {messageId: "temp-user-1747051925999",…} messageId : "temp-user-1747051925999" newContent : "关于选中的内容：\"The ancient people lived long by following natural laws\"，我的问题是&…...

编程日记 2025/7/14 11:00:30

交易所开发-如何开发一个交易所

交易所开发全流程指南：从架构设计到合规落地 ——2025年数字资产交易平台的构建逻辑与技术实践一、开发核心流程：五阶段方法论 1. 需求定位与合规先行市场细分：明确交易所类型（CEX、DEX或混合型），选择目…...

编程日记 2025/7/15 20:58:42

工具篇-如何在Github Copilot中使用MCP服务?

Model Context Protocol (MCP) 是由 Anthropic 公司于 2024 年 11 月推出的一种开放协议标准，目的在于标准化 LLM 与外部数据源、工具及服务之间的交互方式。 MCP 被广泛类比为 “AI 领域的 USB-C 接口 ”。一、vscode的安装下载vscode Visual Studio …...

编程日记 2025/7/15 4:03:12

MATLAB机器人系统工具箱中的loadrobot和importrobot

loadrobot和importrobot是 MATLAB 机器人系统工具箱中用于创建机器人模型的两个核心函数，它们的主要区别可以从以下几个方面来理解： 1. 模型来源 loadrobot 直接加载工具箱预定义的机器人模型（如 UR5e、Panda、Kinova 等）。这些模…...

编程日记 2025/7/18 8:27:05

django之视图

django vs drf 首先要区分django 和 django rest framework(drf)。 django是前后端不分离的，后端写模板（template）渲染成html之后返回给浏览器。 drf是适应前后端分离的架构，基于django做的封装，提供的rest API规范…...

编程日记 2025/7/17 9:46:24

深入探讨dubbo组件的实践

目录 1、dubbo概述 1.1、介绍 1.2、RPC 1.3、区别 1.4、优点 2、dubbo分层 2.1、层级分类 1. Service 服务层（业务层） 2. Config 配置层 3. Proxy 服务代理层 4. Registry 注册中心层 5. Cluster 集群容错层 6. Monitor 监控层 7. Protoco…...

编程日记 2025/7/11 23:15:17

2.1 微积分基本想法

总结性表达微积分的核心思想在于用简单图形逼近复杂形状的面积。牛顿与莱布尼茨通过"以直代曲"的突破性思路，将曲线围成的面积分解为无限个矩形之和，形成两大核心工具： 极限思想：通过无限细分矩形底边（Δ…...

编程日记 2025/7/15 21:40:51

学习threejs，使用Physijs物理引擎，加载各种几何体网格对象

👨‍⚕️ 主页： gis分享者 👨‍⚕️ 感谢各位大佬点赞👍 收藏⭐ 留言📝 加关注✅! 👨‍⚕️ 收录于专栏：threejs gis工程师文章目录一、🍀前言1.1 ☘️Physijs 物理引擎1.1.1 ☘️…...

编程日记 2025/7/17 20:41:19

Excel分组计算求和的两种实现方案

文章目录背景样例数据方案一、函数求和实现步骤方案二、数据透视表实现步骤背景在Excel文档中，经常会进行数据的求和计算，可使用不同的方式实现，记录下来，方便备查。样例数据已有商品销量信息，包含销售日期、…...

编程日记 2025/7/16 5:49:49

nestjs[一文学懂如何在nestjs中对npm功能包封装]

问题描述 NPM（Node Package Manager）是Node.js的包管理工具，它允许开发者轻松地分享、安装和管理依赖包，促进了代码的复用性和项目协作。而npm插件库将是nodejs开发中不可缺失的重要组成因素。在nestjs中，官方已经给…...

编程日记 2025/7/19 7:58:29

PHP 连接和使用 Kafka 的指南

首先说明，我的是系统版本是：Ubuntu 22.04.3，下面是详细步骤 ###### PHP 连接和使用 Kafka 的指南 ###### # 安装依赖 sudo apt-get install -y librdkafka-dev # 安装必要的依赖 # 对于 Ubuntu/Debian sudo apt-get update sudo apt-get in…...

编程日记 2025/7/15 23:44:15

# 07_Elastic Stack 从入门到实践（七）---1

07_Elastic Stack 从入门到实践（七）—1 一、Filebeat入门之读取 Nginx 日志文件 1、首先启动 Elasticsearch 集群和 Nginx 服务，打开GoogleChrome 浏览器，点击 elasticsearch-head 插件，连接Elasticsearch 集群服务器。 # 查看网卡名 $ ip addr# 修改网卡配置，改为…...

编程日记 2025/7/18 5:03:55

CSS-PureCss样式开发

CSS-PureCss样式开发 1-开发说明 1-引入Pure.css2-直接拷贝代码 2-参考网址 purecss中文网 3-代码模板 <!DOCTYPE html> <html lang"zh-CN"><head><meta charset"UTF-8"><meta name"viewport" content"wid…...

编程日记 2025/7/17 22:42:53

学习笔记：Conda 环境共享

1. 环境共享的重要性环境共享是协作项目中非常实用的功能，它能确保整个项目的协作人员都使用相同的软件包，并保证这些包的版本正确。这可以避免因环境配置不同而导致的“在我的机器上可以运行”之类的问题。 2. 导出当前环境配置如果需要将当前的 C…...

编程日记 2025/7/15 12:30:55

蓝牙AVDTP协议概述

1.AVDTP 概念 AVDTP 即 AUDIO/VIDEO DISTRIBUTION TRANSPORT PROTOCOL（音视频分配传输协议），主要负责 A/V stream 的协商、建立及传输程序，还指定了设备之前传输 A/V stream 的消息格式. AVDTP 的传输机制和消息格式是以 RTP 为基…...

编程日记 2025/7/14 1:29:56

Java面试终极篇：Sentinel+Seata+Kafka Streams高并发架构实战

面试官：张总（严肃脸） 程序员：小王（紧张冒冷汗） 第一轮：分布式基础张总：说说Spring Cloud Alibaba的Sentinel和Nacos的区别？ 小王：（结巴&#…...

编程日记 2025/7/18 22:49:43

提权相关记录

Windows potato本地提权常见potato提权：BadPotato、EfsPotato、SweetPotato、JuicyPotato0、PrintNotifyPotato、RottenPotato 提权前置条件：拥有SeImpersonatePrivilege或SeAssignPrimaryTokenPrivilege权限其中一个。可以通过命令whoami /priv或whoa…...

编程日记 2025/7/19 1:16:40

信息化、数字化、数智化之间的区别和联系

在如今这个信息技术飞速发展的时代，我们常常会听到“信息化”、“数字化”和“数智化”这三个术语。对于大多数人来说，这些词汇听起来既高深又晦涩，但其实它们和我们的生活、工作密切相关。如果你能理解它们的概念与区别，你不仅能…...

编程日记 2025/7/18 6:38:01

制造业IT管理方法论：柔性变更与数据治理的融合实践

1. 引言随着工业4.0时代的深入发展，信息技术（IT）与运营技术（OT）的融合日益紧密，对制造企业的IT管理提出了前所未有的挑战与机遇。传统的IT管理框架，如ITIL（信息技术基础架构库&…...

编程日记 2025/7/14 16:41:45

深入了解 gmx_RRCS：计算原理、操作步骤及输出文件解析

前段时间，我写了一篇介绍gmx_RRCS的推文，之后有不少人希望我能再出一个更详细的版本，尤其是对gmx_RRCS输出文件含义进行解读。大家的反馈我都看到了，所以准备再写一篇，仔细讲讲输出文件里各项内容是什么意思&#xff0…...

编程日记 2025/7/15 1:13:51

MySQL 8.0 OCP 1Z0-908 题目解析(1)

题目001 Choose two. User fwuserlocalhost is registered with the SQL Enterprise Firewall and has been granted privileges for the sakila database. Examine these commands that you executed and the results: mysql> SELECT MODE FROM INFORMATION_SCHEMA.SQL…...

编程日记 2025/7/14 5:24:41

文章目录

前言

一、Session类

1.代码

2.代码详解

3.实现Session类

1.构造函数

2.handle_read

3.介绍一下boost的封装函数和api

4.handle_write

二、Server类

1.代码

2.代码思路详解

三、客户端

四、运行截图与流程图

相关文章：