C++ 怎么在 Raft 状态机中实现日志的持久化落盘与快照(Snapshot)截断压缩

星枫小哥_8458

星枫小哥_8458

2026-10-22

998人浏览

原创

raft日志落盘需用fsync保证原子性,快照截断须同步更新lastincludedindex等元数据并原子替换文件,序列化禁用memcpy而应使用protobuf或自定义协议,读取日志需按快照、内存、磁盘优先级查询。

c++ 怎么在 raft 状态机中实现日志的持久化落盘与快照(snapshot)截断压缩

日志落盘必须绕过缓冲,用 fsync 保证原子写入

Raft 要求日志条目在返回客户端成功前已持久化,否则节点崩溃后可能丢失已提交的日志。C++ 标准库的 std::ofstream 默认带缓冲,直接 write() + close() 不够——close() 不触发 fsync,内核可能延迟刷盘。

实操建议:

  • 用 open() 系统调用打开文件,带上 O_WRONLY | O_CREAT | O_APPEND | O_SYNC(O_SYNC 开销大但最简单);或用 O_DSYNC(只同步数据不强制同步元数据,性能更好)
  • 若用 C++ iostream,必须显式调用 flush() + fsync():
    std::ofstream f("log.bin", std::ios::binary | std::ios::app);
    f.write(buf, len);
    f.flush();
    ::fsync(f.fileno()); // 注意:需包含 <unistd.h></unistd.h>
  • 每条日志单独 fsync 性能差,可批量写入后一次 fsync,但需维护“已提交索引”与“已落盘索引”的映射,避免覆盖未同步条目

Snapshot 截断不能只删旧日志文件,要更新 lastIncludedIndex 和 lastIncludedTerm

快照不是简单压缩打包,而是状态机当前一致点的完整备份。截断日志时若只删除 log_0001 到 log_0010,但没更新 Raft 模块内部的 lastIncludedIndex,下次重启会误判日志起始位置,导致 AppendEntries 请求被拒绝或重放错误日志。

关键动作必须成对发生:

  • 生成快照文件(如 snapshot_0015.bin)的同时,把对应状态机的 lastIncludedIndex = 15、lastIncludedTerm = 4 写入快照元数据头(固定前 16 字节)
  • 调用 truncateLogTo(lastIncludedIndex) 前,先将新快照原子替换旧快照(推荐先写临时文件 + rename())
  • 日志文件截断后,需重写日志索引映射表(如有),例如 LevelDB 中的 log_index_to_offset.db 必须删除 ≤ lastIncludedIndex 的所有键

快照序列化别用 memcpy 直拷内存,优先走 protobuf 或自定义二进制协议

状态机对象(比如一个 Map<string int></string> 缓存)若直接 memcpy(&obj, sizeof(obj)),会出严重问题:指针成员(如 std::string 内部的 char*)只拷地址,反序列化后访问野指针;虚函数表、RTTI 信息也全丢。

C++14
C++14

C++14 对 C++11 的修正与增强版本,适合旧系统维护和较老工具链兼容。

下载

安全做法:

  • 用 google::protobuf 定义 SnapshotData message,调用 SerializeToString() —— 它自动处理嵌套、变长字段、字节序
  • 若追求零依赖,手写序列化需分两遍:第一遍计算总长度(含字符串长度前缀),第二遍按顺序写入长度+内容;反序列化时严格校验长度字段防越界
  • 快照文件末尾追加 CRC32 校验和(非 MD5/SHA),读取时先验 checksum 再加载,避免磁盘位翻转导致状态机静默损坏

日志与快照共存时,readLogEntry(index) 必须查三处:快照、内存缓存、磁盘文件

客户端请求查询 index=12 的日志,此时系统可能:快照截止到 index=10,内存缓存了 index=11~13,磁盘上还有 index=11~20 的文件。硬编码只查磁盘会漏掉快照里已固化的内容,也不知该从哪份数据源取。

标准查询逻辑应为:

  • 若 index → 从快照元数据中提取(快照本身不存全部历史日志,但需提供 <code>GetStateAt(index) 接口供回滚用)
  • 若 index 在内存 buffer 范围内 → 直接返回
  • 否则定位到对应日志文件(如 log_0011.bin),用预建的 offset index 二分查找偏移量再 pread()

这里最容易被忽略的是快照的“覆盖语义”:index ≤ lastIncludedIndex 的日志条目在状态机层面已不可见,readLogEntry 返回空或抛异常都比返回过期内容安全。

C++免费学习笔记(深入):立即使用
在学习笔记中,你将探索 C++ 的入门与实战技巧!

相关专题

更多
c++和c语言的区别有哪些
c++和c语言的区别有哪些

c++和c语言的区别:1、面向对象编程(OOP)支持不同;2、新增特性不同;3、标准库不同;4、编译方式不同;5、命名空间不同等等。想了解更多c++的相关内容,可以阅读本专题下面的文章。

2024.03.14

2248

9

c++和python学习顺序推荐
c++和python学习顺序推荐

一般建议先学习C++,再学习Python,因为这样可以逐步从较为底层的编程语言向更高级的语言过渡。想了解更多python的相关内容,可以阅读本专题下面的文章。

2024.03.14

1019

6

python和c++学习性价比分析
python和c++学习性价比分析

Python易于学习,广泛应用于Web开发、数据科学和人工智能等领域,但性能较低。C语言性能高,适用于对性能要求较高的场景,如游戏开发和系统编程,但学习曲线陡峭,错误处理复杂。想了解更多python的相关内容,可以阅读本专题下面的文章。

2024.03.14

447

5

c语言和c++一样吗
c语言和c++一样吗

c语言和c++是两种不同的编程语言,虽然有相似之处,但存在显著差异。c语言专注于过程式编程和系统级开发,以简洁、高效著称。c++作为c语言的超集,引入了面向对象编程,增强了代码组织和管理能力,但学习曲线也更陡峭。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2024.03.14

327

5

c语言和c++先学哪个好
c语言和c++先学哪个好

初学者选择学习c语言还是c++语言,需要根据个人学习目标、背景以及编程兴趣和预期应用方向来决定。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2024.03.14

426

5

c语言和c++的区别和联系
c语言和c++的区别和联系

c语言和c++是计算机科学领域应用广泛的编程语言。虽然它们有着相似的基础,但它们在语言类型、语法功能和内存管理方面存在着显著差异。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2024.03.14

580

5

c++软件中文更改教程
c++软件中文更改教程

对于 ide,可通过打开设置,找到语言设置,选择中文,并保存更改。对于非 ide 应用程序,可查找设置或选项,选择语言设置,更改为中文,并保存更改。想了解更多c++的相关内容,可以阅读本专题下面的文章。

2024.03.21

1409

9

python和java和c++学习性价比分析
python和java和c++学习性价比分析

Python以其易学性、丰富的库和活跃的社区而著称,适合数据科学、人工智能和Web开发。Java以其跨平台性、企业级应用开发和Android应用开发而闻名。C++以其底层控制能力、高效性能和游戏开发而著称。选择哪种语言取决于个人兴趣、职业方向和特定需求。想了解更多python和java和c++的相关内容,可以阅读本专题下面的文章。

2024.03.22

1217

7

c++和c语言学习顺序推荐
c++和c语言学习顺序推荐

对于初学者,建议先学习C语言,掌握编程基础后再转入C++,便于理解面向对象编程概念。有编程经验者可直接学习C++,快速接触高级编程技术。想了解更多c++和c语言的相关内容,可以阅读本专题下面的文章。

2024.03.25

1325

9

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
C++ 手册教程
C++ 手册教程

共41课时 | 78.4万人学习

尚学堂ios初级视频教程
尚学堂ios初级视频教程

共77课时 | 21.2万人学习

C++ Core Guidelines
C++ Core Guidelines

共0课时 | 0人学习