com.easycodebox.common.zookeeper.curator

类 DefaultCuratorFrameworkFactory

java.lang.Object

com.easycodebox.common.zookeeper.curator.DefaultCuratorFrameworkFactory

所有已实现的接口:

org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.FactoryBean<org.apache.curator.framework.CuratorFramework>, org.springframework.beans.factory.InitializingBean

public class DefaultCuratorFrameworkFactory
extends Object
implements org.springframework.beans.factory.FactoryBean<org.apache.curator.framework.CuratorFramework>, org.springframework.beans.factory.InitializingBean, org.springframework.beans.factory.DisposableBean

ZooKeeper client 节点名制造器 zookeeper数据反序列化 节点 获取节点数据 ****************************************************************************************************** 如果curatorFramework需要多个地方使用，且多个地方的root路径不同，则使用NamespaceCuratorFrameworkFactory 创建不同的namespace对象，然后直接使用新创建的curatorFramework。例子：

作者:

WangXiaoJin

构造器概要

构造器

构造器和说明
DefaultCuratorFrameworkFactory()

方法概要

限定符和类型	方法和说明
void	afterPropertiesSet()
void	destroy()
org.apache.curator.framework.CuratorFramework	getClient()
Integer	getConnectionTimeoutMs()
String	getConnectString()
byte[]	getDefaultData()
org.apache.curator.framework.CuratorFramework	getObject()
Class<?>	getObjectType()
org.apache.curator.RetryPolicy	getRetryPolicy()
Integer	getSessionTimeoutMs()
boolean	isCanBeReadOnly()
boolean	isSingleton()
void	setCanBeReadOnly(boolean canBeReadOnly)
void	setClient(org.apache.curator.framework.CuratorFramework client)
void	setConnectionTimeoutMs(Integer connectionTimeoutMs)
void	setConnectString(String connectString)
void	setDefaultData(byte[] defaultData)
void	setRetryPolicy(org.apache.curator.RetryPolicy retryPolicy)
void	setSessionTimeoutMs(Integer sessionTimeoutMs)

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

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

构造器详细资料

DefaultCuratorFrameworkFactory

public DefaultCuratorFrameworkFactory()

方法详细资料

destroy

public void destroy()
             throws Exception

指定者:

destroy 在接口中 org.springframework.beans.factory.DisposableBean

抛出:

Exception

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

指定者:

afterPropertiesSet 在接口中 org.springframework.beans.factory.InitializingBean

抛出:

Exception

getObject

public org.apache.curator.framework.CuratorFramework getObject()
                                                        throws Exception

指定者:

getObject 在接口中 org.springframework.beans.factory.FactoryBean<org.apache.curator.framework.CuratorFramework>

抛出:

Exception

getObjectType

public Class<?> getObjectType()

指定者:

getObjectType 在接口中 org.springframework.beans.factory.FactoryBean<org.apache.curator.framework.CuratorFramework>

isSingleton

public boolean isSingleton()

指定者:

isSingleton 在接口中 org.springframework.beans.factory.FactoryBean<org.apache.curator.framework.CuratorFramework>

getClient

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

setClient

public void setClient(org.apache.curator.framework.CuratorFramework client)

getConnectString

public String getConnectString()

setConnectString

public void setConnectString(String connectString)

getRetryPolicy

public org.apache.curator.RetryPolicy getRetryPolicy()

setRetryPolicy

public void setRetryPolicy(org.apache.curator.RetryPolicy retryPolicy)

getSessionTimeoutMs

public Integer getSessionTimeoutMs()

setSessionTimeoutMs

public void setSessionTimeoutMs(Integer sessionTimeoutMs)

getConnectionTimeoutMs

public Integer getConnectionTimeoutMs()

setConnectionTimeoutMs

public void setConnectionTimeoutMs(Integer connectionTimeoutMs)

getDefaultData

public byte[] getDefaultData()

setDefaultData

public void setDefaultData(byte[] defaultData)

isCanBeReadOnly

public boolean isCanBeReadOnly()

setCanBeReadOnly

public void setCanBeReadOnly(boolean canBeReadOnly)