[Java知识库]Zookeeper值curator常用操作

1.新建一个maven项目，导入如下依赖

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.cd</groupId>
    <artifactId>maven-zookeeper</artifactId>
    <version>1.0-SNAPSHOT</version>


    <dependencies>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>RELEASE</version>
        </dependency>


        <dependency>
            <groupId>org.apache.logging.log4j</groupId>
            <artifactId>log4j-core</artifactId>
            <version>2.8.2</version>
        </dependency>


        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.5.7</version>
        </dependency>

        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
            <version>4.2.0</version>
        </dependency>

        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
            <version>4.2.0</version>
        </dependency>


    </dependencies>

</project>

2.使用Curator框架编写如下常用代码

public class CuratorTest {


    private CuratorFramework client;

    /**
     * 建立连接
     */
    @Before
    public void testConnect(){


        /**
         *  connectString, 连接字符串，zk server 地址和端口 "192.168.84.130:2181"
         *  sessionTimeOut, 会话超时时间 单位ms
         *  connectionTimeoutMs, 连接超时时间 单位ms
         *  retryPolicy  重试策略
         */
                // 重试策略， 每间隔3秒重试一次，重试10次
        RetryPolicy retryPolicy = new ExponentialBackoffRetry(3000, 10);
              // 1. 第一种方式
//        CuratorFramework client = CuratorFrameworkFactory.newClient("192.168.84.130:2181",
//                60 * 1000, 15 * 1000, retryPolicy);
//          //开启连接
//        client.start();



        // 第二种方式
         client = CuratorFrameworkFactory.builder().connectString("192.168.57.139:2181")
                .sessionTimeoutMs(60 * 1000)
                .connectionTimeoutMs(15 * 1000)
                     // /cdbaba节点
                .retryPolicy(retryPolicy).namespace("cdbaba").build();
        // 开启连接
        client.start();

    }


    /**
     *  创建节点: create 持久 临时 顺序 数据
     *   1. 基本创建
     *   2. 创建节点的类型
     *   3. 设置节点的类型
     *   4.创建多级节点  /app1/p1
     *
     */
    @Test
    public void testCreate() throws Exception {

        // 1. 基本创建
        // 如果创建节点，没有指定数据，则默认将当前客户端的ip作为数据
        String path = client.create().forPath("/app1");
        System.out.println(path);

    }


    // 创建带节点的数据
    @Test
    public void testCreate2() throws Exception {

        // 默认创建的是持久数据节点
        String path = client.create().forPath("/app2","haha".getBytes());
        System.out.println(path);

    }



    // 创建带数据的节点
    @Test
    public void testCreate3() throws Exception {

        // 创建的临时节点
        String path = client.create().withMode(CreateMode.EPHEMERAL).forPath("/app3","haha".getBytes());
        System.out.println(path);

    }



    // 创建多级节点
    @Test
    public void testCreate4() throws Exception {

        // 创建的临时节点
        //  creatingParentsIfNeeded() 如果父节点不存在，则创建父节点
        String path = client.create().creatingParentsIfNeeded().forPath("/app4/p1");
        System.out.println(path);

    }


    /**
     * 查询节点
     * 1. 查询数据： get
     * 2. 查询子节点： ls
     * 3. 查询节点详细信息
     */
    // 1. 查询数据： get
    @Test
    public void testGet1() throws Exception {
         // 1. 查询数据： get
        byte[] data = client.getData().forPath("/app1");
        System.out.println(new String(data));

    }

    // 2. 查询子节点： ls
    @Test
    public void testGet2() throws Exception {
        // 2. 查询子节点： ls
        List<String> data = client.getChildren().forPath("/");
        System.out.println(data);

    }


    @Test
    public void testGet3() throws Exception {
           // 用于存储查询出来的节点信息
        Stat stat = new Stat();
        System.out.println(stat);

        // 查询节点状态信息: ls -s  存放到stat中
        client.getData().storingStatIn(stat).forPath("/app1");
        System.out.println(stat);
    }


    //==============================================================//

    /**
     * 修改数据
     * 1. 基本修改  setData().forPath()
     * 2. 根据版本修改 setData().withVersion().forPath()
     *    * version是通过查询出来的，目的就是为了让其他客户端或者线程不干扰我
     */
    @Test
    public void testSet() throws Exception {
        client.setData().forPath("/app1","itcast".getBytes());
    }


    @Test
    public void testSetForVersion() throws Exception {
        Stat stat = new Stat();
        // 查询节点状态信息: ls -s
        client.getData().storingStatIn(stat).forPath("/app1");

        int version = stat.getVersion();
        System.out.println(version);

        client.setData().withVersion(version).forPath("/app1","hehe".getBytes());

    }



    //======delete=================================================//

    /**
     *  删除节点： delete deleteAll
     *  1. 删除单个节点
     *  2. 删除带有子节点的节点
     *  3.必须成功的删除
     *  4.回调
     */

    // 1. 删除单个节点
    @Test
    public void testDelete() throws Exception {
        // 1. 删除单个节点
        client.delete().forPath("/app1");

    }


    // 2.删除带有子节点的节点
    @Test
    public void testDelete2() throws Exception {
        // 2.删除带有子节点的节点
        client.delete().deletingChildrenIfNeeded().forPath("/app4");

    }


    // 3.必须删除成功，说白了就是不断重试，直到删除成功
    @Test
    public void testDelete3() throws Exception {

        client.delete().guaranteed().forPath("/app2");

    }


    // 删除时回调
    @Test
    public void testDelete4() throws Exception {

        client.delete().guaranteed().inBackground(new BackgroundCallback() {
            @Override
            public void processResult(CuratorFramework curatorFramework, CuratorEvent curatorEvent) throws Exception {
                System.out.println("我被删除了");
                System.out.println(curatorEvent);
            }
        }).forPath("/app2");

    }