一、前言

　　前面分析了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
     
       pendingSyncs =         new ConcurrentLinkedQueue
      
       ();}
      
     

　　说明：该类维护了提交请求处理器和同步请求处理器，同时维护一个待同步请求的队列，是否使用同步请求处理器要根据其标志而定。

　　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的源码分析就告一段落了，其中之分析了部分源码，还有很多的没有分析到，之后在使用过程中遇到则再进行分析，也谢谢各位园友的观看~