com.github.panhongan.util.zookeeper

类 ZKUtil

java.lang.Object

com.github.panhongan.util.zookeeper.ZKUtil

public class ZKUtil
extends Object

构造器概要

构造器

构造器和说明
ZKUtil()

方法概要

方法

限定符和类型	方法和说明
static void	closeZK(org.apache.zookeeper.ZooKeeper zk)
static org.apache.zookeeper.ZooKeeper	connectZK(String zk_host, int timeout, org.apache.zookeeper.Watcher watcher)
static boolean	createNodeRecursively(org.apache.zookeeper.ZooKeeper zk, String path, boolean is_persistent)
static void	deleteNode(String zk_host, String path)
static void	deleteNode(org.apache.zookeeper.ZooKeeper zk, String path)
static void	deleteNodeRecursively(org.apache.zookeeper.ZooKeeper zk, String path)
static boolean	isValidSession(org.apache.zookeeper.ZooKeeper zk)
static void	waitForConnectionFinished(org.apache.zookeeper.ZooKeeper zk)
static boolean	waitForConnectionFinished(org.apache.zookeeper.ZooKeeper zk, int timeout)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

ZKUtil

public ZKUtil()

方法详细资料

waitForConnectionFinished

public static void waitForConnectionFinished(org.apache.zookeeper.ZooKeeper zk)

waitForConnectionFinished

public static boolean waitForConnectionFinished(org.apache.zookeeper.ZooKeeper zk,
                                int timeout)

connectZK

public static org.apache.zookeeper.ZooKeeper connectZK(String zk_host,
                                       int timeout,
                                       org.apache.zookeeper.Watcher watcher)

closeZK

public static void closeZK(org.apache.zookeeper.ZooKeeper zk)

createNodeRecursively

public static boolean createNodeRecursively(org.apache.zookeeper.ZooKeeper zk,
                            String path,
                            boolean is_persistent)

deleteNode

public static void deleteNode(org.apache.zookeeper.ZooKeeper zk,
              String path)

deleteNode

public static void deleteNode(String zk_host,
              String path)

deleteNodeRecursively

public static void deleteNodeRecursively(org.apache.zookeeper.ZooKeeper zk,
                         String path)

isValidSession

public static boolean isValidSession(org.apache.zookeeper.ZooKeeper zk)