Zookeeper集群模式下的请求处理流程源码解析(ZK是如何保证数据一致性的?)

图1

Zookeeper集群模式下的请求处理流程源码解析(ZK是如何保证数据一致性的?)

图1集群下的zookeeper启动的顺序。需要注意的是 同步数据完成后才能 client才能访问该集群。 

图2

Zookeeper集群模式下的请求处理流程源码解析(ZK是如何保证数据一致性的?)

 

图3

Zookeeper集群模式下的请求处理流程源码解析(ZK是如何保证数据一致性的?)

图4

Zookeeper集群模式下的请求处理流程源码解析(ZK是如何保证数据一致性的?)

总结:

集群环境下,leader,Follower,Observer,是在启动socket 后,通过选举 进行确定leader,follower,observer。 当client发送写请求时,oberserver,follower 都没有权限写数据,都会转发给leader,然后.leader 向 follower,oberserver,发送提议,等待follower,和observer回复ack时,leader才向自己和follower,observer 提交commit 内容图4;

图3如果在添加一个follower的情况下,新添加的follower要从leader中同步数据,来保证数据的一致性。

图4 如果leader在收到follower的ack回复时,突然挂掉,等再次恢复正常的时候也要从新从leader中同步数据,保证数据的一致性。


图5

Zookeeper集群模式下的请求处理流程源码解析(ZK是如何保证数据一致性的?)