org.apache.shenyu.sync.data.zookeeper

类 ZookeeperClient

java.lang.Object

org.apache.shenyu.sync.data.zookeeper.ZookeeperClient

所有已实现的接口:

java.lang.AutoCloseable

public class ZookeeperClient
extends java.lang.Object
implements java.lang.AutoCloseable

构造器概要

构造器

构造器和说明
ZookeeperClient(ZookeeperConfig zookeeperConfig)

方法概要

限定符和类型	方法和说明
org.apache.curator.framework.recipes.cache.TreeCache	addCache(java.lang.String path, org.apache.curator.framework.recipes.cache.TreeCacheListener... listeners) add new curator cache.
void	close() start.
void	createOrUpdate(java.lang.String key, java.lang.Object value, org.apache.zookeeper.CreateMode mode) create or update key with value.
void	createOrUpdate(java.lang.String key, java.lang.String value, org.apache.zookeeper.CreateMode mode) create or update key with value.
void	delete(java.lang.String key) delete a node with specific key.
java.lang.String	get(java.lang.String key) get value for specific key.
org.apache.curator.framework.recipes.cache.TreeCache	getCache(java.lang.String path) get created cache.
java.util.List<java.lang.String>	getChildren(java.lang.String key) get children with specific key.
org.apache.curator.framework.CuratorFramework	getClient() get curator framework.
java.lang.String	getDirectly(java.lang.String key) get from zk directly.
boolean	isExist(java.lang.String key) check if key exist.
void	start() start.

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

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

构造器详细资料

ZookeeperClient

public ZookeeperClient(ZookeeperConfig zookeeperConfig)

方法详细资料

start

public void start()

start.

close

public void close()

start.

指定者:

close 在接口中 java.lang.AutoCloseable

getClient

public org.apache.curator.framework.CuratorFramework getClient()

get curator framework.

返回:

curator framework client.

isExist

public boolean isExist(java.lang.String key)

check if key exist.

参数:

key - zookeeper path

返回:

if exist.

getDirectly

public java.lang.String getDirectly(java.lang.String key)

get from zk directly.

参数:

key - zookeeper path

返回:

value.

get

public java.lang.String get(java.lang.String key)

get value for specific key.

参数:

key - zookeeper path

返回:

value.

createOrUpdate

public void createOrUpdate(java.lang.String key,
                           java.lang.String value,
                           org.apache.zookeeper.CreateMode mode)

create or update key with value.

参数:

key - zookeeper path key.

value - string value.

mode - creation mode.

createOrUpdate

public void createOrUpdate(java.lang.String key,
                           java.lang.Object value,
                           org.apache.zookeeper.CreateMode mode)

create or update key with value.

参数:

key - zookeeper path key.

value - object value.

mode - creation mode.

delete

public void delete(java.lang.String key)

delete a node with specific key.

参数:

key - zookeeper path key.

getChildren

public java.util.List<java.lang.String> getChildren(java.lang.String key)

get children with specific key.

参数:

key - zookeeper key.

返回:

children node name.

getCache

public org.apache.curator.framework.recipes.cache.TreeCache getCache(java.lang.String path)

get created cache.

参数:

path - path.

返回:

cache.

addCache

public org.apache.curator.framework.recipes.cache.TreeCache addCache(java.lang.String path,
                                                                     org.apache.curator.framework.recipes.cache.TreeCacheListener... listeners)

add new curator cache.

参数:

path - path.

listeners - listeners.

返回:

cache.