Zookeeper入门（2）——Curator介绍与引入_引入curator依赖

二、Curator介绍与引入

Apache Curator

1、Curator是什么？

Apache Curator是Apache ZooKeeper的Java/JVM客户端库，这是一个分布式协调服务。它包括一个高级API框架和实用程序，使使用Apache ZooKeeper变得更容易和更可靠。它还包括常见用例和扩展功能，如服务发现和Java 8异步DSL。

2、Curator各个模块介绍

DSL是 Domain Specific Language 的缩写，即领域特定语言，为了解决某一类任务而专门设计的计算机语言。

3、Curator引入

<properties>
    <curator.version>4.2.0</curator.version>
</properties>
<dependencies>
    <dependency>
        <groupId>org.apache.curator</groupId>
        <artifactId>curator-recipes</artifactId>
        <version>${curator.version}</version>
    </dependency>
    <dependency>
        <groupId>org.apache.curator</groupId>
        <artifactId>curator-test</artifactId>
        <version>${curator.version}</version>
    </dependency>
</dependencies>
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

4、Zookeeper客户端的使用

介绍curator之前首先介绍一个zkCli.sh的使用

在对某个znode进行读操作时，应该先执行sync方法，使得读操作的连接所连的zk实例能与leader进行同步，从而保证能读到最新的数据。
注意：sync调用是异步的，无需等待调用的返回，zk服务器会保证所有后续的操作会在sync操作完成之后才执行，哪怕这些操作是在执行sync之前被提交的。

在ZK中，ZK客户端对服务器每一个数据节点的写操作，ZK会认为都是一次完整的事务操作，要么成功，要么失败，保证了数据的原子性。而每次事务都会分配一个唯一的事务id，以标识这次事务操作的数据信息。下面详细理解一下节点状态各个字段的含义：

• cZxid：创建节点的事务id

• ctime：创建节点的时间

• mZxid：修改节点的事务id

• mtime：修改节点的时间

• pZxid：子节点列表最后一次修改的事务id。删除或添加子节点，不包含修改子节点的数据。

• cversion：子节点的版本号，删除或添加子节点，版本号会自增

• dataVersion：节点数据版本号，数据写入操作，版本号会递增

• aclVersion：节点ACL权限版本，权限写入操作，版本号会递增

• ephemeralOwner：临时节点创建时的事务id，如果节点是永久节点，则它的值为0

• dataLength：节点数据长度（单位：byte），中文占3个byte

• numChildren：子节点数量

5、Curator创建ZKCli

下面是一个简单的使用curator创建一个zkcli的示例，并创建/configuration节点

public class Launcher {
    private static final String ZK_ADDRESS = "xxx.xxx.xxx.xxx:2181";
    public static void main(String[] args) {
        // 指定重试策略，最大重试三次，每次间隔1000ms
        RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);
        // 创建zk客户端
		CuratorFramework client = CuratorFrameworkFactory.newClient(ZK_ADDRESS, retryPolicy);
        // 启动客户端连接
        client.start();
        try {
            // 创建zk节点
            client.create().forPath("/configuration");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17