news 2026/4/23 9:18:06

jraft原理源码应用系列-nacos

作者头像

张小明

前端开发工程师

1.2k 24
文章封面图
jraft原理源码应用系列-nacos

简介

SOFAStack(Scalable Open Financial Architecture Stack)是蚂蚁集团(原蚂蚁金服)自主研发的一套金融级分布式中间件技术栈,jraft是sofastack的raft组件,构建高可用、强一致性(CP)的分布式系统,本系列分析jraft应用的原理源码分析,包括

nacos jraft

seata jraft

rocketmq jraft

本文分析nacos jraft应用,based nacos 2.3.2

关键词

nacos

配置中心

服务注册中心

参考资料

In Search of an Understandable Consensus Algorithm raft论文简版

《jraft原理源码分析(一)》,分析了jraft的架构,组件和启动》 分析了jraft技术架构,组件架构,是本文的基础

jraft技术架构

上图是jraft的技术架构

Corecore包定义核心组件的接口,包括Node,StateMachine,Closure,client服务等,Node实现也在core包

Node代表raft集群的节点,包括大部分核心逻辑,组件的初始化都在Node,

选举主节点选举是jraft的核心功能,主节点是分布式节点协调的关键,日志写入主节点完成

日志日志是jraft另一个核心功能,包括日志写入,日志复制,状态机的推进

存储这里存储是jraft保存自身日志的存储,状态机状态的存储由应用提供

状态机状态机是应用的接口,应用实现状态机,接收jraft推送过半数节点写入的日志,按自身逻辑保存

快照快照存储状态机的数据(StateMachine state),快照有两个作用,删除该快照之前的日志,节省空间;新节点或落后节点直接安装快照,快速追上进度,达到可用状态

read线性一致性读,官方定义:在 T 时刻执行写入操作,那么在 T 时刻之后一定能够读取到之前写入的值,简单地说,从jraft实现角度,读取状态机最新共识点的数据

rpc rpc组件负责client与集群(节点),节点间的通讯

jraft@nacos

本文不深入分析nacos整体原理源码,重点分析nacos使用jraft,包括分布式存储和集群节点管理分

布式存储

本节分析nacos jraft分布式存储

上图是nacos jraft的类图,从两个维度分析,数据类型和类结构

数据类型

  1. 第一类,NamingMetadataOperateService负责,服务注册数据,包括服务元素据和实例元素据,这两类数据通常是AP,但也可以配置使用CP,因此也用到jraft
  2. 第二类,PersistentClientOperationServiceImpl负责,注册持久化数据,例如,数据库信息,redis服务信息
  3. 第三类,DistributedDatabaseOperateImpl负责配置中心数据

其中后两类一定走CP,需要分布式存储,线性一致性读;第一类后面2.1.2详细分析,存储可以配置为走CP,但读不是线性一致性读,对于微服务实例这个合理,线性一致性读性能太差,当数据不一致,读到已经失效的服务实例,通过重试选择另一个有效实例。

类结构

大致可分为3层,从左到右,前置服务层,raft层,应用

前置服务

前置处理client的读写数据,即,上面介绍的三个服务,

NamingMetadataOperateService/PersistentClientOperationServiceImpl/DistributedDatabaseOperateImpl

Raft写入是需要leader处理

raft层

raft层CP协议jraft实现

CPProtocol/JRaftProtocolCPProtocol定义CP协议的接口,实现是JRaftProtocol

JRaftServer/RaftGroupTuple前者负责配置和启动jraft组件, Node和RpcServer;后者持有jraft两件套,node和状态机,注意到,针对每个group,即每种类型创建一套node和状态机,不要跟jraft的group混淆,jraft支持多组,nacos的group对应不同的事件类型

状态机层

状态机是分布式存储共识数据推到应用处理

RequestProcessor4CP 日志数据应用侧的处理器,状态机交给该处理器处理提交的共识数据

PersistentClientOperationServiceImpl/DistributedDatabaseOperateImpl/InstanceMetadataProcessor/ServiceMetadataProcessor 这4个RequestProcessor4CP的实现,分别对应处理4种数据类型,其中前两个同时也是前置处理类

源码分析

应用写入

写入流程,CPProtocol(JRaftProtocol)的write--》JraftServer的commit

上图是JraftServer的commit方法,写入是leader负责,如果当前节点不是leader转交给leader

应用处理数据

DistributedDatabaseOperateImpl 配置中心最终是写入数据库,即,jraft+数据库实现分布式数据库

InstanceMetadataProcessor/ServiceMetadataProcessor 写入NamingMetadataManager的Map,即,jraft+Map实现分布式Map

应用读取
1. 配置中心的读取,最终是JraftServer的get方法处理

线性一致性读,线性一致性读失败,降级到raftlog读

2. 服务和实例元数据

服务和实例没有走线性一致读,两数据写入NamingMetadataManager的Map,client通过rest/rpc直接读取

集群管理

本节分析nacos的集群成员变更

上图是nacos集群jraft的类图

MemmberLookupnacos集群管理有自身机制,没有依赖jraft的集群管理,MemmberLookup同步nacos集群节点后,推送成员变更事件(MemberChangeEvent)到订阅者;另外,nacos支持api方式,rpc或者rest增加或移除peer

MemberChangeListener/ProtocolManager ProtocolManager负责构建和持有CProtocol,“兼职”成员变更事件的订阅者

Node最后,还是jraft Node承受了一切,注意到,只有移除peer(REMOVE_PEERS),并不是CHANGE_PEERS,原因是,nacos节点增加时,启动jraft,jraft node自动加入集群,nacos节点移除,jraft集群只是认为node下线,需要显式删除,因此只有删除需要调用node处理

系列文章

  1. Jraft应用分析-nacos,服务元数据,服务实例元数据,配置分布式存储
  2. Jraft应用分析-seata,session分布式存储
  3. Jraft应用分析-rocketmq控制器raft模式
版权声明: 本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若内容造成侵权/违法违规/事实不符,请联系邮箱:809451989@qq.com进行投诉反馈,一经查实,立即删除!
网站建设 2026/4/18 10:14:09

Excalidraw对齐辅助线触发距离设置建议

Excalidraw 对齐辅助线触发距离设置建议 在设计工具的世界里,一个看似微不足道的像素值,往往能决定整个用户体验的流畅与否。比如你在拖动一个方框时,它是否“恰到好处”地贴合到另一个元素边缘——这种直觉般的精准感,背后其实依…

作者头像 李华
网站建设 2026/4/19 5:48:44

Excalidraw自由绘图平滑度优化:手写轨迹处理算法

Excalidraw自由绘图平滑度优化:手写轨迹处理算法 在数字白板工具日益普及的今天,用户早已不再满足于“能画”,而是追求“画得自然”。尤其是在远程协作、头脑风暴或教学演示场景中,一条流畅、有笔触感的手绘线条,往往比…

作者头像 李华
网站建设 2026/4/18 3:47:44

为什么你的努力领导看不到?是你不会向上管理,想要优秀,至少要做到第三层级

底层是被动响应,领导安排什么做什么,结果是没存在感; 第二层是主动汇报,定期反馈进展,但只是执行者; 第三层是提前预判,不只汇报还提建议,领导觉得你靠谱; 第四层是影响决策,用数据影响领导,成为智囊; 顶层是成为伙伴,理解领导压力主动分担,领导把你当自己人。 大多数人停在第二…

作者头像 李华
网站建设 2026/4/18 20:02:17

专题:所有宾语类型(持续补充)

英语中,宾语(Object) 是动作的承受者或对象,是及物动词、介词后面必须或可以搭配的成分。根据语法功能和位置,宾语主要分为 3 大类,具体分类及解析如下:一、 直接宾语(Direct Object…

作者头像 李华
网站建设 2026/4/23 7:18:40

小批量硅胶复模,医疗设备外壳3D打印定制,通过安全认证

小批量硅胶复模,医疗设备外壳3D打印定制,通过安全认证 做医疗设备研发的第3年,我终于在上海找到了靠谱的小批量硅胶复模和3D打印定制厂家——这是我踩了3次坑后,最真切的感受。 从事医疗设备研发行业的人都懂,新品研…

作者头像 李华