一、前言
前面分析了FollowerZooKeeperServer，接着分析ObserverZooKeeperServer。
二、ObserverZooKeeperServer源码分析
2.1 类的继承关系
public class ObserverZooKeeperServer extends LearnerZooKeeperServer {}
说明：ObserverZooKeeperServer也继承了LearnerZooKeeperServer抽象类，角色为Observer，其请求处理链为ObserverRequestProcessor -> CommitProcessor -> FinalRequestProcessor。可能会存在SyncRequestProcessor。
2.2 类的属性
public class ObserverZooKeeperServer extends LearnerZooKeeperServer { // 日志 private static final Logger LOG = LoggerFactory.getLogger(ObserverZooKeeperServer.class); /** * Enable since request processor for writing txnlog to disk and * take periodic snapshot. Default is ON. */ // 同步处理器是否可用 private boolean syncRequestProcessorEnabled = this.self.getSyncEnabled(); /* * Request processors */ // 提交请求处理器 private CommitProcessor commitProcessor; // 同步请求处理器 private SyncRequestProcessor syncProcessor; /* * Pending sync requests */ // 待同步请求队列 ConcurrentLinkedQueue<Request> pendingSyncs = new ConcurrentLinkedQueue<Request>(); }
说明：该类维护了提交请求处理器和同步请求处理器，同时维护一个待同步请求的队列，是否使用同步请求处理器要根据其标志而定。
2.3 类的构造函数
ObserverZooKeeperServer(FileTxnSnapLog logFactory, QuorumPeer self, DataTreeBuilder treeBuilder, ZKDatabase zkDb) throws IOException { // 父类构造函数 super(logFactory, self.tickTime, self.minSessionTimeout, self.maxSessionTimeout, treeBuilder, zkDb, self); LOG.info("syncEnabled =" + syncRequestProcessorEnabled); }
说明：其会调用父类构造函数进行初始化操作，同时可确定此时同步请求处理器是否可用。
2.4 核心函数分析
1. commitRequest函数
public void commitRequest(Request request) { if (syncRequestProcessorEnabled) { // 同步处理器可用 // Write to txnlog and take periodic snapshot // 使用同步处理器处理请求 syncProcessor.processRequest(request); } // 提交请求 commitProcessor.commit(request); }
说明：若同步处理器可用，则使用同步处理器进行处理（放入同步处理器的queuedRequests队列中），然后提交请求（放入提交请求处理器的committedRequests队列中）。
2. sync函数
synchronized public void sync(){ if(pendingSyncs.size() ==0){ // 没有未完成的同步请求 LOG.warn("Not expecting a sync."); return; } // 移除队首元素 Request r = pendingSyncs.remove(); // 提交请求 commitProcessor.commit(r); }
说明：若还有未完成的同步请求，则移除该请求，并且进行提交。
三、总结
本篇博文分析了ObserverZooKeeperServer的源码，其核心也是请求处理链对于请求的处理。至此，ZooKeeper的源码分析就告一段落了，其中之分析了部分源码，还有很多的没有分析到，之后在使用过程中遇到则再进行分析，也谢谢各位园友的观看~
