cp RaftCore 方法
获取 Raft集群节点 peers.add(NamingProxy.getServers());
Raft集群数据恢复 RaftStore.load();
Raft选举 GlobalExecutor.register(new MasterElection());
Raft心跳 GlobalExecutor.register(new HeartBeat());
Raft发布内容
Raft保证内容一致性
集群选举
RaftCore
RaftPeer存放投票信息和节点选举状态
每隔500ms发送投票信息,投票信息里面有个term字段 是automic integer的 每次发送的时候都自增 然后收到其他节点的反馈
接口 /nacos/v1/ns/raft接收投票信息
如果收到的投票信息里面的term字段大于当前服务的则投票信息会改为投递 term字段大的服务,并把自己的服务器状态设置为follower 并返回结果
500ms heartbeat用于集群重新选举以及新节点的加入 和节点的下线 heartbeat是leader发往各follower节点的心跳
调用 /nacos/v1/ns/raft/beat接口接收心跳