com.dangdang.ddframe.job.internal.server

类 ServerService

java.lang.Object

com.dangdang.ddframe.job.internal.server.ServerService

public class ServerService
extends Object

作业服务器节点服务.

作者:

zhangliang, caohao

构造器概要

构造器

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

方法概要

方法

限定符和类型	方法和说明
void	clearJobStoppedStatus() 清除停止作业的标记.
void	clearPreviousServerStatus() 每次作业启动前清理上次运行状态.
List<String>	getAllServers() 获取所有的作业服务器列表.
List<String>	getAvailableServers() 获取可用的作业服务器列表.
boolean	isJobStoppedManually() 判断是否是手工停止的作业.
boolean	isServerReady() 判断当前服务器是否是等待执行的状态.
void	persistProcessFailureCount(int processFailureCount) 持久化统计处理数据失败的数量的数据.
void	persistProcessSuccessCount(int processSuccessCount) 持久化统计处理数据成功的数量的数据.
void	persistServerOnline() 持久化作业服务器上线相关信息.
void	processServerShutdown() 处理服务器关机的相关信息.
void	updateServerStatus(ServerStatus status) 在开始或结束执行作业时更新服务器状态.

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

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

构造器详细资料

ServerService

public ServerService(CoordinatorRegistryCenter coordinatorRegistryCenter,
             JobConfiguration jobConfiguration)

方法详细资料

clearPreviousServerStatus

public void clearPreviousServerStatus()

每次作业启动前清理上次运行状态.

persistServerOnline

public void persistServerOnline()

持久化作业服务器上线相关信息.

clearJobStoppedStatus

public void clearJobStoppedStatus()

清除停止作业的标记.

isJobStoppedManually

public boolean isJobStoppedManually()

判断是否是手工停止的作业.

返回:

是否是手工停止的作业

processServerShutdown

public void processServerShutdown()

处理服务器关机的相关信息.

updateServerStatus

public void updateServerStatus(ServerStatus status)

在开始或结束执行作业时更新服务器状态.

参数:

status - 服务器状态

getAllServers

public List<String> getAllServers()

获取所有的作业服务器列表.

返回:

所有的作业服务器列表

getAvailableServers

public List<String> getAvailableServers()

获取可用的作业服务器列表.

返回:

可用的作业服务器列表

isServerReady

public boolean isServerReady()

判断当前服务器是否是等待执行的状态.

返回:

当前服务器是否是等待执行的状态

persistProcessSuccessCount

public void persistProcessSuccessCount(int processSuccessCount)

持久化统计处理数据成功的数量的数据.

persistProcessFailureCount

public void persistProcessFailureCount(int processFailureCount)

持久化统计处理数据失败的数量的数据.