服务器设计细节 之 【缓冲区模块】(memXXX接口、std::cpoy)

news2026/4/27 17:56:48
目录2.实现思想2.4.简单实现3.memXXX接口3.1.memcpy — 内存拷贝3.2.memmove — 内存移动3.3.memset — 内存填充3.4.memchr — 内存查找3.5.memcmp — 内存比较4.std::copy -- 范围拷贝1.模块概述Buffer 模块是一个基于线性内存空间的缓冲区组件用于临时存储数据和按序取出数据它通过读写偏移量机制避免了频繁的数据搬移同时能够自动处理空间不足的情况2.实现思想2.1.内存模型采用 std::vectorchar 作为底层内存空间其内部是一块连续的线性内存string不能够处理\0所以不采用2.2.缓冲区核心要素要素说明默认空间大小缓冲区初始容量默认为 1024 字节读偏移量_reader_idx标记当前读取位置的相对偏移量写偏移量_writer_idx标记当前写入位置的相对偏移量偏移量是相对于缓冲区起始地址的相对值而非绝对内存地址2.3.数据操作思想1写入数据流程从当前写偏移位置开始写入检查尾部空闲空间是否足够足够直接写入不足检查总空闲空间尾部 头部是否足够(足够将现有数据搬移到缓冲区起始位置整理碎片空间不足对缓冲区进行扩容)写入成功后写偏移量向后移动2读取数据流程从当前读偏移位置开始读取可读数据大小 写偏移量 - 读偏移量读取后读偏移量向后移动2.4.简单实现#include vector #include cstdint #include cassert #include algorithm #include string #include cstring #define BUFFER_DEFAULT_SIZE 1024 class Buffer { private: std::vectorchar _buffer;//缓冲区 uint64_t _reader_idx; //读偏移 uint64_t _writer_idx; //写偏移 public: Buffer():_reader_idx(0), _writer_idx(0), _buffer(BUFFER_DEFAULT_SIZE){} char* Begin(){ return *_buffer.begin(); } //获取当前写入起始地址 char* WritePosition() { return Begin() _writer_idx; } //获取当前读取起始地址 char* ReadPosition() { return Begin() _reader_idx; } //获取末尾空间大小---写偏移之后的空间大小 uint64_t TailIdleSize() { return _buffer.size() - _writer_idx; } //获取头部空间大小---读偏移之前的空间大小 uint64_t FrontIdleSize() { return _reader_idx; } //获取可读数据大小 前闭后开 uint64_t ReadableSize() { return _writer_idx - _reader_idx; } //读偏移向后移动 void MoveReadOffset(uint64_t len) { assert(len ReadableSize()); _reader_idx len; } //写偏移向后移动 void MoveWriteOffset(uint64_t len) { assert(len TailIdleSize()); _writer_idx len; } //扩容逻辑确保写空间足够 void EnsureWriteSpace(uint64_t len) { // 情况1尾部空间足够直接返回 if (len TailIdleSize()) { return; } uint64_t readable ReadableSize(); // 情况2尾部空间不足但总空闲空间足够需要整理碎片 if (len TailIdleSize() FrontIdleSize()) { // 将可读数据移动到缓冲区起始位置 std::memmove(Begin(), ReadPosition(), readable); _reader_idx 0; _writer_idx readable; } // 情况3总空闲空间也不够需要扩容 else { // 先整理碎片到起始位置再扩容 if (_reader_idx 0) { std::memmove(Begin(), ReadPosition(), readable); _reader_idx 0; _writer_idx readable; } // 扩容到至少能容纳 (readable len) 字节 _buffer.resize(readable len); } } //写入数据 void Write(const void* data, uint64_t len) { EnsureWriteSpace(len); const char* d (const char*)data; std::copy(d, d len, WritePosition()); } //移动偏移量 void WriteAndPush(const void* buf, uint64_t len) { Write(buf, len); MoveWriteOffset(len); } //复用逻辑 void WriteString(const std::string data) { Write(data.c_str(), data.size()); } void WriteStringAndPush(const std::string data) { WriteString(data); MoveWriteOffset(data.size()); } void WriteBuffer(Buffer data) { Write(data.ReadPosition(), data.ReadableSize()); } void WriteBufferAndPush(Buffer data) { WriteBuffer(data); MoveWriteOffset(data.ReadableSize()); } //读取数据 void Read(void* buffer, uint64_t len) { assert(len ReadableSize()); std::copy(ReadPosition(), ReadPosition() len, (char*)buffer); } //移动偏移量 void ReadAndPop(void* buf, uint64_t len) { Read(buf, len); MoveReadOffset(len); } //强调复用逻辑 std::string ReadAsString(uint64_t len) { assert(len ReadableSize()); return std::string(ReadPosition(), len); } std::string ReadAsStringAndPop(uint64_t len) { std::string ret ReadAsString(len); MoveReadOffset(len); return ret; } //查找换行符 char* FindCRLF() { char* res (char*)memchr(ReadPosition(), \n, ReadableSize()); return res; } //针对ASCII字符有效 std::string Getline() { char* pos FindCRLF(); if(pos nullptr) return ; return ReadAsString(pos - ReadPosition() 1); } std::string GetlineAndPop() { std::string ret Getline(); MoveReadOffset(ret.size()); return ret; } //清空缓冲区 void Clear() { _writer_idx _reader_idx 0; } };3.memXXX接口3.1.memcpy — 内存拷贝项目说明函数原型void* memcpy(void* dest, const void* src, size_t n);头文件cstring功能从src复制n个字节到dest参数dest: 目标地址src: 源地址n: 拷贝字节数返回值返回dest指针安全性不安全。若dest和src内存重叠行为未定义适用场景两块不重叠内存的拷贝例如缓冲区读写、结构体复制性能极快编译器通常做极致优化示例memcpy(write_pos, data, len);3.2.memmove — 内存移动项目说明函数原型void* memmove(void* dest, const void* src, size_t n);头文件cstring功能从src复制n个字节到dest参数dest: 目标地址src: 源地址n: 拷贝字节数返回值返回dest指针安全性安全。允许dest和src内存重叠内部会判断重叠方向并选择合适拷贝顺序适用场景同一块内存内数据的搬移例如整理碎片、删除中间元素性能略慢于memcpy因为有重叠判断但差距极小示例memmove(buf, buf reader_idx, readable);3.3.memset — 内存填充项目说明函数原型void* memset(void* str, int c, size_t n);头文件cstring功能将str指向内存的前n个字节设置为值c参数str: 目标地址c: 要设置的值以int传入实际转为unsigned charn: 填充字节数返回值返回str指针安全性安全。但需确保n不超出有效内存范围适用场景初始化内存为 0、填充固定值、清除敏感数据性能极快通常会使用 CPU 特殊指令优化示例memset(obj, 0, sizeof(obj));3.4.memchr — 内存查找项目说明函数原型void* memchr(const void* str, int c, size_t n);头文件cstring功能在str指向的前n个字节中查找字符c的首次出现参数str: 搜索起始地址c: 要查找的字符n: 搜索范围字节数返回值找到返回指向该字节的指针未找到返回nullptr安全性安全。不会越界访问超出n的内存适用场景查找分隔符如\n、定位特定标记字节性能线性扫描中等速度。查找大块数据时性能不如专有算法示例memchr(buf read_idx, \n, readable_size);3.5.memcmp — 内存比较项目说明函数原型int memcmp(const void* ptr1, const void* ptr2, size_t n);头文件cstring功能比较ptr1和ptr2指向的前n个字节参数ptr1: 第一块内存ptr2: 第二块内存n: 比较字节数返回值0ptr1小于ptr20相等0ptr1大于ptr2安全性安全。比较前n个字节不会越界适用场景二进制数据比较、检查数据是否相同性能逐字节比较大块数据可考虑先比较首字节或哈希示例memcmp(buf1, buf2, 16);memcpy 本身不会检查边界如果长度不正确就会发生越界导致未定义行为4.std::copy -- 范围拷贝项目说明函数原型templateclass InputIt, class OutputIt OutputIt std::copy(InputIt first, InputIt last, OutputIt d_first);头文件algorithm功能将[first, last)范围内的元素拷贝到以d_first为起点的目标区域参数first: 源范围起始迭代器last: 源范围结束迭代器不包含d_first: 目标范围起始迭代器返回值指向目标范围最后一个被拷贝元素的下一个位置的迭代器底层实现对平凡可复制类型如char编译器通常会优化为memmove安全性若目标范围与源范围重叠且d_first在[first, last)内行为未定义类型安全编译期检查无需手动计算字节数自动推导类型大小泛型支持适用于任何满足输入/输出迭代器概念的类型不仅限于char*适用场景C 风格代码泛型编程非平凡类型对象的拷贝性能平凡类型与memmove相当非平凡类型触发赋值运算符可能较慢示例std::copy(d, d len, WritePosition());

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/2560228.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

SpringBoot-17-MyBatis动态SQL标签之常用标签

文章目录 1 代码1.1 实体User.java1.2 接口UserMapper.java1.3 映射UserMapper.xml1.3.1 标签if1.3.2 标签if和where1.3.3 标签choose和when和otherwise1.4 UserController.java2 常用动态SQL标签2.1 标签set2.1.1 UserMapper.java2.1.2 UserMapper.xml2.1.3 UserController.ja…

wordpress后台更新后 前端没变化的解决方法

使用siteground主机的wordpress网站,会出现更新了网站内容和修改了php模板文件、js文件、css文件、图片文件后,网站没有变化的情况。 不熟悉siteground主机的新手,遇到这个问题,就很抓狂,明明是哪都没操作错误&#x…

网络编程(Modbus进阶)

思维导图 Modbus RTU(先学一点理论) 概念 Modbus RTU 是工业自动化领域 最广泛应用的串行通信协议,由 Modicon 公司(现施耐德电气)于 1979 年推出。它以 高效率、强健性、易实现的特点成为工业控制系统的通信标准。 包…

UE5 学习系列(二)用户操作界面及介绍

这篇博客是 UE5 学习系列博客的第二篇,在第一篇的基础上展开这篇内容。博客参考的 B 站视频资料和第一篇的链接如下: 【Note】:如果你已经完成安装等操作,可以只执行第一篇博客中 2. 新建一个空白游戏项目 章节操作,重…

IDEA运行Tomcat出现乱码问题解决汇总

最近正值期末周,有很多同学在写期末Java web作业时,运行tomcat出现乱码问题,经过多次解决与研究,我做了如下整理: 原因: IDEA本身编码与tomcat的编码与Windows编码不同导致,Windows 系统控制台…

利用最小二乘法找圆心和半径

#include <iostream> #include <vector> #include <cmath> #include <Eigen/Dense> // 需安装Eigen库用于矩阵运算 // 定义点结构 struct Point { double x, y; Point(double x_, double y_) : x(x_), y(y_) {} }; // 最小二乘法求圆心和半径 …

使用docker在3台服务器上搭建基于redis 6.x的一主两从三台均是哨兵模式

一、环境及版本说明 如果服务器已经安装了docker,则忽略此步骤,如果没有安装,则可以按照一下方式安装: 1. 在线安装(有互联网环境): 请看我这篇文章 传送阵>> 点我查看 2. 离线安装(内网环境):请看我这篇文章 传送阵>> 点我查看 说明&#xff1a;假设每台服务器已…

XML Group端口详解

在XML数据映射过程中&#xff0c;经常需要对数据进行分组聚合操作。例如&#xff0c;当处理包含多个物料明细的XML文件时&#xff0c;可能需要将相同物料号的明细归为一组&#xff0c;或对相同物料号的数量进行求和计算。传统实现方式通常需要编写脚本代码&#xff0c;增加了开…

LBE-LEX系列工业语音播放器|预警播报器|喇叭蜂鸣器的上位机配置操作说明

LBE-LEX系列工业语音播放器|预警播报器|喇叭蜂鸣器专为工业环境精心打造&#xff0c;完美适配AGV和无人叉车。同时&#xff0c;集成以太网与语音合成技术&#xff0c;为各类高级系统&#xff08;如MES、调度系统、库位管理、立库等&#xff09;提供高效便捷的语音交互体验。 L…

(LeetCode 每日一题) 3442. 奇偶频次间的最大差值 I (哈希、字符串)

题目&#xff1a;3442. 奇偶频次间的最大差值 I 思路 &#xff1a;哈希&#xff0c;时间复杂度0(n)。 用哈希表来记录每个字符串中字符的分布情况&#xff0c;哈希表这里用数组即可实现。 C版本&#xff1a; class Solution { public:int maxDifference(string s) {int a[26]…

【大模型RAG】拍照搜题技术架构速览:三层管道、两级检索、兜底大模型

摘要 拍照搜题系统采用“三层管道&#xff08;多模态 OCR → 语义检索 → 答案渲染&#xff09;、两级检索&#xff08;倒排 BM25 向量 HNSW&#xff09;并以大语言模型兜底”的整体框架&#xff1a; 多模态 OCR 层 将题目图片经过超分、去噪、倾斜校正后&#xff0c;分别用…

【Axure高保真原型】引导弹窗

今天和大家中分享引导弹窗的原型模板&#xff0c;载入页面后&#xff0c;会显示引导弹窗&#xff0c;适用于引导用户使用页面&#xff0c;点击完成后&#xff0c;会显示下一个引导弹窗&#xff0c;直至最后一个引导弹窗完成后进入首页。具体效果可以点击下方视频观看或打开下方…

接口测试中缓存处理策略

在接口测试中&#xff0c;缓存处理策略是一个关键环节&#xff0c;直接影响测试结果的准确性和可靠性。合理的缓存处理策略能够确保测试环境的一致性&#xff0c;避免因缓存数据导致的测试偏差。以下是接口测试中常见的缓存处理策略及其详细说明&#xff1a; 一、缓存处理的核…

龙虎榜——20250610

上证指数放量收阴线&#xff0c;个股多数下跌&#xff0c;盘中受消息影响大幅波动。 深证指数放量收阴线形成顶分型&#xff0c;指数短线有调整的需求&#xff0c;大概需要一两天。 2025年6月10日龙虎榜行业方向分析 1. 金融科技 代表标的&#xff1a;御银股份、雄帝科技 驱动…

观成科技:隐蔽隧道工具Ligolo-ng加密流量分析

1.工具介绍 Ligolo-ng是一款由go编写的高效隧道工具&#xff0c;该工具基于TUN接口实现其功能&#xff0c;利用反向TCP/TLS连接建立一条隐蔽的通信信道&#xff0c;支持使用Let’s Encrypt自动生成证书。Ligolo-ng的通信隐蔽性体现在其支持多种连接方式&#xff0c;适应复杂网…

铭豹扩展坞 USB转网口 突然无法识别解决方法

当 USB 转网口扩展坞在一台笔记本上无法识别,但在其他电脑上正常工作时,问题通常出在笔记本自身或其与扩展坞的兼容性上。以下是系统化的定位思路和排查步骤,帮助你快速找到故障原因: 背景: 一个M-pard(铭豹)扩展坞的网卡突然无法识别了,扩展出来的三个USB接口正常。…

未来机器人的大脑:如何用神经网络模拟器实现更智能的决策?

编辑&#xff1a;陈萍萍的公主一点人工一点智能 未来机器人的大脑&#xff1a;如何用神经网络模拟器实现更智能的决策&#xff1f;RWM通过双自回归机制有效解决了复合误差、部分可观测性和随机动力学等关键挑战&#xff0c;在不依赖领域特定归纳偏见的条件下实现了卓越的预测准…

Linux应用开发之网络套接字编程(实例篇)

服务端与客户端单连接 服务端代码 #include <sys/socket.h> #include <sys/types.h> #include <netinet/in.h> #include <stdio.h> #include <stdlib.h> #include <string.h> #include <arpa/inet.h> #include <pthread.h> …

华为云AI开发平台ModelArts

华为云ModelArts&#xff1a;重塑AI开发流程的“智能引擎”与“创新加速器”&#xff01; 在人工智能浪潮席卷全球的2025年&#xff0c;企业拥抱AI的意愿空前高涨&#xff0c;但技术门槛高、流程复杂、资源投入巨大的现实&#xff0c;却让许多创新构想止步于实验室。数据科学家…

深度学习在微纳光子学中的应用

深度学习在微纳光子学中的主要应用方向 深度学习与微纳光子学的结合主要集中在以下几个方向&#xff1a; 逆向设计 通过神经网络快速预测微纳结构的光学响应&#xff0c;替代传统耗时的数值模拟方法。例如设计超表面、光子晶体等结构。 特征提取与优化 从复杂的光学数据中自…