public class CacheSyncExecutorTicket extends ClusterTicketAdaptor
构造器和说明 |
---|
CacheSyncExecutorTicket() |
限定符和类型 | 方法和说明 |
---|---|
void |
afterJoin()
状态同步完成后调用,成功加入集群的通知。
|
void |
approach(ClusterToolKit toolKit)
通知进场(连接各种Channel、ClusterInvoker、RPCProxy)
|
void |
beforeJoin()
进场之前通知,通常用于锁住集群的当前模块,使当前节点的该模块进场时,其他节点的对应模块不会发生状态改变
|
void |
catchUpWith(ClusterNode node)
进场成功,跟随某个节点的状态(通常使用进场时注册的通信组件)
如果是第一台机器,则不会调用这个方法
|
ResourceConsistenceExecutor |
getExecutor() |
static CacheSyncExecutorTicket |
getInstance() |
void |
onLeft()
离场时监听
|
public static CacheSyncExecutorTicket getInstance()
public void beforeJoin()
ClusterTicket
public void approach(ClusterToolKit toolKit)
ClusterTicket
public void catchUpWith(ClusterNode node)
ClusterTicket
public void afterJoin()
ClusterTicket
public void onLeft()
ClusterTicket
public ResourceConsistenceExecutor getExecutor()