# 解压
tar -xzvf apache-zookeeper-3.8.0-bin.tar.gz -C /bigdata/app

# 配置环境变量
echo ‘export ZOOKEEPER_HOME=/bigdata/app/apache-zookeeper-3.8.0-bin’ >> /etc/profile
echo ‘export PATH=$PATH:$ZOOKEEPER_HOME/bin’ >> /etc/profile
source /etc/profile

配置ZooKeeper：

设置myid：

# 在fgedu02上执行
echo 2 > /bigdata/fgdata/zookeeper/myid

# 在fgedu03上执行
echo 3 > /bigdata/fgdata/zookeeper/myid

# 查看集群状态
# 在每个节点上执行
bin/zkServer.sh status

# 停止ZooKeeper集群
# 在每个节点上执行
bin/zkServer.sh stop

# 重启ZooKeeper集群
# 在每个节点上执行
bin/zkServer.sh restart

public class ZooKeeperExample {
private static final String CONNECT_STRING = “fgedu01:2181,fgedu02:2181,fgedu03:2181”;
private static final int SESSION_TIMEOUT = 30000;
private ZooKeeper zk;

public void connect() throws IOException {
zk = new ZooKeeper(CONNECT_STRING, SESSION_TIMEOUT, new Watcher() {
@Override
public void process(WatchedEvent event) {
System.out.println(“Event: ” + event.getType());
}
});
}

public void createNode(String path, String data) throws KeeperException, InterruptedException {
zk.create(path, data.getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
}

public String getData(String path) throws KeeperException, InterruptedException {
Stat stat = new Stat();
byte[] data = zk.getData(path, false, stat);
return new String(data);
}

public void setData(String path, String data) throws KeeperException, InterruptedException {
zk.setData(path, data.getBytes(), -1);
}

public void deleteNode(String path) throws KeeperException, InterruptedException {
zk.delete(path, -1);
}

public List getChildren(String path) throws KeeperException, InterruptedException {
return zk.getChildren(path, false);
}

public void close() throws InterruptedException {
zk.close();
}

public static void main(String[] args) throws Exception {
ZooKeeperExample example = new ZooKeeperExample();
example.connect();
example.createNode(“/fgedu”, “Hello ZooKeeper”);
System.out.println(“Data: ” + example.getData(“/fgedu”));
example.setData(“/fgedu”, “Hello ZooKeeper Updated”);
System.out.println(“Data after update: ” + example.getData(“/fgedu”));
System.out.println(“Children: ” + example.getChildren(“/”));
example.close();
}
}