学校网站建设网站冷水滩网站建设

学校网站建设网站,冷水滩网站建设,logo免费网站,黄页 推广简介SOFAStack#xff08;Scalable Open Financial Architecture Stack#xff09;是蚂蚁集团#xff08;原蚂蚁金服#xff09;自主研发的一套金融级分布式中间件技术栈#xff0c;jraft是sofastack的raft组件#xff0c;构建高可用、强一致性(CP)的分布式系统#xff…简介SOFAStackScalable Open Financial Architecture Stack是蚂蚁集团原蚂蚁金服自主研发的一套金融级分布式中间件技术栈jraft是sofastack的raft组件构建高可用、强一致性(CP)的分布式系统本系列分析jraft应用的原理源码分析包括nacos jraftseata jraftrocketmq jraft本文分析nacos jraft应用based nacos 2.3.2关键词nacos配置中心服务注册中心参考资料In Search of an Understandable Consensus Algorithm raft论文简版《jraft原理源码分析(一)》分析了jraft的架构组件和启动》 分析了jraft技术架构组件架构是本文的基础jraft技术架构上图是jraft的技术架构Corecore包定义核心组件的接口包括NodeStateMachineClosureclient服务等Node实现也在core包Node代表raft集群的节点包括大部分核心逻辑组件的初始化都在Node选举主节点选举是jraft的核心功能主节点是分布式节点协调的关键日志写入主节点完成日志日志是jraft另一个核心功能包括日志写入日志复制状态机的推进存储这里存储是jraft保存自身日志的存储状态机状态的存储由应用提供状态机状态机是应用的接口应用实现状态机接收jraft推送过半数节点写入的日志按自身逻辑保存快照快照存储状态机的数据StateMachine state快照有两个作用删除该快照之前的日志节省空间新节点或落后节点直接安装快照快速追上进度达到可用状态read线性一致性读官方定义在 T 时刻执行写入操作那么在 T 时刻之后一定能够读取到之前写入的值简单地说从jraft实现角度读取状态机最新共识点的数据rpc rpc组件负责client与集群(节点)节点间的通讯jraftnacos本文不深入分析nacos整体原理源码重点分析nacos使用jraft包括分布式存储和集群节点管理分布式存储本节分析nacos jraft分布式存储上图是nacos jraft的类图从两个维度分析数据类型和类结构数据类型第一类NamingMetadataOperateService负责服务注册数据包括服务元素据和实例元素据这两类数据通常是AP但也可以配置使用CP因此也用到jraft第二类PersistentClientOperationServiceImpl负责注册持久化数据例如数据库信息redis服务信息第三类DistributedDatabaseOperateImpl负责配置中心数据其中后两类一定走CP需要分布式存储线性一致性读第一类后面2.1.2详细分析存储可以配置为走CP但读不是线性一致性读对于微服务实例这个合理线性一致性读性能太差当数据不一致读到已经失效的服务实例通过重试选择另一个有效实例。类结构大致可分为3层从左到右前置服务层raft层应用前置服务前置处理client的读写数据即上面介绍的三个服务NamingMetadataOperateService/PersistentClientOperationServiceImpl/DistributedDatabaseOperateImplRaft写入是需要leader处理raft层raft层CP协议jraft实现CPProtocol/JRaftProtocolCPProtocol定义CP协议的接口实现是JRaftProtocolJRaftServer/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即jraftMap实现分布式Map应用读取1. 配置中心的读取最终是JraftServer的get方法处理线性一致性读线性一致性读失败降级到raftlog读2. 服务和实例元数据服务和实例没有走线性一致读两数据写入NamingMetadataManager的Mapclient通过rest/rpc直接读取集群管理本节分析nacos的集群成员变更上图是nacos集群jraft的类图MemmberLookupnacos集群管理有自身机制没有依赖jraft的集群管理MemmberLookup同步nacos集群节点后推送成员变更事件(MemberChangeEvent)到订阅者另外nacos支持api方式rpc或者rest增加或移除peerMemberChangeListener/ProtocolManager ProtocolManager负责构建和持有CProtocol“兼职”成员变更事件的订阅者Node最后还是jraft Node承受了一切注意到只有移除peer(REMOVE_PEERS)并不是CHANGE_PEERS原因是nacos节点增加时启动jraftjraft node自动加入集群nacos节点移除jraft集群只是认为node下线需要显式删除因此只有删除需要调用node处理系列文章Jraft应用分析-nacos服务元数据服务实例元数据配置分布式存储Jraft应用分析-seatasession分布式存储Jraft应用分析-rocketmq控制器raft模式