com.dangdang.ddframe.job.internal.storage

类 JobNodeStorage

java.lang.Object

com.dangdang.ddframe.job.internal.storage.JobNodeStorage

public class JobNodeStorage
extends Object

作业节点数据访问类.

作业节点是在普通的节点前加上作业名称的前缀.

作者:

zhangliang

构造器概要

构造器

构造器和说明
JobNodeStorage(CoordinatorRegistryCenter coordinatorRegistryCenter, JobConfiguration jobConfiguration)

方法概要

方法

限定符和类型	方法和说明
void	addConnectionStateListener(org.apache.curator.framework.state.ConnectionStateListener listener) 注册连接状态监听器.
void	addDataListener(org.apache.curator.framework.recipes.cache.TreeCacheListener listener) 注册数据监听器.
void	createJobNodeIfNeeded(String node) 如果存在则创建作业节点.
void	executeInLeader(String latchNode, LeaderExecutionCallback callback) 在主节点执行操作.
void	executeInTransaction(TransactionExecutionCallback callback) 在事务中执行操作.
void	fillEphemeralJobNode(String node, Object value) 填充临时节点数据.
void	fillJobNodeIfNullOrOverwrite(String node, Object value) 如果节点不存在或允许覆盖则填充节点数据.
List<String>	getJobNodeChildrenKeys(String node) 获取作业节点子节点名称列表.
String	getJobNodeData(String node) 获取作业节点数据.
String	getJobNodeDataDirectly(String node) 直接从注册中心而非本地缓存获取作业节点数据.
long	getRegistryCenterTime() 获取注册中心当前时间.
boolean	isJobNodeExisted(String node) 判断作业节点是否存在.
void	removeJobNodeIfExisted(String node) 删除作业节点.
void	replaceJobNode(String node, Object value) 替换作业节点数据.
void	updateJobNode(String node, Object value) 更新节点数据.

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

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

构造器详细资料

JobNodeStorage

public JobNodeStorage(CoordinatorRegistryCenter coordinatorRegistryCenter,
              JobConfiguration jobConfiguration)

方法详细资料

isJobNodeExisted

public boolean isJobNodeExisted(String node)

判断作业节点是否存在.

参数:

node - 作业节点名称

返回:

作业节点是否存在

getJobNodeData

public String getJobNodeData(String node)

获取作业节点数据.

参数:

node - 作业节点名称

返回:

作业节点数据值

getJobNodeDataDirectly

public String getJobNodeDataDirectly(String node)

直接从注册中心而非本地缓存获取作业节点数据.

参数:

node - 作业节点名称

返回:

作业节点数据值

getJobNodeChildrenKeys

public List<String> getJobNodeChildrenKeys(String node)

获取作业节点子节点名称列表.

参数:

node - 作业节点名称

返回:

作业节点子节点名称列表

createJobNodeIfNeeded

public void createJobNodeIfNeeded(String node)

如果存在则创建作业节点.

参数:

node - 作业节点名称

removeJobNodeIfExisted

public void removeJobNodeIfExisted(String node)

删除作业节点.

参数:

node - 作业节点名称

fillJobNodeIfNullOrOverwrite

public void fillJobNodeIfNullOrOverwrite(String node,
                                Object value)

如果节点不存在或允许覆盖则填充节点数据.

参数:

node - 作业节点名称

value - 作业节点数据值

fillEphemeralJobNode

public void fillEphemeralJobNode(String node,
                        Object value)

填充临时节点数据.

参数:

node - 作业节点名称

value - 作业节点数据值

updateJobNode

public void updateJobNode(String node,
                 Object value)

更新节点数据.

参数:

node - 作业节点名称

value - 作业节点数据值

replaceJobNode

public void replaceJobNode(String node,
                  Object value)

替换作业节点数据.

参数:

node - 作业节点名称

value - 待替换的数据

executeInTransaction

public void executeInTransaction(TransactionExecutionCallback callback)

在事务中执行操作.

参数:

callback - 执行操作的回调

executeInLeader

public void executeInLeader(String latchNode,
                   LeaderExecutionCallback callback)

在主节点执行操作.

参数:

latchNode - 分布式锁使用的作业节点名称

callback - 执行操作的回调

addConnectionStateListener

public void addConnectionStateListener(org.apache.curator.framework.state.ConnectionStateListener listener)

注册连接状态监听器.

addDataListener

public void addDataListener(org.apache.curator.framework.recipes.cache.TreeCacheListener listener)

注册数据监听器.

getRegistryCenterTime

public long getRegistryCenterTime()

获取注册中心当前时间.

返回:

注册中心当前时间