根據對應的標識創建選舉算法

protected Election createElectionAlgorithm(int electionAlgorithm){ Election le=null; //TODO: use a factory rather than a switch switch (electionAlgorithm) { case 0: le = new LeaderElection(this); break; case 1: le = new AuthFastLeaderElection(this); break; case 2: le = new AuthFastLeaderElection(this, true); break; case 3: qcm = createCnxnManager(); QuorumCnxManager.Listener listener = qcm.listener; if(listener != null){ listener.start(); //啟動監聽器，這個監聽具體做什么的暫時不管，后面遇到需要了解的地方再回過頭來看 le = new FastLeaderElection(this, qcm);//初始化FastLeaderElection } else { LOG.error("Null listener when initializing cnx manager"); } break; default: assert false; } return le; }

?

總結

以上是生活随笔為你收集整理的leader选举的源码分析-quorumPeer.createElectionAlgorithm的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。