org.apache.zookeeper.server.quorum

Class QuorumPeerMain

java.lang.Object

org.apache.zookeeper.server.quorum.QuorumPeerMain

@InterfaceAudience.Public
public class QuorumPeerMain
extends Object

Configuration file

When the main() method of this class is used to start the program, the first argument is used as a path to the config file, which will be used to obtain configuration information. This file is a Properties file, so keys and values are separated by equals (=) and the key/value pairs are separated by new lines. The following is a general summary of keys used in the configuration file. For full details on this see the documentation in docs/index.html

1. dataDir - The directory where the ZooKeeper data is stored.
2. dataLogDir - The directory where the ZooKeeper transaction log is stored.
3. clientPort - The port used to communicate with clients.
4. tickTime - The duration of a tick in milliseconds. This is the basic unit of time in ZooKeeper.
5. initLimit - The maximum number of ticks that a follower will wait to initially synchronize with a leader.
6. syncLimit - The maximum number of ticks that a follower will wait for a message (including heartbeats) from the leader.
7. server.id - This is the host:port[:port] that the server with the given id will use for the quorum protocol.

In addition to the config file. There is a file in the data directory called "myid" that contains the server id as an ASCII decimal value.

Field Summary

Fields

Modifier and Type	Field and Description
protected QuorumPeer	quorumPeer

Constructor Summary

Constructors

Constructor and Description
QuorumPeerMain()

Method Summary

Modifier and Type	Method and Description
void	close() Shutdowns properly the service, this method is not a public API.
protected QuorumPeer	getQuorumPeer()
protected void	initializeAndRun(String[] args)
static void	main(String[] args) To start the replicated server specify the configuration file name on the command line.
void	runFromConfig(QuorumPeerConfig config)
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

quorumPeer

protected QuorumPeer quorumPeer

Constructor Detail

QuorumPeerMain

public QuorumPeerMain()

Method Detail

main

public static void main(String[] args)

To start the replicated server specify the configuration file name on the command line.

Parameters:

args - path to the configfile

initializeAndRun

protected void initializeAndRun(String[] args)
                         throws QuorumPeerConfig.ConfigException,
                                IOException,
                                AdminServer.AdminServerException

Throws:

QuorumPeerConfig.ConfigException

IOException

AdminServer.AdminServerException

runFromConfig

public void runFromConfig(QuorumPeerConfig config)
                   throws IOException,
                          AdminServer.AdminServerException

Throws:

IOException

AdminServer.AdminServerException

getQuorumPeer

protected QuorumPeer getQuorumPeer()
                            throws SaslException

Throws:

SaslException

close

public void close()

Shutdowns properly the service, this method is not a public API.

toString

public String toString()

Overrides:

toString in class Object