AbstractIntervalWorkerId (Bigbird Framework 1.0.0-SNAPSHOT API)

java.lang.Object
- wang.bigbird.domain.framework.id.worker.AbstractIntervalWorkerId

所有已实现的接口:

WorkerIdAssigner

直接已知子类:

RedisWorkerIdAssigner, ZkWorkerIdAssigner
```
public abstract class AbstractIntervalWorkerId
extends Object
implements WorkerIdAssigner
```
WorkerId生成基类

作者:

Bigbird

字段概要

字段
限定符和类型	字段和说明
`protected AtomicBoolean`	`active` 心跳原子标识
`protected Long`	`interval` 心跳间隔
`protected String`	`pidName` 名称格式为：ip_port
`protected Long`	`workerId`

构造器概要

构造器
构造器和说明

AbstractIntervalWorkerId(Long interval, String pidHome, Integer pidPort)

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

方法概要

所有方法实例方法抽象方法具体方法
限定符和类型	方法和说明
`long`	`assignWorkerId()` 分配一个worker id
`protected abstract Long`	`assignWorkerIdByMiddleware()` 依靠中间件分配一个worker id
`protected abstract long`	`averageTime()` 获取机器节点列表的活跃时间平均值
`void`	`init()` 在初始化workerId的过程中，会执行如下处理： 1、判断之前是否分配了workerId，如果已经分配，那么继续使用上一次分配的workerId，否则新分配一个workerId。
`protected abstract void`	`initEnv()` 初始化环境
`protected abstract long`	`lastTime()` 依靠中间件获取上一次记录的时间
`protected abstract Long`	`loadWorkerIdFromMiddleware()` 从中间件获取已分配的worker id
`protected abstract void`	`registerNode()` 注册节点到节点列表中
`protected abstract void`	`report()` 心跳上报
`protected void`	`startHeartBeatThread()` 心跳线程，用于每隔一段时间上报一次临时节点时间

从类继承的方法 java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- 字段详细资料
  - active
```
protected AtomicBoolean active
```
    心跳原子标识
  - interval
```
protected Long interval
```
    心跳间隔
  - pidName
```
protected String pidName
```
    名称格式为：ip_port
  - workerId
```
protected Long workerId
```
- 构造器详细资料
  - AbstractIntervalWorkerId
```
public AbstractIntervalWorkerId(Long interval,
                                String pidHome,
                                Integer pidPort)
```
- 方法详细资料
  - init
```
@PostConstruct
public void init()
                          throws Exception
```
    在初始化workerId的过程中，会执行如下处理： 1、判断之前是否分配了workerId，如果已经分配，那么继续使用上一次分配的workerId，否则新分配一个workerId。 2、判断当前系统时间与上一次上报的时间，如果小于上一次上报的时间，意味着发生了时钟回拨，失败告警。 3、判断当前系统时间与其余节点的系统时间平均值，如果小于平均值，意味着发生了时钟回拨，失败告警。
    
    抛出:
    
    Exception
  - startHeartBeatThread
```
protected void startHeartBeatThread()
```
    心跳线程，用于每隔一段时间上报一次临时节点时间
  - initEnv
```
protected abstract void initEnv()
                         throws Exception
```
    初始化环境
    
    抛出:
    
    Exception
  - loadWorkerIdFromMiddleware
```
protected abstract Long loadWorkerIdFromMiddleware()
                                            throws Exception
```
    从中间件获取已分配的worker id
    
    返回:
    
    worker id
    
    抛出:
    
    Exception
  - assignWorkerIdByMiddleware
```
protected abstract Long assignWorkerIdByMiddleware()
                                            throws Exception
```
    依靠中间件分配一个worker id
    
    返回:
    
    worker id
    
    抛出:
    
    Exception
  - lastTime
```
protected abstract long lastTime()
                          throws Exception
```
    依靠中间件获取上一次记录的时间
    
    返回:
    
    抛出:
    
    Exception
  - averageTime
```
protected abstract long averageTime()
```
    获取机器节点列表的活跃时间平均值
    
    返回:
    
    机器节点列表的活跃时间平均值
  - registerNode
```
protected abstract void registerNode()
                              throws Exception
```
    注册节点到节点列表中
    
    抛出:
    
    Exception
  - report
```
protected abstract void report()
```
    心跳上报
  - assignWorkerId
```
public long assignWorkerId()
```
    从接口复制的说明: WorkerIdAssigner
    
    分配一个worker id
    
    指定者:
    
    assignWorkerId 在接口中 WorkerIdAssigner
    
    返回:
    
    分配到的 worker id

类 AbstractIntervalWorkerId

字段概要

构造器概要

方法概要

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

字段详细资料

active

interval

pidName

workerId

构造器详细资料

AbstractIntervalWorkerId

方法详细资料

init

startHeartBeatThread

initEnv

loadWorkerIdFromMiddleware

assignWorkerIdByMiddleware

lastTime

averageTime

registerNode

report

assignWorkerId