ZooKeeper启动过程

wolong

ZooKeeper启动过程

1.如何启动
　　zkServer.sh【Linux】或 zkServer.cmd【Windows】
　　以zkServer.cmd为例（zkServer.sh中内容太多）：


　　可以清晰的看出：调用了QuorumPeerMain这个类，传的参数为%ZOOCFG%【在zkEnv.cmd中定义，就是zoo.cfg】。
　　到QuorumPeerMain类中一看，果然有个main方法，且接受一个参数【配置文件路径】：


　　当然，接受的参数不是一个也没关系，只不过就不能集群了，只能以单机模式运行。仅当接受一个参数作为配置文件路径，且此配置文件没有设置为单机模式，才会开启ZooKeeper集群启动过程【上图120行，runFromConfig】。
　　2.启动过程源码分析
　　runFromConfig：

　　可以看出，程序转移到了QuorumPeer，首先设置一系列zoo.cfg中的属性值，而后start，QuorumPeer继承了Thread类，自然转到了QuorumPeer.run()。
　　run方法太长了，精简了一下，只留了骨架：
　　



[java] view plaincopy

• @Override  
  
•    public void run() {  
  
•     /// JMX...  
  
•        try {  
  
•            /*
  
•             * Main loop
  
•             */  
  
•            while (running) {  
  
•                switch (getPeerState()) {  
  
•                case LOOKING:  
  
•                    /// ...  
  
•                 setCurrentVote(makeLEStrategy().lookForLeader());
  
•                 /// ...  
  
•                    break;  
  
•                case OBSERVING:  
  
•                    try {  
  
•                        setObserver(makeObserver(logFactory));
  
•                        observer.observeLeader();
  
•                    } catch (Exception e) {  
  
•                    } finally {  
  
•                        observer.shutdown();
  
•                        setObserver(null);   
  
•                        updateServerState();
  
•                    }
  
•                    break;  
  
•                case FOLLOWING:  
  
•                    try {  
  
•                        setFollower(makeFollower(logFactory));
  
•                        follower.followLeader();
  
•                    } catch (Exception e) {  
  
•                    } finally {  
  
•                       follower.shutdown();
  
•                       setFollower(null);  
  
•                       updateServerState();
  
•                    }
  
•                    break;  
  
•                case LEADING:  
  
•                    try {  
  
•                        setLeader(makeLeader(logFactory));
  
•                        leader.lead();
  
•                        setLeader(null);  
  
•                    } catch (Exception e) {  
  
•                    } finally {  
  
•                        if (leader != null) {  
  
•                            leader.shutdown("Forcing shutdown");  
  
•                            setLeader(null);  
  
•                        }
  
•                        updateServerState();
  
•                    }
  
•                    break;  
  
•                }
  
•            }
  
•        } finally {  
  
•            /// clear JMX  
  
•        }
  
•    }
  

　　
可以看出，只要没有stop或者没有异常抛出，这个线程便一直在运行，没有后续更多的操作了，全部在这个循环里。
　　
　　到此为止，ZooKeeper集群中的这一个节点【Peer】启动完毕。
　　
　　从run()方法可以清晰的看到，ZooKeeper中的节点可以有四种状态：
　　

• LOOKING
  
• OBSERVING
  
• FOLLOWING
  
• LEADING
  

　　其中，getPeerState()方法中state初始化为LOOKING，因此每一个节点启动时的状态都是LOOKING。
　　下一步，就是参与投票，选出ZooKeeper集群的Leader，见下篇文章：ZooKeeper FastLeaderElection算法。
　　

　　转自ZooKeeper启动过程