fabric 主节点选举过程

2024-08-29 16:08
文章标签 过程 节点 选举 fabric

本文主要是介绍fabric 主节点选举过程,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

  • 1. 静态指定主节点
  • 2. 动态选举主节点
  • 3. 参考资料

每个组织都有一个或多个主节点与排序节点进行连接,但是过多的节点与排序节点进行通讯无疑会占用过多的带宽。为了灵活利用带宽,Fabric 提供两种方式指定主节点:

  • 静态指定:系统管理员可以自定义配置一个或多个节点作为该组织的主节点;
  • 动态选举:节点可以通过选举选择一个节点作为主节点。

这两种方式都可以通过修改 core.yaml 的 useLeaderElection 和 orgLeader 字段值指定主节点选择方式。useLeaderElection 表示是否采用选择方式,orgLeader 表示该节点是否为主节点。因此,两个值均为 true 是非法的,而两个值为 false,则表明该节点为 stand-by 模式,即该节点将不会成为主节点。如果 useLeaderElection 为 false,则必须保证组织内至少有一个节点 orgLeader 值为 true。

1. 静态指定主节点

core.yaml 设置如下:

peer:gossip:useLeaderElection: false # 不进行动态选举主节点orgLeader: true          # 指定该节点为主节点

或者配置环境变量:

export CORE_PEER_GOSSIP_USELEADERELECTION=false
export CORE_PEER_GOSSIP_ORGLEADER=true

前面提到,如果指定某个节点不为主节点也是可以的:

peer:gossip:useLeaderElection: false # 不进行动态选举主节点orgLeader: false         # 指定该节点为非主节点

或者配置环境变量:

export CORE_PEER_GOSSIP_USELEADERELECTION=false
export CORE_PEER_GOSSIP_ORGLEADER=false

2. 动态选举主节点

动态选举配置信息:

peer:gossip:# Leader election service configurationelection:# Longest time peer waits for stable membership during leader election startup (unit: second)startupGracePeriod: 15s# Interval gossip membership samples to check its stability (unit: second)membershipSampleInterval: 1s# Time passes since last declaration message before peer decides to perform leader election (unit: second)leaderAliveThreshold: 10s# Time between peer sends propose message and declares itself as a leader (sends declaration message) (unit: second)leaderElectionDuration: 5s

Gossip 动态选举算法有如下特点:

  • 节点的角色通过比较节点 ID 来确定
  • 每个节点只有两种角色:主节点和从节点,当所有节点的共识一致的时候,就会产生一个主节点
  • 如果网络被划分为多个分区,则每个分区都有一个主节点,当多个分区合并为一个分区的时候,则主节点的数量也应该只留下 1 个
  • 节点之间的通信发送两种消息:
    • proposal 消息:申请成为主节点
    • declaration 消息:声明自己为主节点

每个节点都在后台持续运行:

  1. 如果主节点不存在,则进入主节点选举过程;
  2. 如果节点为主节点,则广播 declaration 消息,声明自己为主节点,如果收到别的节点发送的较低 节点 ID值,则成为从节点;
  3. 如果节点为从节点,并且在一定时间内(由 core.yaml 中的 leaderAliveThreshold 设置,默认 10 秒)没有收到其它节点发送的 declaration 消息,则设置主节点不存在。

主节点选举过程:

  1. 提交自己为主节点的提案;
  2. 收集其它节点发送的提案;
  3. 如果有其它节点声明为主节点,则放弃选举过程;
  4. 如果主节点不存在,则将自己的节点 ID 与其它节点的 ID 值进行比较,如果自己的 ID 值比其它任何一个节点 ID 值都小,则声明自己成为主节点,否则放弃选举过程。

详细过程图示:

在这里插入图片描述

主节点选举关键代码
// ref: <https://github.com/hyperledger/fabric/blob/master/gossip/election/election.go>func (le *leaderElectionSvcImpl) run() {defer le.stopWG.Done()for !le.shouldStop() {if !le.isLeaderExists() {le.leaderElection()}// If we are yielding and some leader has been elected,// stop yieldingif le.isLeaderExists() && le.isYielding() {le.stopYielding()}if le.shouldStop() {return}if le.IsLeader() {le.leader()} else {le.follower()}}
}func (le *leaderElectionSvcImpl) leaderElection() {le.logger.Debug(le.id, ": Entering")defer le.logger.Debug(le.id, ": Exiting")// If we're yielding to other peers, do not participate// in leader electionif le.isYielding() {return}// Propose ourselves as a leaderle.propose()// Collect other proposalsle.waitForInterrupt(getLeaderElectionDuration())// If someone declared itself as a leader, give up// on trying to become a leader tooif le.isLeaderExists() {le.logger.Info(le.id, ": Some peer is already a leader")return}if le.isYielding() {le.logger.Debug(le.id, ": Aborting leader election because yielding")return}// Leader doesn't exist, let's see if there is a better candidate than us// for being a leaderfor _, o := range le.proposals.ToArray() {id := o.(string)if bytes.Compare(peerID(id), le.id) < 0 {return}}// If we got here, there is no one that proposed being a leader// that's a better candidate than us.le.beLeader()atomic.StoreInt32(&le.leaderExists, int32(1))
}

3. 参考资料

  • Leader election

这篇关于fabric 主节点选举过程的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1118326

相关文章

SpringBoot 整合 Grizzly的过程

《SpringBoot整合Grizzly的过程》Grizzly是一个高性能的、异步的、非阻塞的HTTP服务器框架,它可以与SpringBoot一起提供比传统的Tomcat或Jet... 目录为什么选择 Grizzly?Spring Boot + Grizzly 整合的优势添加依赖自定义 Grizzly 作为

mysql-8.0.30压缩包版安装和配置MySQL环境过程

《mysql-8.0.30压缩包版安装和配置MySQL环境过程》该文章介绍了如何在Windows系统中下载、安装和配置MySQL数据库,包括下载地址、解压文件、创建和配置my.ini文件、设置环境变量... 目录压缩包安装配置下载配置环境变量下载和初始化总结压缩包安装配置下载下载地址:https://d

springboot整合gateway的详细过程

《springboot整合gateway的详细过程》本文介绍了如何配置和使用SpringCloudGateway构建一个API网关,通过实例代码介绍了springboot整合gateway的过程,需要... 目录1. 添加依赖2. 配置网关路由3. 启用Eureka客户端(可选)4. 创建主应用类5. 自定

最新版IDEA配置 Tomcat的详细过程

《最新版IDEA配置Tomcat的详细过程》本文介绍如何在IDEA中配置Tomcat服务器,并创建Web项目,首先检查Tomcat是否安装完成,然后在IDEA中创建Web项目并添加Web结构,接着,... 目录配置tomcat第一步,先给项目添加Web结构查看端口号配置tomcat    先检查自己的to

SpringBoot集成SOL链的详细过程

《SpringBoot集成SOL链的详细过程》Solanaj是一个用于与Solana区块链交互的Java库,它为Java开发者提供了一套功能丰富的API,使得在Java环境中可以轻松构建与Solana... 目录一、什么是solanaj?二、Pom依赖三、主要类3.1 RpcClient3.2 Public

Android数据库Room的实际使用过程总结

《Android数据库Room的实际使用过程总结》这篇文章主要给大家介绍了关于Android数据库Room的实际使用过程,详细介绍了如何创建实体类、数据访问对象(DAO)和数据库抽象类,需要的朋友可以... 目录前言一、Room的基本使用1.项目配置2.创建实体类(Entity)3.创建数据访问对象(DAO

SpringBoot整合kaptcha验证码过程(复制粘贴即可用)

《SpringBoot整合kaptcha验证码过程(复制粘贴即可用)》本文介绍了如何在SpringBoot项目中整合Kaptcha验证码实现,通过配置和编写相应的Controller、工具类以及前端页... 目录SpringBoot整合kaptcha验证码程序目录参考有两种方式在springboot中使用k

SpringBoot整合InfluxDB的详细过程

《SpringBoot整合InfluxDB的详细过程》InfluxDB是一个开源的时间序列数据库,由Go语言编写,适用于存储和查询按时间顺序产生的数据,它具有高效的数据存储和查询机制,支持高并发写入和... 目录一、简单介绍InfluxDB是什么?1、主要特点2、应用场景二、使用步骤1、集成原生的Influ

SpringBoot实现websocket服务端及客户端的详细过程

《SpringBoot实现websocket服务端及客户端的详细过程》文章介绍了WebSocket通信过程、服务端和客户端的实现,以及可能遇到的问题及解决方案,感兴趣的朋友一起看看吧... 目录一、WebSocket通信过程二、服务端实现1.pom文件添加依赖2.启用Springboot对WebSocket

浅析Spring Security认证过程

类图 为了方便理解Spring Security认证流程,特意画了如下的类图,包含相关的核心认证类 概述 核心验证器 AuthenticationManager 该对象提供了认证方法的入口,接收一个Authentiaton对象作为参数; public interface AuthenticationManager {Authentication authenticate(Authenti