wang.bigbird.domain.framework.id.base.utils

类 WorkerIdUtils

java.lang.Object

wang.bigbird.domain.framework.id.base.utils.WorkerIdUtils

public class WorkerIdUtils
extends Object

worker id文件操作类

作者:

Bigbird

字段概要

字段

限定符和类型	字段和说明
static String	WORKER_SPLIT workerID文件分隔符

构造器概要

构造器

构造器和说明
WorkerIdUtils()

方法概要

限定符和类型	方法和说明
static String	getPidName(Integer pidPort, ServerSocket socket) 获取ip和端口构成的节点唯一标识PidName
static Long	getWorkerId(String pidHome, String pidName) 获取worker id 如果节点对应的worker id存在，那么，在pidHome目录下会存在如下名称的文件 pidName_workerId
static void	sleepMs(long ms, long diff) 睡眠等待回拨时间
static void	writePidFile(String name) 创建workerID文件（workerID文件已经存在，则不创建，返回一个false；如果没有，则返回true） 文件名称格式：ip_port_workerID

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

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

字段详细资料

WORKER_SPLIT

public static final String WORKER_SPLIT

workerID文件分隔符

另请参阅:

常量字段值

构造器详细资料

WorkerIdUtils

public WorkerIdUtils()

方法详细资料

getPidName

public static String getPidName(Integer pidPort,
                                ServerSocket socket)

获取ip和端口构成的节点唯一标识PidName

参数:

pidPort - 使用端口，

socket - 用于验证端口是否可用并且在节点服务时持续占用端口

返回:

格式为：ip_port的PidName

getWorkerId

public static Long getWorkerId(String pidHome,
                               String pidName)

获取worker id

如果节点对应的worker id存在，那么，在pidHome目录下会存在如下名称的文件 pidName_workerId

参数:

pidHome - workerID文件存储路径

pidName - 节点唯一标识PidName

返回:

worker ID值

sleepMs

public static void sleepMs(long ms,
                           long diff)

睡眠等待回拨时间

参数:

ms - 平均心跳时间

diff - 回拨时间差

writePidFile

public static void writePidFile(String name)

创建workerID文件（workerID文件已经存在，则不创建，返回一个false；如果没有，则返回true） 文件名称格式：ip_port_workerID

参数:

name - workerID文件路径