wang.bigbird.domain.framework.id.worker

类 ZkWorkerIdAssigner

java.lang.Object

wang.bigbird.domain.framework.id.worker.AbstractIntervalWorkerId

wang.bigbird.domain.framework.id.worker.ZkWorkerIdAssigner

所有已实现的接口:

WorkerIdAssigner

public class ZkWorkerIdAssigner
extends AbstractIntervalWorkerId

ZK编号分配器

作者:

Bigbird

字段概要

字段

限定符和类型	字段和说明
static String	UID_FOREVER 持久顺序节点根目录(用于保存节点的顺序编号)
static String	UID_ROOT ZK上uid根目录
static String	UID_TEMPORARY 临时节点根目录(用于保存活跃节点及活跃心跳)
static String	ZK_SPLIT

从类继承的字段 wang.bigbird.domain.framework.id.worker.AbstractIntervalWorkerId

active, interval, pidName, workerId

构造器概要

构造器

构造器和说明
ZkWorkerIdAssigner(Long interval, String pidHome, Integer pidPort)

方法概要

限定符和类型	方法和说明
protected Long	assignWorkerIdByMiddleware() 依靠中间件分配一个worker id
protected long	averageTime() 获取机器节点列表的活跃时间平均值
protected void	initEnv() 初始化环境
protected long	lastTime() 依靠中间件获取上一次记录的时间
protected Long	loadWorkerIdFromMiddleware() 从中间件获取已分配的worker id
protected void	registerNode() 注册节点到节点列表中
protected void	report() 心跳上报

从类继承的方法 wang.bigbird.domain.framework.id.worker.AbstractIntervalWorkerId

assignWorkerId, init, startHeartBeatThread

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

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

字段详细资料

ZK_SPLIT

public static final String ZK_SPLIT

另请参阅:

常量字段值

UID_ROOT

public static final String UID_ROOT

ZK上uid根目录

另请参阅:

常量字段值

UID_FOREVER

public static final String UID_FOREVER

持久顺序节点根目录(用于保存节点的顺序编号)

UID_TEMPORARY

public static final String UID_TEMPORARY

临时节点根目录(用于保存活跃节点及活跃心跳)

构造器详细资料

ZkWorkerIdAssigner

public ZkWorkerIdAssigner(Long interval,
                          String pidHome,
                          Integer pidPort)

方法详细资料

initEnv

protected void initEnv()
                throws Exception

从类复制的说明: AbstractIntervalWorkerId

初始化环境

指定者:

initEnv 在类中 AbstractIntervalWorkerId

抛出:

Exception

loadWorkerIdFromMiddleware

protected Long loadWorkerIdFromMiddleware()
                                   throws Exception

从类复制的说明: AbstractIntervalWorkerId

从中间件获取已分配的worker id

指定者:

loadWorkerIdFromMiddleware 在类中 AbstractIntervalWorkerId

返回:

worker id

抛出:

Exception

assignWorkerIdByMiddleware

protected Long assignWorkerIdByMiddleware()
                                   throws Exception

从类复制的说明: AbstractIntervalWorkerId

依靠中间件分配一个worker id

指定者:

assignWorkerIdByMiddleware 在类中 AbstractIntervalWorkerId

返回:

worker id

抛出:

Exception

lastTime

protected long lastTime()
                 throws Exception

从类复制的说明: AbstractIntervalWorkerId

依靠中间件获取上一次记录的时间

指定者:

lastTime 在类中 AbstractIntervalWorkerId

返回:

抛出:

Exception

averageTime

protected long averageTime()

从类复制的说明: AbstractIntervalWorkerId

获取机器节点列表的活跃时间平均值

指定者:

averageTime 在类中 AbstractIntervalWorkerId

返回:

机器节点列表的活跃时间平均值

registerNode

protected void registerNode()
                     throws Exception

从类复制的说明: AbstractIntervalWorkerId

注册节点到节点列表中

指定者:

registerNode 在类中 AbstractIntervalWorkerId

抛出:

Exception

report

protected void report()

从类复制的说明: AbstractIntervalWorkerId

心跳上报

指定者:

report 在类中 AbstractIntervalWorkerId