目录结构此系列文章是sofa-jraft 1.3.7版本代码阅读的过程笔记。主要阐述了节点启动、选主、日志复制、快照机制、状态机对接、一致性读和优先级选举等机制的实现过程。 sofa-jraft源码阅读-导读提示 前期准备、基础概念与机制 节点启动与leader选主分析 单节点存储分析 分布式状态机与计数器的例子分析 副本复制整体分析 快照机制分析 线性一致性读与优先级选举的实现

关于指针为了弄明白** * & 等这些奇怪的符号的意思，比如下面这段leveldb代码 Status DB::Open(const Options& options, const std::string& dbname, DB** dbptr) { *dbptr = nullptr; // ... 每次看c cpp代码时都对这些”奇怪的”符号表示很难

leveldb源码阅读文章结构 01.前期准备 02.整体架构与相关图解 03.写数据分析 04.读数据分析 05.LRU与skiplist实现 06.compact分析 07.多种iter实现 08.系统api对接调用 01. 前期准备版本 v1.20 编译# master git clone --recurse-submodules https://github.com/google/l

c3p0相关 由于一些历史原因，工作中部分项目还在使用c3p0。这个连接池相对古老，问题相对较多，所以抽时间稍微了解了下。 官方或者maven仓库提供的0.9.1.2版本的source，或多或少的有些编译问题。或者是部分类是编译时生成的，比如Newxxx等类。下面的分支对其做了补齐。 没有编译错误的代码分支 demo在这里 整体大致逻辑有：获取(取出)连接、归还连接、创建真实物理连接、最小最大

幼儿园练习题  Code to 60 

内部rpc接口文档AddOffsetsToTxnRequestversion:0nametypedefaultValuedocStringtransactional_idSTRINGnullThe transactional id corresponding to the transaction. producer_idINT64nullCurrent producer id in use by

副本复制异常场景及样例case分析crash时机列表(下面简称C)前提都是leader节点写盘成功 L(leader)还没给R(replica)返回第一个请求 // 参见 关键环节与注入点整理要点2 R没有收到第一个请求的响应体(或者是收到了但是还没来得及处理) 1 2 是不是可以合并掉？(可以合并)有个问题要考虑消息落盘后 到 给R回复第一次请求的响应这个时间段内leader做了哪些逻辑，

LEADER_AND_ISR和UPDATE_METADATA请求分析节点常规启动时每个节点收到的请求的列表梳理node0 启动0： apiKey=UPDATE_METADATA apiKey=LEADER_AND_ISR apiKey=UPDATE_METADATA 启动1： apiKey=UPDATE_METADATA apiKey=UPDATE_METAD

分区选主、分区状态机定义与变换逻辑分区状态机启动kafka.controller.PartitionStateMachine.startup() 初始化分区状态，按online offline new分类。 触发分区上线事件。事件的处理的逻辑主要是给partition选leader。 给分区选举leader关于分区的leader是如何选取的，涉及的情况比较多，现在大概列举几个要

副本状态机状态定义与变换逻辑副本状态机启动kafka.controller.ReplicaStateMachine.startup() 主要两个逻辑： 初始化副本状态 initializeReplicaState 处理副本状态改变事件 handleStateChanges 初始化副本状态 根据controllerContext.partitionReplicaAssign