集群间消息通信

集群间消息通信2消息类型数据同步型服务器初始化型请求处理型会话管理型3数据同步型DIFF：用于通知Learner服务器、Leader即将与其进行“DIFF”方式的数据同步TRUNC：用于触发Learner服务器进行内存数据库的回滚操作SNAP：用于通知Learner服务器，Learner即将与其进行“全量”方式的数据同步UPTODATE：用来告诉Learner服务器，已经完成了数据同步，可以开始对外提供服务了4服务器初始化型OBSERVERINFO：该信息通常是由Observer服务器在启动的时候发送给Leader的，用于向Leader服务器注册自己，同时向Leader服务器表明当前Learner服务器的角色是Observer。消息中包含了当前Observer服务器的SID和已经处理的最新ZXID。5服务器初始化型FOLLOWERINFO：该信息通常是由Follower服务器在启动的时候发送给Leader的，用于向Leader服务器注册自己，同时向Leader服务器表明当前Learner服务器的角色是Follower。消息中包含了当前Follower服务器的SID和已经处理的最新ZXID。6服务器初始化型LEADERINFO：在Learner连接上Leader后，会向Leader发送LearnerInfo消息（包含了OBSERVERINFO和FOLLOWERINFO两类消息），Leader服务器在接收到该消息后，也会将Leader服务器的基本信息发送给这些Learner，这个消息就是LEADERINFO，通常包含了当前Leader服务器的最新EPOCH值。7服务器初始化型ACKEPOCH：Learner在接收到Leader发来的LEADERINFO消息后，会将自己最新的ZXID和EPOCH以ACKEPOCH消息的形式发送给Leader。8服务器初始化型NEWLEADER：该消息通常用于Leader服务器向Learner发送一个阶段性的标识消息——Leader会在和Learner完成一个交互流程后，向Learner发送NEWLEADER消息，同时带上当前Leader服务器处理的最新ZXID。这一系统交互流程包括：足够多的Follower服务器连接上Leader或是完成数据同步。9请求处理型REQUEST：该消息是ZooKeeper的请求转发消息。在ZooKeeper中，所有的事务请求去必须由Leader服务器来处理。当Learner服务器接收到客户端的事务请求后，就会将请求以REQUEST消息的形式转发给Leader服务器来处理。10请求处理型PROPOSAL：该消息是ZooKeeper实现ZAB算法的核心所在，即ZAB协议中的提议。在处理事务请求的时候，Leader服务器会将事务请求以PROPOSAL消息的形式创建投票发送给集群中所有的Follower服务器来进行事务日志的记录。11请求处理型ACK：服务器在接收到来自Leader的PROPOSAL消息后，会进行事务日志的记录。如果完成了事务日志的记录，那么就会以ACK消息的反馈给Leader。12请求处理型COMMIT：该消息用于通知集群中所有的Follower服务器，可以进行事务请求的提交了。Leader服务器在接收到过半的Follower服务器发来的ACK消息后，就进入事务请求的最终提交流程——生成COMMIT消息，告知所有的Follower服务器进行事务请求的提交。13请求处理型INFORM：ZooKeeper特别设计了INFORM消息，该消息不仅能够通知Observer已经可以提交事务请求，同时还会在消息中携带事务请求的内容。SYNC：该消息用于通知Learner服务器已经完成了Sync操作。14会话管理型PING：该消息用于Leader同步Learner服务器上的客户端心跳检测，用以激活存活的客户端。Leader服务器无法直接收到所有客户端的心跳检测，需要委托给Learner来保存这些客户端的心跳检测的客户端列表，同样以PING消息的形式反馈给Leader服务器，由Leader服务器来负责逐个对这些客户端进行会话激活。15会话管理型REVALI