org.apache.zookeeper.Zookeeper

* Zookeeper 是在Java中客户端主类,负责建立与zookeeper集群的会话,并提供方法进行操作。 

  org.apache.zookeeper.Watcher

Watcher接口表示一个标准的事件处理器,其定义了事件通知相关的逻辑,包含KeeperState和EventType两个枚举类,分别代表了通知状态和事件类型,同时定义了事件的回调方法:process(WatchedEvent event)。

process方法是Watcher接口中的一个回调方法,当ZooKeeper向客户端发送一个Watcher事件通知时,客户端就会对相应的process方法进行回调,从而实现对事件的处理。**

 基本使用

1 导入 pom

建立java maven项目,引入maven pom坐标。

<dependency>

    <groupId>org.apache.zookeeper</groupId>

    <artifactId>zookeeper</artifactId>

    <version>3.4.9</version>

</dependency>

2 代码实现:

public static void main(String[] args) throws Exception {

        // 初始化 ZooKeeper实例(zk地址、会话超时时间,与系统默认一致、watcher)

        ZooKeeper zk = new ZooKeeper("node-1:2181,node-2:2181", 30000, new Watcher() {

            @Override

            public void process(WatchedEvent event) {

                System.out.println("事件类型为:" + event.getType());

                System.out.println("事件发生的路径:" + event.getPath());

                System.out.println("通知状态为:" +event.getState());

            }

        });

zk.create("/myGirls", "性感的".getBytes("UTF-8"), Ids.OPEN_ACL_UNSAFE,

 CreateMode.PERSISTENT);

      zk.close();

代码实现 截图 :

运行结果

 结果 原因

 成功 结果

Logo

权威|前沿|技术|干货|国内首个API全生命周期开发者社区

更多推荐