com.baidu.disconf.core.common.zookeeper

Class ZookeeperMgr

java.lang.Object

com.baidu.disconf.core.common.zookeeper.ZookeeperMgr

public class ZookeeperMgr
extends Object

ZK统一管理器

Version:

2014-7-7

Author:

liaoqiqi

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	LOGGER

Method Summary

Methods

Modifier and Type	Method and Description
String	createEphemeralNode(String path, String value, org.apache.zookeeper.CreateMode createMode)
void	deleteNode(String path)
boolean	exists(String path)
static ZookeeperMgr	getInstance()
List<String>	getRootChildren()
org.apache.zookeeper.ZooKeeper	getZk()
void	init(String host, String defaultPrefixString, boolean debug)
void	makeDir(String dir, String data) Zoo的新建目录
String	read(String path, org.apache.zookeeper.Watcher watcher, org.apache.zookeeper.data.Stat stat)
String	readUrl(String url, org.apache.zookeeper.Watcher watcher)
void	reconnect() 重新连接
void	release()
void	writePersistentUrl(String url, String value)

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

protected static final org.slf4j.Logger LOGGER

Method Detail

init

public void init(String host,
        String defaultPrefixString,
        boolean debug)
          throws Exception

Throws:

Exception

getInstance

public static ZookeeperMgr getInstance()

reconnect

public void reconnect()

重新连接

makeDir

public void makeDir(String dir,
           String data)

Zoo的新建目录

Parameters:

dir -

release

public void release()
             throws InterruptedException

Throws:

InterruptedException

getRootChildren

public List<String> getRootChildren()

Returns:

List

writePersistentUrl

public void writePersistentUrl(String url,
                      String value)
                        throws Exception

Throws:

Exception

readUrl

public String readUrl(String url,
             org.apache.zookeeper.Watcher watcher)
               throws Exception

Returns:

List

Throws:

Exception

getZk

public org.apache.zookeeper.ZooKeeper getZk()

exists

public boolean exists(String path)
               throws Exception

Throws:

Exception

createEphemeralNode

public String createEphemeralNode(String path,
                         String value,
                         org.apache.zookeeper.CreateMode createMode)
                           throws Exception

Throws:

Exception

read

public String read(String path,
          org.apache.zookeeper.Watcher watcher,
          org.apache.zookeeper.data.Stat stat)
            throws InterruptedException,
                   org.apache.zookeeper.KeeperException

Parameters:

path -

watcher -

stat -

Returns:

String

Throws:

InterruptedException

org.apache.zookeeper.KeeperException

deleteNode

public void deleteNode(String path)

Parameters:

path -