org.tio.utils.zk

Class Zk

java.lang.Object

org.tio.utils.zk.Zk

public class Zk
extends Object

Author:

tanyaowu 2017年9月19日 下午3:06:34

Field Summary

Fields

Modifier and Type	Field and Description
static org.apache.curator.framework.CuratorFramework	zkclient

Constructor Summary

Constructors

Constructor and Description
Zk()

Method Summary

Modifier and Type	Method and Description
static void	addPathChildrenCacheListener(String path, org.apache.curator.framework.recipes.cache.PathChildrenCacheListener pathChildrenCacheListener)
static void	createContainers(String path)
static void	createOrUpdate(String path, byte[] content, org.apache.zookeeper.CreateMode createMode)
static void	createOrUpdate(String path, String content, org.apache.zookeeper.CreateMode createMode)
static void	delete(String path)
static boolean	exists(String path)
static byte[]	getBytes(String path)
static List<String>	getChildren(String path)
static String	getString(String path)
static String	getString(String path, String charset)
static void	init(String address, ClientDecorator clientDecorator)
static void	setData(String path, byte[] bs)
static void	setData(String path, String content)
static void	start() Start the client.
static void	upload(String path, String localpath, org.apache.zookeeper.CreateMode createMode)

Methods inherited from class java.lang.Object

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

Field Detail

zkclient

public static org.apache.curator.framework.CuratorFramework zkclient

Constructor Detail

Zk

public Zk()

Method Detail

init

public static void init(String address,
                        ClientDecorator clientDecorator)
                 throws Exception

Parameters:

address -

clientDecorator -

Throws:

Exception

start

public static void start()

Start the client. Most mutator methods will not work until the client is started

createOrUpdate

public static void createOrUpdate(String path,
                                  String content,
                                  org.apache.zookeeper.CreateMode createMode)
                           throws Exception

Parameters:

path -

content -

createMode -

Throws:

Exception

createOrUpdate

public static void createOrUpdate(String path,
                                  byte[] content,
                                  org.apache.zookeeper.CreateMode createMode)
                           throws Exception

Parameters:

path -

content -

createMode -

Throws:

Exception

createContainers

public static void createContainers(String path)
                             throws Exception

Throws:

Exception

delete

public static void delete(String path)
                   throws Exception

Parameters:

path -

Throws:

Exception

exists

public static boolean exists(String path)
                      throws Exception

Parameters:

path -

Returns:

Throws:

Exception

getBytes

public static byte[] getBytes(String path)
                       throws Exception

Parameters:

path -

Returns:

Throws:

Exception

getString

public static String getString(String path,
                               String charset)
                        throws Exception

Parameters:

path -

charset -

Returns:

Throws:

Exception

getString

public static String getString(String path)
                        throws Exception

Throws:

Exception

getChildren

public static List<String> getChildren(String path)
                                throws Exception

Parameters:

path -

Returns:

Throws:

Exception

upload

public static void upload(String path,
                          String localpath,
                          org.apache.zookeeper.CreateMode createMode)
                   throws Exception

Parameters:

path -

localpath -

createMode -

Throws:

Exception

setData

public static void setData(String path,
                           byte[] bs)
                    throws Exception

Parameters:

path -

bs -

Throws:

Exception

setData

public static void setData(String path,
                           String content)
                    throws Exception

Parameters:

path -

content -

Throws:

Exception

addPathChildrenCacheListener

public static void addPathChildrenCacheListener(String path,
                                                org.apache.curator.framework.recipes.cache.PathChildrenCacheListener pathChildrenCacheListener)
                                         throws Exception

Parameters:

path -

pathChildrenCacheListener -

Throws:

Exception