core.yaml 设置如下:
peer:
gossip:
useLeaderElection: false # 不进行动态选举主节点
orgLeader: true # 指定该节点为主节点
1
2
3
4
或者配置环境变量:
export CORE_PEER_GOSSIP_USELEADERELECTION=false
export CORE_PEER_GOSSIP_ORGLEADER=true
1
2
前面提到,如果指定某个节点不为主节点也是可以的:
peer:
gossip:
useLeaderElection: false # 不进行动态选举主节点
orgLeader: false # 指定该节点为非主节点
1
2
3
4
或者配置环境变量:
export CORE_PEER_GOSSIP_USELEADERELECTION=false
export CORE_PEER_GOSSIP_ORGLEADER=false
1
2
- 动态选举主节点
动态选举配置信息:
peer:
gossip:
# Leader election service configuration
election:
# 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 消息:声明自己为主节点
每个节点都在后台持续运行:
如果主节点不存在,则进入主节点选举过程;
如果节点为主节点,则广播 declaration 消息,声明自己为主节点,如果收到别的节点发送的较低 节点 ID值,则成为从节点;
如果节点为从节点,并且在一定时间内(由 core.yaml 中的 leaderAliveThreshold 设置,默认 10 秒)没有收到其它节点发送的 declaration 消息,则设置主节点不存在。
主节点选举过程:
提交自己为主节点的提案;
收集其它节点发送的提案;
如果有其它节点声明为主节点,则放弃选举过程;
如果主节点不存在,则将自己的节点 ID 与其它节点的 ID 值进行比较,如果自己的 ID 值比其它任何一个节点 ID 值都小,则声明自己成为主节点,否则放弃选举过程。