Zookeeper入门看这篇就够了（2）

Zookeeper单机模式安装

java 环境

配置JAVA环境，检验环境 java -version

下载安装Zookeeper

下载地址：https://zookeeper.apache.org/releases.html

下载解压Zookeeper

cd /usr/local/

wget https://dlcdn.apache.org/zookeeper/zookeeper-3.7.0/apache-zookeeper-3.7.0-bin.tar.gz

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

cd zookeeper-3.7.0/

重命名配置文件 zoo_sample.cfg

cp conf/zoo_sample.cfg conf/zoo.cfg

启动ZK

./bin/zkServer.sh start

连接ZK客户端

./bin/zkCli.sh

当我们看到下图的信息的时候，表示我们启动成功

Zookeeper命令

基本命令

create : 在树中的某个位置创建一个节点

delete : 删除一个节点存在：测试节点是否存在于某个位置

get data : 从节点读取数据

set data： 将数据写入节点

get children : 检索节点的子节点列表

sync : 等待数据被传播

操作Zookeeper

查看Zookeeper中包含的key

ls /

创建一个新的Znode

创建成功以后我们可以使用 ls /查看我们创建的内容

create /zkMxn muxiaonong

ls /

[zkMxn, zookeeper]

get命令获取创建Znode的内容

get /zkMxn

set 命令来对 zk 所关联的字符串进行设置

set /zkMxn mxn666

删除Znode

delete /zkMxn

Java Api操作 ZK

1. 导入Jar包

<dependency>    
        <groupId>org.apache.zookeeper</groupId>   
        <artifactId>zookeeper</artifactId>
        <version>3.6.3</version>
</dependency>
<!--junit单元测试--> 
<dependency> 
        <groupId>junit</groupId> 
        <artifactId>junit</artifactId> 
        <version>4.13.2</version> 
        <scope>runtime</scope> 
 </dependency>

2. API操作Zookeeper

创建Zookeeper对象

public ZooKeeper(String connectString, int sessionTimeout, Watcher watcher) throws IOException {
        this(connectString, sessionTimeout, watcher, false);
    }

connectString： 连接的地址，包括主机名和端口号，多个的话用逗号隔开

sessionTimeout： 等待客户端通信的最长时间，客户端如果超过这个时间没有和服务端进行通信，那么就认为该客户端已经终止，一般设置值为 5-10秒，单位为毫秒

watcher： 监听器，用于接收会话事件的接口，需要自己定义，实现process()方法

连接Zookeeper

Zookeeper zkClient = "";
String connectStr = "192.168.2.1:2181";
zkClient = new ZooKeeper(connectStr, 5000, new Watcher() {
    @Override
    public void process(WatchedEvent watchedEvent) { }
});

创建节点

public String create(String path, byte[] data, List<ACL> acl, CreateMode createMode) throws KeeperException, InterruptedException {}

path： 节点路径

data： 节点数据

acl： 节点权限，例如：ZooDefs.Ids.OPEN_ACL_UNSAFE

OPEN_ACL_UNSAFE：完全开发，采用world验证模式，由于每个ZK连接都有world验证模式，所以当我们节点设置了该参数时，对所有连接开放

CREATOR_ALL_ACL： 创建该Znode连接的拥有所有权限，这里采用的是auth验证模式，用sessionID做验证，如果设置了该参数，只有创建改Znode节点的连接才能对这个Znode进行任何操作

READ_ACL_UNSAFE：所有的客户端都可读，这里采用world验证模式，和第一条同理，所有连接都可以读取该znode

createMode： 节点类型，例如：CreateMode.PERSISTENT

PERSISTENT：持久节点

PERSISTENT_SEQUENTIAL：持久有序节点

EPHEMERAL：短暂节点

EPHEMERAL_SEQUENTIAL：短暂有序节点