其他分享
首页 > 其他分享> > zookeeper代码实现常用命令 - 雨中散步撒哈拉

zookeeper代码实现常用命令 - 雨中散步撒哈拉

作者:互联网


作者:雨中散步撒哈拉
来源:https://liudongdong.top
公众号:雨中散步撒哈拉
备注:欢迎关注公众号,学习技术,一起成长!

文末福利:上百本电子书,等待你的领取^v^

环境说明:

  1. 服务器为centos7集群

  2. zk为zookeeper-3.4.10.tar.gz版本

  3. jdk为1.8

一、创建项目

1. 添加依赖包,pom文件如下

    junit    junit    RELEASE    org.apache.logging.log4j    log4j-core    2.8.2    org.apache.zookeeper    zookeeper    3.4.10

2. 配置日志文件

资源文件创建日志配置文件log4j.properties

log4j.rootLogger=INFO, stdout 
log4j.appender.stdout=org.apache.log4j.ConsoleAppender 
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout 
log4j.appender.stdout.layout.ConversionPattern=%d %p [%c] - %m%n 
log4j.appender.logfile=org.apache.log4j.FileAppender 
log4j.appender.logfile.File=target/spring.log
log4j.appender.logfile.layout=org.apache.log4j.PatternLayout 
log4j.appender.logfile.layout.ConversionPattern=%d %p [%c] - %m%n

二、代码实现zk命令

0. 创建连接

连接集群ip和对外端口2181,集群映射,已在windows做了配置
hosts文件内容:

d1040f5302a63b109b74b0e02bcbf791.jpg

代码实现连接:

private static final String IPS = "master:2181,slave1:2181,slave2:2181";
private static final int SESSIONTIMEOUT = 200;
private ZooKeeper zkClient = null;

@Test
public void contectTest() throws Exception{
    zkClient = new ZooKeeper(IPS, SESSIONTIMEOUT, new Watcher() {
        @Override
        public void process(WatchedEvent event) {

        }
    });

    System.out.println("==================");
    System.out.println(zkClient.getState());
    System.out.println("==================");
}

运行打印结果

b0865d278d38b70b8573cfc214983c98.jpgimage.png

2. 创建节点

创建/idea节点,类型为临时节点

private static final String IPS = "master:2181,slave1:2181,slave2:2181";
private static final int SESSIONTIMEOUT = 200;
private ZooKeeper zkClient = null;

@Before
public void contectTest() throws Exception{
    zkClient = new ZooKeeper(IPS, SESSIONTIMEOUT, new Watcher() {
        @Override
        public void process(WatchedEvent event) {

        }
    });

    System.out.println("==================");
    System.out.println(zkClient.getState());
    System.out.println("==================");
}

@Test
public void createTest() throws Exception{
    String s = zkClient.create("/idea", "helloworld".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);
    System.out.println(s);
}

打印结果

b2a09e8c54a12cf791b48ea852d52685.jpgimage.png

3. 监听节点变化

监控根节点下的子节点变化

private static final String IPS = "master:2181,slave1:2181,slave2:2181";
private static final int SESSIONTIMEOUT = 200;
private ZooKeeper zkClient = null;

@Before
public void contectTest() throws Exception{
    zkClient = new ZooKeeper(IPS, SESSIONTIMEOUT, new Watcher() {
        @Override
        public void process(WatchedEvent event) {
            System.out.println(event.getType() + "--" + event.getPath());
            try {
                zkClient.getChildren("/", true);
            } catch (KeeperException e) {
                e.printStackTrace();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    });

    System.out.println("==================");
    System.out.println(zkClient.getState());
    System.out.println("==================");
}


@Test
public void childrenTest() throws Exception{
    List children = zkClient.getChildren("/", true);
    for (String ch : children){
        System.out.println(ch);
    }
    Thread.sleep(Long.MAX_VALUE);
}

在xshell模范添加节点,也可以在代码中模仿添加节点

[zk: localhost:2181(CONNECTED) 0] create -e /java "java"
Created /java
[zk: localhost:2181(CONNECTED) 1] create -e /python "java"
Created /python

打印结果

ea0f5f7d9150249de84de1f60acbf4e7.jpgimage.png

4. 判断节点是否存在

private static final String IPS = "master:2181,slave1:2181,slave2:2181";
private static final int SESSIONTIMEOUT = 200;
private ZooKeeper zkClient = null;

@Before
public void contectTest() throws Exception{
    zkClient = new ZooKeeper(IPS, SESSIONTIMEOUT, new Watcher() {
        @Override
        public void process(WatchedEvent event) {

        }
    });

    System.out.println("==================");
    System.out.println(zkClient.getState());
    System.out.println("==================");
}

@Test
public void exTest() throws Exception{
    Stat exists = zkClient.exists("/test", false);
    System.out.println(exists == null ? "no" : "yes");

}

打印结果

220696bc3688a58ab8750b7f3b373699.jpgimage.png

5. 测试完整代码

package com.example.demo;

import org.apache.zookeeper.*;
import org.apache.zookeeper.data.Stat;
import org.junit.Before;
import org.junit.Test;

import java.util.List;

public class ZKDemo {

    private static final String IPS = "master:2181,slave1:2181,slave2:2181";
    private static final int SESSIONTIMEOUT = 200;
    private ZooKeeper zkClient = null;

    @Before
    public void contectTest() throws Exception{
        zkClient = new ZooKeeper(IPS, SESSIONTIMEOUT, new Watcher() {
            @Override
            public void process(WatchedEvent event) {
                /*System.out.println(event.getType() + "--" + event.getPath());
                try {
                    zkClient.getChildren("/", true);
                } catch (KeeperException e) {
                    e.printStackTrace();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }*/
            }
        });

        System.out.println("==================");
        System.out.println(zkClient.getState());
        System.out.println("==================");
    }

    @Test
    public void createTest() throws Exception{
        String s = zkClient.create("/idea", "helloworld".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);
        System.out.println(s);
    }

    @Test
    public void childrenTest() throws Exception{
        List children = zkClient.getChildren("/", true);
        for (String ch : children){
            System.out.println(ch);
        }
        Thread.sleep(Long.MAX_VALUE);
    }

    @Test
    public void exTest() throws Exception{
        Stat exists = zkClient.exists("/test", false);
        System.out.println(exists == null ? "no" : "yes");

    }


}





文末福利

包含c、c++、java、python、linux、html、php等上百本电子书!

4ff30b6736f8976c9163a31d8fcebee2.jpg

aa7dc62d63e01172b687478ee5f52c00.jpg

1b53df41172ce844877c93d2ba190098.jpg



获取方式:

    搜索并关注公众号:雨中散步撒哈拉

    回复关键词:001




标签:zookeeper,System,println,2181,雨中散步,常用命令,zkClient,public,out
来源: https://blog.51cto.com/u_13501912/2823362