get -w /node
# 在其他窗口执行下面命令，会触发相关事件
set /node 123
delete /node

ls -w /node
# 在其他窗口执行下面命令，会触发相关事件
create /node/node1
delete /node/node1

# The number of milliseconds of each tick
tickTime=2000
# The number of ticks that the initial 
# synchronization phase can take
initLimit=10
# The number of ticks that can pass between 
# sending a request and getting an acknowledgement
syncLimit=5
# the directory where the snapshot is stored.
# do not use /tmp for storage, /tmp here is just 
# example sakes.
#修改路径
dataDir=D:\\zookeeper-3.4.13\\data
#dataLogDir=dataDir=D:\\zookeeper-3.4.13\\log
# the port at which the clients will connect
clientPort=2181
# the maximum number of client connections.
# increase this if you need to handle more clients
#maxClientCnxns=60
#
# Be sure to read the maintenance section of the 
# administrator guide before turning on autopurge.
#
# http://zookeeper.apache.org/doc/current/zookeeperAdmin.html#sc_maintenance
#
# The number of snapshots to retain in dataDir
#autopurge.snapRetainCount=3
# Purge task interval in hours
# Set to "0" to disable auto purge feature
#autopurge.purgeInterval=1

set ZOOCFGDIR=%~dp0%..\conf
set ZOO_LOG_DIR=%~dp0%..
set ZOO_LOG4J_PROP=INFO,CONSOLE
#增加下面两条
set JAVA=D:\Program Files (x86)\jdk1.8.0_111\bin\java
set JAVA_HOME=D:\Program Files (x86)\jdk1.8.0_111

ssh-copy-id root@jt2
ssh-copy-id root@jt3
ssh-copy-id root@jt4

vi ~/.ssh/config

Host jt2
Hostname jt2
User root
Host jt3
Hostname jt3
User root
Host jt4
Hostname jt4
User root

chmod 600 ~/.ssh/config

先进入~目录：
cd ~
创建.ssh目录：
mkdir .ssh
创建config文件
vi config

vi /etc/selinux/config
SELINUX=disabled

设置开机启用防火墙：systemctl enable firewalld.service
设置开机禁用防火墙：systemctl disable firewalld.service
启动防火墙：systemctl start firewalld
关闭防火墙：systemctl stop firewalld
检查防火墙状态：systemctl status firewalld

tar -zxvf apache-zookeeper-3.5.6-bin.tar.gz

mv apache-zookeeper-3.5.6-bin/ zookeeper

cd /usr/local/jingtian/zookeeper/conf
cp zoo_sample.cfg zoo.cfg

vim zoo.cfg
# The number of milliseconds of each tick
tickTime=2000
# The number of ticks that the initial 
# synchronization phase can take
initLimit=10
# The number of ticks that can pass between 
# sending a request and getting an acknowledgement
syncLimit=5
# the directory where the snapshot is stored.
# do not use /tmp for storage, /tmp here is just 
# example sakes.
dataDir=/usr/local/jingtian/zookeeper/data
# the port at which the clients will connect
clientPort=2181
# the maximum number of client connections.
# increase this if you need to handle more clients
#maxClientCnxns=60
#
# Be sure to read the maintenance section of the 
# administrator guide before turning on autopurge.
#
# http://zookeeper.apache.org/doc/current/zookeeperAdmin.html#sc_maintenance
#
# The number of snapshots to retain in dataDir
#autopurge.snapRetainCount=3
# Purge task interval in hours
# Set to "0" to disable auto purge feature
#autopurge.purgeInterval=1
server.0=jt2:2888:3888
server.1=jt3:2888:3888
server.2=jt4:2888:3888

export ZK_HOME=/usr/local/jingtian/zookeeper
export PATH=$PATH:$ZK_HOME/bin

启动：./zkServer.sh start
停止：./zkServer.sh stop
重启：./zkServer.sh restart
查看集群节点状态：./zkServer.sh status
批量启动
将zk.sh复制到/user/local/jingtian/目录下
执行：bash zk.sh start则就会启动

#!/bin/bash

case $1 in
"start"){
  for i in jt2 jt3 jt4
  do
    echo  ------------- zookeeper $i 启动 ------------
    ssh $i "/usr/local/jingtian/zookeeper/bin/zkServer.sh start"
  done
}
;;
"stop"){
  for i in jt2 jt3 jt4
  do
    echo  ------------- zookeeper $i 停止 ------------
    ssh $i "/usr/local/jingtian/zookeeper/bin/zkServer.sh stop"
  done
}
;;
"status"){
  for i in jt2 jt3 jt4
  do
    echo  ------------- zookeeper $i 状态 ------------
    ssh $i "/usr/local/jingtian/zookeeper/bin/zkServer.sh status"
  done
}
;;
esac

peerType=observer
server.0=jt2:2888:3888
server.1=jt3:2888:3888
server.2=jt4:2888:3888
#所有机器都需要配置这个
server.3=jt5:2888:3888:observer

#git提交id（随便编一个或者用github上的id）
git.commit.id=123123
#构建时间
build.time=2022-08-02

# The number of milliseconds of each tick
tickTime=2000
# The number of ticks that the initial 
# synchronization phase can take
initLimit=10
# The number of ticks that can pass between 
# sending a request and getting an acknowledgement
syncLimit=5
# the directory where the snapshot is stored.
# do not use /tmp for storage, /tmp here is just 
# example sakes.
dataDir=/tmp/zookeeper
# the port at which the clients will connect
clientPort=2181
# the maximum number of client connections.
# increase this if you need to handle more clients
#maxClientCnxns=60
#
# Be sure to read the maintenance section of the 
# administrator guide before turning on autopurge.
#
# http://zookeeper.apache.org/doc/current/zookeeperAdmin.html#sc_maintenance
#
# The number of snapshots to retain in dataDir
#autopurge.snapRetainCount=3
# Purge task interval in hours
# Set to "0" to disable auto purge feature
#autopurge.purgeInterval=1

public static void main(String[] args) {
ZooKeeperServerMain main = new ZooKeeperServerMain();
//核心流程
main.initializeAndRun(args);
    ...
}
protected void initializeAndRun(String[] args)
throws ConfigException, IOException, AdminServerException
{
//核心流程
runFromConfig(config);
}

public void runFromConfig(ServerConfig config)
throws IOException, AdminServerException {
// Start Admin server
//启动服务管理器（JettyAdminServer）-启动Jetty
adminServer = AdminServerFactory.createAdminServer();
adminServer.setZooKeeperServer(zkServer);
//这是启动Jetty容器
adminServer.start();
boolean needStartZKServer = true;
if (config.getClientPortAddress() != null) {
//cnxnFactory负责zk的网络请求，createFactory中
//从系统配置中读取ZOOKEEPER_SERVER_CNXN_FACTORY，默认是没有这个配置的，因此默认是使用NIOServerCnxnFactory
cnxnFactory = ServerCnxnFactory.createFactory();
//0.0.0.0/0.0.0.0:2181，单个客户端连接数超过限制，请求的传入连接队列的最大长度，-1不限制
cnxnFactory.configure(config.getClientPortAddress(), config.getMaxClientCnxns(), false);
//这才是启动ZookeeperServer服务的核心逻辑
cnxnFactory.startup(zkServer);
// zkServer has been started. So we don't need to start it again in secureCnxnFactory.
//是否需要启动Zookeeper服务，Zookeeper服务已经启动了，不需要再次启动，设置为false
needStartZKServer = false;
    }
}

public void startup(ZooKeeperServer zks, boolean startServer)
throws IOException, InterruptedException {
//NIO启动对应线程，四种线程
start();
//设置Zookeeper的ServerCnxnFactory（客户端与服务端进行通信的对象，就是当前对象NIOServerCnxnFactory）
setZooKeeperServer(zks);
if (startServer) {
//加载会话和数据
zks.startdata();
//启动Zookeeper服务，在这里会创建一个SessionTrackerImpl线程，并执行该线程
//这个线程就是用来管理Session的属性的
//同时也会构建核心业务调用链
zks.startup();
    }
}

public synchronized void startup() {
//创建Session的核心管理线程SessionTrackerImpl
if (sessionTracker == null) {
createSessionTracker();
    }
//启动SessionTrackerImpl线程
startSessionTracker();
//构建核心业务调用链
setupRequestProcessors();
registerJMX();
//设置zkserver的状态为运行
setState(State.RUNNING);
notifyAll();
}

# The number of milliseconds of each tick
tickTime=2000
# The number of ticks that the initial 
# synchronization phase can take
initLimit=10
# The number of ticks that can pass between 
# sending a request and getting an acknowledgement
syncLimit=5
# the directory where the snapshot is stored.
# do not use /tmp for storage, /tmp here is just 
# example sakes.
dataDir=D:/桌面/景天/idealwork/Zookeeper/zookeeper-release-3.5.6/data/zkdata1
# the port at which the clients will connect
clientPort=2181

#集群配置
server.1=127.0.0.1:12881:13881
server.2=127.0.0.1:12882:13882
server.3=127.0.0.1:12883:13883

# The number of milliseconds of each tick
tickTime=2000
# The number of ticks that the initial 
# synchronization phase can take
initLimit=10
# The number of ticks that can pass between 
# sending a request and getting an acknowledgement
syncLimit=5
# the directory where the snapshot is stored.
# do not use /tmp for storage, /tmp here is just 
# example sakes.
dataDir=D:/桌面/景天/idealwork/Zookeeper/zookeeper-release-3.5.6/data/zkdata2
# the port at which the clients will connect
clientPort=2182

#集群配置
server.1=127.0.0.1:12881:13881
server.2=127.0.0.1:12882:13882
server.3=127.0.0.1:12883:13883

# The number of milliseconds of each tick
tickTime=2000
# The number of ticks that the initial 
# synchronization phase can take
initLimit=10
# The number of ticks that can pass between 
# sending a request and getting an acknowledgement
syncLimit=5
# the directory where the snapshot is stored.
# do not use /tmp for storage, /tmp here is just 
# example sakes.
dataDir=D:/桌面/景天/idealwork/Zookeeper/zookeeper-release-3.5.6/data/zkdata3
# the port at which the clients will connect
clientPort=2183

#集群配置
server.1=127.0.0.1:12881:13881
server.2=127.0.0.1:12882:13882
server.3=127.0.0.1:12883:13883