org.apache.zookeeper.server.quorum.QuorumPeerMain

QuorumPeerMain源代码

1. package org.apache.zookeeper.server.quorum;
3. import java.io.IOException;
4. import javax.management.JMException;
5. import javax.security.sasl.SaslException;
6. import org.apache.yetus.audience.InterfaceAudience;
7. import org.apache.zookeeper.audit.ZKAuditProvider;
8. import org.apache.zookeeper.jmx.ManagedUtil;
9. import org.apache.zookeeper.metrics.MetricsProvider;
10. import org.apache.zookeeper.metrics.MetricsProviderLifeCycleException;
11. import org.apache.zookeeper.metrics.impl.MetricsProviderBootstrap;
12. import org.apache.zookeeper.server.DatadirCleanupManager;
13. import org.apache.zookeeper.server.ExitCode;
14. import org.apache.zookeeper.server.ServerCnxnFactory;
15. import org.apache.zookeeper.server.ServerMetrics;
16. import org.apache.zookeeper.server.ZKDatabase;
17. import org.apache.zookeeper.server.ZooKeeperServerMain;
18. import org.apache.zookeeper.server.admin.AdminServer.AdminServerException;
19. import org.apache.zookeeper.server.auth.ProviderRegistry;
20. import org.apache.zookeeper.server.persistence.FileTxnSnapLog;
21. import org.apache.zookeeper.server.persistence.FileTxnSnapLog.DatadirException;
22. import org.apache.zookeeper.server.quorum.QuorumPeerConfig.ConfigException;
23. import org.apache.zookeeper.server.util.JvmPauseMonitor;
24. import org.apache.zookeeper.util.ServiceUtils;
25. import org.slf4j.Logger;
26. import org.slf4j.LoggerFactory;
28. /**
29. *
30. * <h2>Configuration file</h2>
31. *
32. * When the main() method of this class is used to start the program, the first
33. * argument is used as a path to the config file, which will be used to obtain
34. * configuration information. This file is a Properties file, so keys and
35. * values are separated by equals (=) and the key/value pairs are separated
36. * by new lines. The following is a general summary of keys used in the
37. * configuration file. For full details on this see the documentation in
38. * docs/index.html
39. * <ol>
40. * <li>dataDir - The directory where the ZooKeeper data is stored.</li>
41. * <li>dataLogDir - The directory where the ZooKeeper transaction log is stored.</li>
42. * <li>clientPort - The port used to communicate with clients.</li>
43. * <li>tickTime - The duration of a tick in milliseconds. This is the basic
44. * unit of time in ZooKeeper.</li>
45. * <li>initLimit - The maximum number of ticks that a follower will wait to
46. * initially synchronize with a leader.</li>
47. * <li>syncLimit - The maximum number of ticks that a follower will wait for a
48. * message (including heartbeats) from the leader.</li>
49. * <li>server.<i>id</i> - This is the host:port[:port] that the server with the
50. * given id will use for the quorum protocol.</li>
51. * </ol>
52. * In addition to the config file. There is a file in the data directory called
53. * "myid" that contains the server id as an ASCII decimal value.
54. *
55. */
56. @InterfaceAudience.Public
57. public class QuorumPeerMain {
59.     private static final Logger LOG = LoggerFactory.getLogger(QuorumPeerMain.class);
61.     private static final String USAGE = "Usage: QuorumPeerMain configfile";
63.     protected QuorumPeer quorumPeer;
65.     /**
66.      * To start the replicated server specify the configuration file name on
67.      * the command line.
68.      * @param args path to the configfile
69.      */
70.     public static void main(String[] args) {
71.         QuorumPeerMain main = new QuorumPeerMain();
72.         try {
73.             main.initializeAndRun(args);
74.         } catch (IllegalArgumentException e) {
75.             LOG.error("Invalid arguments, exiting abnormally", e);
76.             LOG.info(USAGE);
77.             System.err.println(USAGE);
78.             ZKAuditProvider.addServerStartFailureAuditLog();
79.             ServiceUtils.requestSystemExit(ExitCode.INVALID_INVOCATION.getValue());
80.         } catch (ConfigException e) {
81.             LOG.error("Invalid config, exiting abnormally", e);
82.             System.err.println("Invalid config, exiting abnormally");
83.             ZKAuditProvider.addServerStartFailureAuditLog();
84.             ServiceUtils.requestSystemExit(ExitCode.INVALID_INVOCATION.getValue());
85.         } catch (DatadirException e) {
86.             LOG.error("Unable to access datadir, exiting abnormally", e);
87.             System.err.println("Unable to access datadir, exiting abnormally");
88.             ZKAuditProvider.addServerStartFailureAuditLog();
89.             ServiceUtils.requestSystemExit(ExitCode.UNABLE_TO_ACCESS_DATADIR.getValue());
90.         } catch (AdminServerException e) {
91.             LOG.error("Unable to start AdminServer, exiting abnormally", e);
92.             System.err.println("Unable to start AdminServer, exiting abnormally");
93.             ZKAuditProvider.addServerStartFailureAuditLog();
94.             ServiceUtils.requestSystemExit(ExitCode.ERROR_STARTING_ADMIN_SERVER.getValue());
95.         } catch (Exception e) {
96.             LOG.error("Unexpected exception, exiting abnormally", e);
97.             ZKAuditProvider.addServerStartFailureAuditLog();
98.             ServiceUtils.requestSystemExit(ExitCode.UNEXPECTED_ERROR.getValue());
99.         }
100.         LOG.info("Exiting normally");
101.         ServiceUtils.requestSystemExit(ExitCode.EXECUTION_FINISHED.getValue());
102.     }
104.     protected void initializeAndRun(String[] args) throws ConfigException, IOException, AdminServerException {
105.         QuorumPeerConfig config = new QuorumPeerConfig();
106.         if (args.length == 1) {
107.             config.parse(args[0]);
108.         }
110.         // Start and schedule the the purge task
111.         DatadirCleanupManager purgeMgr = new DatadirCleanupManager(
112.             config.getDataDir(),
113.             config.getDataLogDir(),
114.             config.getSnapRetainCount(),
115.             config.getPurgeInterval());
116.         purgeMgr.start();
118.         if (args.length == 1 && config.isDistributed()) {
119.             runFromConfig(config);
120.         } else {
121.             LOG.warn("Either no config or no quorum defined in config, running in standalone mode");
122.             // there is only server in the quorum -- run as standalone
123.             ZooKeeperServerMain.main(args);
124.         }
125.     }
127.     public void runFromConfig(QuorumPeerConfig config) throws IOException, AdminServerException {
128.         try {
129.             ManagedUtil.registerLog4jMBeans();
130.         } catch (JMException e) {
131.             LOG.warn("Unable to register log4j JMX control", e);
132.         }
134.         LOG.info("Starting quorum peer, myid=" + config.getServerId());
135.         final MetricsProvider metricsProvider;
136.         try {
137.             metricsProvider = MetricsProviderBootstrap.startMetricsProvider(
138.                 config.getMetricsProviderClassName(),
139.                 config.getMetricsProviderConfiguration());
140.         } catch (MetricsProviderLifeCycleException error) {
141.             throw new IOException("Cannot boot MetricsProvider " + config.getMetricsProviderClassName(), error);
142.         }
143.         try {
144.             ServerMetrics.metricsProviderInitialized(metricsProvider);
145.             ProviderRegistry.initialize();
146.             ServerCnxnFactory cnxnFactory = null;
147.             ServerCnxnFactory secureCnxnFactory = null;
149.             if (config.getClientPortAddress() != null) {
150.                 cnxnFactory = ServerCnxnFactory.createFactory();
151.                 cnxnFactory.configure(config.getClientPortAddress(), config.getMaxClientCnxns(), config.getClientPortListenBacklog(), false);
152.             }
154.             if (config.getSecureClientPortAddress() != null) {
155.                 secureCnxnFactory = ServerCnxnFactory.createFactory();
156.                 secureCnxnFactory.configure(config.getSecureClientPortAddress(), config.getMaxClientCnxns(), config.getClientPortListenBacklog(), true);
157.             }
159.             quorumPeer = getQuorumPeer();
160.             quorumPeer.setTxnFactory(new FileTxnSnapLog(config.getDataLogDir(), config.getDataDir()));
161.             quorumPeer.enableLocalSessions(config.areLocalSessionsEnabled());
162.             quorumPeer.enableLocalSessionsUpgrading(config.isLocalSessionsUpgradingEnabled());
163.             //quorumPeer.setQuorumPeers(config.getAllMembers());
164.             quorumPeer.setElectionType(config.getElectionAlg());
165.             quorumPeer.setMyid(config.getServerId());
166.             quorumPeer.setTickTime(config.getTickTime());
167.             quorumPeer.setMinSessionTimeout(config.getMinSessionTimeout());
168.             quorumPeer.setMaxSessionTimeout(config.getMaxSessionTimeout());
169.             quorumPeer.setInitLimit(config.getInitLimit());
170.             quorumPeer.setSyncLimit(config.getSyncLimit());
171.             quorumPeer.setConnectToLearnerMasterLimit(config.getConnectToLearnerMasterLimit());
172.             quorumPeer.setObserverMasterPort(config.getObserverMasterPort());
173.             quorumPeer.setConfigFileName(config.getConfigFilename());
174.             quorumPeer.setClientPortListenBacklog(config.getClientPortListenBacklog());
175.             quorumPeer.setZKDatabase(new ZKDatabase(quorumPeer.getTxnFactory()));
176.             quorumPeer.setQuorumVerifier(config.getQuorumVerifier(), false);
177.             if (config.getLastSeenQuorumVerifier() != null) {
178.                 quorumPeer.setLastSeenQuorumVerifier(config.getLastSeenQuorumVerifier(), false);
179.             }
180.             quorumPeer.initConfigInZKDatabase();
181.             quorumPeer.setCnxnFactory(cnxnFactory);
182.             quorumPeer.setSecureCnxnFactory(secureCnxnFactory);
183.             quorumPeer.setSslQuorum(config.isSslQuorum());
184.             quorumPeer.setUsePortUnification(config.shouldUsePortUnification());
185.             quorumPeer.setLearnerType(config.getPeerType());
186.             quorumPeer.setSyncEnabled(config.getSyncEnabled());
187.             quorumPeer.setQuorumListenOnAllIPs(config.getQuorumListenOnAllIPs());
188.             if (config.sslQuorumReloadCertFiles) {
189.                 quorumPeer.getX509Util().enableCertFileReloading();
190.             }
191.             quorumPeer.setMultiAddressEnabled(config.isMultiAddressEnabled());
192.             quorumPeer.setMultiAddressReachabilityCheckEnabled(config.isMultiAddressReachabilityCheckEnabled());
193.             quorumPeer.setMultiAddressReachabilityCheckTimeoutMs(config.getMultiAddressReachabilityCheckTimeoutMs());
195.             // sets quorum sasl authentication configurations
196.             quorumPeer.setQuorumSaslEnabled(config.quorumEnableSasl);
197.             if (quorumPeer.isQuorumSaslAuthEnabled()) {
198.                 quorumPeer.setQuorumServerSaslRequired(config.quorumServerRequireSasl);
199.                 quorumPeer.setQuorumLearnerSaslRequired(config.quorumLearnerRequireSasl);
200.                 quorumPeer.setQuorumServicePrincipal(config.quorumServicePrincipal);
201.                 quorumPeer.setQuorumServerLoginContext(config.quorumServerLoginContext);
202.                 quorumPeer.setQuorumLearnerLoginContext(config.quorumLearnerLoginContext);
203.             }
204.             org.apache.zookeeper.server.quorum.QuorumPeerMain.setQuorumCnxnThreadsSize(config.quorumCnxnThreadsSize);
205.             quorumPeer.initialize();
207.             if (config.jvmPauseMonitorToRun) {
208.                 quorumPeer.setJvmPauseMonitor(new JvmPauseMonitor(config));
209.             }
211.             quorumPeer.start();
212.             ZKAuditProvider.addZKStartStopAuditLog();
213.             quorumPeer.join();
214.         } catch (InterruptedException e) {
215.             // warn, but generally this is ok
216.             LOG.warn("Quorum Peer interrupted", e);
217.         } finally {
218.             try {
219.                 metricsProvider.stop();
220.             } catch (Throwable error) {
221.                 LOG.warn("Error while stopping metrics", error);
222.             }
223.         }
224.     }
226.     // @VisibleForTesting
227.     protected QuorumPeer getQuorumPeer() throws SaslException {
228.         return new QuorumPeer();
229.     }
231.     /**
232.      * Shutdowns properly the service, this method is not a public API.
233.      */
234.     public void close() {
235.         if (quorumPeer != null) {
236.             try {
237.                 quorumPeer.shutdown();
238.             } finally {
239.                 quorumPeer = null;
240.             }
241.         }
242.     }
244.     @Override
245.     public String toString() {
246.         QuorumPeer peer = quorumPeer;
247.         return peer == null ? "" : peer.toString();
248.     }
250. }

复制代码

org.apache.zookeeper.server.quorum.QuorumPeerMain 是 Apache ZooKeeper 项目中的一个类，它负责启动和管理 ZooKeeper 的 Quorum 服务器。
ZooKeeper 是一个为分布式体系提供服务的开源项目，它为分布式应用提供了一致的、可靠的、高性能的调和服务。Quorum 服务器是 ZooKeeper 集群的核心组件之一，它负责处理客户端的请求，维护集群的状态，以及在集群中复制和同步数据。
QuorumPeerMain 类是 ZooKeeper Quorum 服务器的入口点。当你在下令行中运行 ZooKeeper 时，这个类会被 JVM 加载并执行。它负责剖析下令行参数，配置 ZooKeeper 服务器，然后启动服务器并进入监听状态。
这个类包罗了启动和管理 ZooKeeper Quorum 服务器的逻辑。它读取配置文件（通常是 zoo.cfg），设置须要的体系属性，创建和配置 QuorumPeer 对象，然后启动服务器。一旦服务器启动并运行，它将开始担当客户端的毗连请求并处理这些请求。

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。