Raft Read Index 的实现
2015 年 10 月 27 日
首先, 获取”集群”的 ReadIndex. 注意, 不是某个节点上面的某个状态, 而集群的多个节点共同确定的一个变量. 这个变量如何获取, 下面说明.
func GetClusterReadIndex(){ foreach(peers as peer){ i = peer.rpc_GetLastIndex(); ret = max(ret, i); if(recv_majority){ break; } } return ret; }
获取至少半数以上成员的 LastIndex, 也就是每个节点持久化的最新一条日志的 index. 一条日志只要在一个节点上被持久化, 那么这条日志要么被集群 commit, 要么被覆盖之后再 commit, 没有其它的选项.
由此可见, ReadIndex 不一定已经被 commit, 但一定会被 commit, 最终也将会 apply. 所以, 拿到集群的 ReadIndex 之后, 我们只需要等, 等它被任意一个节点 apply 即可.
ReadIndex = cluster.GetReadIndex(); while(1){ foreach(peers as peer){ if(ReadIndex >= peer.LastApplied()){ return peer.GetValue(); } } }
不断地重复轮询全部节点, 如果谁 apply 了, 就以谁的值为准. 还有一种方案, 那就是等本地的状态机 apply, 这样避免网络传输.
ReadIndex = cluster.GetReadIndex(); while(1){ if(ReadIndex >= self.LastApplied()){ return self.GetValue(); } }