wang.bigbird.domain.framework.id.worker

类 RedisWorkerIdAssigner

java.lang.Object

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

wang.bigbird.domain.framework.id.worker.RedisWorkerIdAssigner

所有已实现的接口:

WorkerIdAssigner

public class RedisWorkerIdAssigner
extends AbstractIntervalWorkerId

Redis编号分配器，相对于ZK编号分配器，判断活跃节点存在一定延迟

作者:

Bigbird

字段概要

字段

限定符和类型	字段和说明
static String	UID_FOREVER uid机器节点列表
static String	UID_ROOT redis上uid机器节点的key前缀
static String	UID_TEMPORARY uid活跃节点心跳列表（用于保存活跃节点及活跃心跳）

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

active, interval, pidName, workerId

构造器概要

构造器

构造器和说明
RedisWorkerIdAssigner(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

字段详细资料

UID_ROOT

public static final String UID_ROOT

redis上uid机器节点的key前缀

另请参阅:

常量字段值

UID_FOREVER

public static final String UID_FOREVER

uid机器节点列表

UID_TEMPORARY

public static final String UID_TEMPORARY

uid活跃节点心跳列表（用于保存活跃节点及活跃心跳）

构造器详细资料

RedisWorkerIdAssigner

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

方法详细资料

initEnv

protected void initEnv()

从类复制的说明: AbstractIntervalWorkerId

初始化环境

指定者:

initEnv 在类中 AbstractIntervalWorkerId

loadWorkerIdFromMiddleware

protected Long loadWorkerIdFromMiddleware()

从类复制的说明: AbstractIntervalWorkerId

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

指定者:

loadWorkerIdFromMiddleware 在类中 AbstractIntervalWorkerId

返回:

worker id

assignWorkerIdByMiddleware

protected Long assignWorkerIdByMiddleware()

从类复制的说明: AbstractIntervalWorkerId

依靠中间件分配一个worker id

指定者:

assignWorkerIdByMiddleware 在类中 AbstractIntervalWorkerId

返回:

worker id

lastTime

protected long lastTime()

从类复制的说明: AbstractIntervalWorkerId

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

指定者:

lastTime 在类中 AbstractIntervalWorkerId

返回:

averageTime

protected long averageTime()

从类复制的说明: AbstractIntervalWorkerId

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

指定者:

averageTime 在类中 AbstractIntervalWorkerId

返回:

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

registerNode

protected void registerNode()

从类复制的说明: AbstractIntervalWorkerId

注册节点到节点列表中

指定者:

registerNode 在类中 AbstractIntervalWorkerId

report

protected void report()

从类复制的说明: AbstractIntervalWorkerId

心跳上报

指定者:

report 在类中 AbstractIntervalWorkerId