# The number of milliseconds of each tick
# 每次心跳时间
tickTime=2000
# The number of ticks that the initial 
# synchronization phase can take
# 允许 follower 链接初始化连接到 leader 最大时间 它表示 tickTime 的时间倍数
initLimit=10
# The number of ticks that can pass between 
# sending a request and getting an acknowledgement
# 允许 follower 与 leader 数据同步最大时间 它表示 tickTime 的时间倍数
syncLimit=5
# the directory where the snapshot is stored.
# do not use /tmp for storage, /tmp here is just 
# example sakes.
# 数据保存目录，（如果没有指定dataLogDir也保存到这个目录）
dataDir=/opt/homebrew/var/run/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
# 单个客户端 zookeeper 允许连接端最大数量
#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
# 自动触发清除任务的时间间隔（单位小时），0为不清理
#autopurge.purgeInterval=1
​
## Metrics Providers
#
# https://prometheus.io Metrics Exporter
#metricsProvider.className=org.apache.zookeeper.metrics.prometheus.PrometheusMetricsProvider
#metricsProvider.httpPort=7000
#metricsProvider.exportJvmInfo=true

# 启动 zookeeper 服务
zkServer start
​
# 查看 zookeeper 状态
zkServer status
​
# 停止 zookeeper 服务
zkServer stop

# 获取镜像
docker pull zookeeper
# 安装 zookeeper
docker run --name zookeeper-1 --restart always -d zookeeper
# 进入 zk 命令窗口
docker exec -it 镜像ID zkCli.sh# 获取镜像
docker pull zookeeper
# 安装 zookeeper
docker run --name zookeeper-1 --restart always -d zookeeper
# 进入 zk 命令窗口
docker exec -it 镜像ID zkCli.sh

package com.qf.bootzkclient.config;
​
import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;
​
@Data
@Component
@ConfigurationProperties(prefix = "curator")
public class WrapperZk {
    private int retryCount;
​
    private int elapsedTimeMs;
​
    private String connectString;
​
    private int sessionTimeoutMs;
​
    private int connectionTimeoutMs;
}

package com.qf.bootzkclient.config;
​
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.retry.RetryNTimes;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
​
@Configuration
public class CuratorConfig {
    @Autowired
    WrapperZk wrapperZk;
​
    @Bean(initMethod = "start")
    public CuratorFramework curatorFramework() {
        return CuratorFrameworkFactory.newClient(
                wrapperZk.getConnectString(),
                wrapperZk.getSessionTimeoutMs(),
                wrapperZk.getConnectionTimeoutMs(),
                new RetryNTimes(wrapperZk.getRetryCount(), wrapperZk.getElapsedTimeMs())
        );
    }
}

@Slf4j
@SpringBootTest
class BootZkClientApplicationTest {
​
    @Autowired
    private CuratorFramework curatorFramework;
​
    @Test
    public void create() throws Exception {
        // 添加持久节点
        String path = curatorFramework.create().forPath("/curator-node2");
        // 添加临时序号节点
//        String s = curatorFramework.create().withProtection(CreateMode.EPHEMERAL_SEQUENTIAL).
//                forPath("/curator-node", "some-date".getBytes());
        System.out.println("curator create node " + path + " successfully");
    }
}