目录

• 引用头文件
• Raft 核心实现分析
  • 1. 类设计
    • 主要类及其成员
      • Node 类
      • StateMachine 类（抽象基类）
    • 类图
  • 2. 处理流程
    • 主要流程说明
    • 流程图
  • 3. 时序图
    • 领导者选举时序
    • 日志复制时序
  • 4. 关键特性
    • 安全性保证
    • 可用性保证
    • 性能优化
  • 5. 代码质量分析
    • 优点
    • 改进建议

引用头文件

#include <pthread.h>
#include <unistd.h>
#include <butil/string_printf.h>
#include <butil/class_name.h>
#include "braft/raft.h"
#include "braft/node.h"
#include "braft/storage.h"
#include "braft/node_manager.h"
#include "braft/log.h"
#include "braft/memory_log.h"
#include "braft/raft_meta.h"
#include "braft/snapshot.h"
#include "braft/fsm_caller.h"            // IteratorImpl

Raft 核心实现分析

主要类及其成员

Node 类

• 成员变量:
  • _impl: NodeImpl指针，实际实现
• 主要成员函数:
  • init(): 初始化节点
  • shutdown(): 关闭节点
  • apply(): 应用状态机命令
  • list_peers(): 列出集群节点
  • add_peer()/remove_peer(): 修改集群配置
  • transfer_leadership_to(): 转移领导权
  • is_leader()/leader_id(): 领导者相关查询
  • snapshot(): 触发快照

StateMachine 类（抽象基类）

• 主要虚函数:
  • on_apply(): 应用状态机命令
  • on_snapshot_save(): 保存快照
  • on_snapshot_load(): 加载快照
  • on_leader_start(): 成为领导者时回调
  • on_leader_stop(): 停止领导者时回调
  • on_error(): 错误处理
  • on_configuration_committed(): 配置变更提交

classDiagram class Node { -NodeImpl* _impl +init(NodeOptions) +shutdown(Closure*) +apply(Task) +add_peer(PeerId) +remove_peer(PeerId) +transfer_leadership_to(PeerId) } class StateMachine { <<abstract>> +on_apply(Iterator&) +on_snapshot_save(SnapshotWriter*) +on_snapshot_load(SnapshotReader*) +on_leader_start(int64_t) +on_leader_stop(Status) +on_error(Error) } class NodeOptions { +int election_timeout_ms +int snapshot_interval_s +StateMachine* fsm +LogStorage* log_storage +string log_uri +string snapshot_uri } Node --> NodeImpl : contains Node --> NodeOptions : uses NodeOptions --> StateMachine : contains

2. 处理流程

主要流程说明

1. 节点启动流程:
   • 初始化配置(NodeOptions)
   • 创建/恢复日志存储
   • 初始化状态机
   • 启动RPC服务
2. 日志复制流程:
   • 接收客户端请求(apply)
   • 领导者追加日志
   • 复制到从节点
   • 提交并应用到状态机
3. 选举流程:
   • 超时触发选举
   • 预投票阶段
   • 正式投票阶段
   • 领导者变更

流程图