接口 com.fr.cluster.core.ClusterNode
的使用

使用ClusterNode的程序包

程序包	说明
com.fr.cluster.core
com.fr.cluster.core.event
com.fr.cluster.engine.assist.consistence
com.fr.cluster.engine.assist.monitor
com.fr.cluster.engine.assist.monitor.impl
com.fr.cluster.engine.assist.monitor.impl.crash
com.fr.cluster.engine.assist.monitor.impl.time
com.fr.cluster.engine.assist.monitor.schedule.time
com.fr.cluster.engine.base
com.fr.cluster.engine.core
com.fr.cluster.engine.event
com.fr.cluster.engine.member.persistence	Created by juhaoyu on 2018/3/6.
com.fr.cluster.engine.member.view	Created by juhaoyu on 2018/3/6.
com.fr.cluster.engine.rpc.proxy.components
com.fr.cluster.engine.transport.context
com.fr.cluster.engine.transport.context.impl
com.fr.cluster.entry
com.fr.cluster.extension
com.fr.cluster.extension.strategy
com.fr.cluster.extension.strategy.impl
com.fr.cluster.message
com.fr.cluster.message.components
com.fr.cluster.rpc.base	Created by juhaoyu on 2017/12/15.
com.fr.cluster.rpc.proxy	Created by juhaoyu on 2017/12/15.
com.fr.decision.webservice.v10.backup
com.fr.decision.webservice.v10.backup.module
com.fr.decision.webservice.v10.log
com.fr.decision.webservice.v10.user.sync
com.fr.io.context.manager
com.fr.io.sync	1、新节点启动BOOTSTRAP引导流程 a、已有节点正在运行时，增加一个新的节点，会选择一台CACHE不为空的节点作为同步源； b、新节点会发送所有下层资源仓库的文件MD5列表到同步源节点； c、同步源节点会比较和本地的资源比较MD5值，会以同步源节点为基准(新节点存在而同步源节点不存在的资源会忽略掉)，若MD5不一致就加到待同步列表； d、如果待同步列表的某些资源不在缓存，则会触发拉取到缓存并同步到其它节点； e、如果待同步列表的某些资源在缓存中，则会直接发送这些缓存到新节点； 2、缓存与资源文件 a、默认模式下，资源不会主动加载到缓存中，只有访问的时候，才会从下层资源仓库加载，一旦加载其它节点就会同步； b、缓存的key值都是下层资源仓库的工作目录的相对路径，比如～/tomcat/webApps/WebReport1/WEB-INF/reportlets/abc.cpt")，其缓存key就是reportlets/abc.cpt; c、手动添加的资源文件，如果开启（手动或者自动）了自动扫描监听会同步到各个节点； 3、资源文件同步模块的使用 a、当集群各个节点使用文件系统存储时，需要进行文件同步； b、当集群各个节点使用共享存储时，将关闭同步功能，仅提供缓存功能； c、非集群环境下，不会启动资源文件同步模块； Created by rinoux on 2018/2/1.
com.fr.schedule.feature.job
com.fr.scheduler.job
com.fr.transaction

com.fr.cluster.core中ClusterNode的使用

返回ClusterNode的com.fr.cluster.core中的方法

限定符和类型	方法和说明
ClusterNode	ClusterMergeSubView.getCreator() 谁创建了合并子集群
ClusterNode	ClusterView.getCurrent() 获取当前节点
ClusterNode	ClusterView.getNodeById(java.lang.String id) 根据id获取节点

返回变量类型为ClusterNode的类型的com.fr.cluster.core中的方法

限定符和类型	方法和说明
java.util.List<ClusterNode>	ClusterMergeSubView.getMembers() 所有的节点
java.util.List<ClusterNode>	ClusterView.listNodes() 获取所有节点
java.util.List<ClusterNode>	ClusterView.listNodes(Filter<ClusterNode> filter) 自定义获取节点（多数用于根据状态过滤）

类型变量类型为ClusterNode的com.fr.cluster.core中的方法参数

限定符和类型	方法和说明
EventTrigger	EmptyCluster.getClusterEventTrigger(Filter<ClusterNode> filter)
EventTrigger	Cluster.getClusterEventTrigger(Filter<ClusterNode> filter) 获取集群下的事件触发器，用于触发事件，同时可以作为一个运行中简便的RPC方式（发送事件给其他节点）
java.util.List<ClusterNode>	ClusterView.listNodes(Filter<ClusterNode> filter) 自定义获取节点（多数用于根据状态过滤）

com.fr.cluster.core.event中ClusterNode的使用

类型参数类型为ClusterNode的com.fr.cluster.core.event中的字段

限定符和类型	字段和说明
static Event<ClusterNode>	ClusterViewEvent.NODE_CONNECTED 某个节点连接上集群 视图改变的时候，如果节点不在当前的视图列表中则会发送节点连接事件
static Event<ClusterNode>	ClusterViewEvent.NODE_JOINED 某个节点正式加入集群
static Event<ClusterNode>	ClusterViewEvent.NODE_LEFT 某个节点离开集群 视图改变的时候，如果之前保留的视图节点列表中的节点不在当前刷新的列表中则会发送该事件

com.fr.cluster.engine.assist.consistence中ClusterNode的使用

参数类型为ClusterNode的com.fr.cluster.engine.assist.consistence中的方法

限定符和类型	方法和说明
static boolean	ClusterConsistenceUtil.validateJarConsistence4OldNode(ClusterNode newClusterNode) 用于比较新加入的节点和第一个节点是否一致

com.fr.cluster.engine.assist.monitor中ClusterNode的使用

参数类型为ClusterNode的com.fr.cluster.engine.assist.monitor中的方法

限定符和类型	方法和说明
void	ClusterMonitor.monitor(ClusterNode node) 监视某一个节点 看这个节点有没有问题。

com.fr.cluster.engine.assist.monitor.impl中ClusterNode的使用

参数类型为ClusterNode的com.fr.cluster.engine.assist.monitor.impl中的方法

限定符和类型	方法和说明
void	AbstractClusterMonitor.monitor(ClusterNode node)

com.fr.cluster.engine.assist.monitor.impl.crash中ClusterNode的使用

参数类型为ClusterNode的com.fr.cluster.engine.assist.monitor.impl.crash中的方法

限定符和类型	方法和说明
void	ClusterCrashMonitor.monitor(ClusterNode crashNode)

com.fr.cluster.engine.assist.monitor.impl.time中ClusterNode的使用

参数类型为ClusterNode的com.fr.cluster.engine.assist.monitor.impl.time中的方法

限定符和类型	方法和说明
void	ClusterTimeMeasureTicket.catchUpWith(ClusterNode node)
void	ClusterTimeMonitor.monitor(ClusterNode node)

com.fr.cluster.engine.assist.monitor.schedule.time中ClusterNode的使用

参数类型为ClusterNode的com.fr.cluster.engine.assist.monitor.schedule.time中的方法

限定符和类型	方法和说明
void	ClusterTimeConsistenceJob.run(com.fr.third.v2.org.quartz.JobExecutionContext context, ClusterNode node)

com.fr.cluster.engine.base中ClusterNode的使用

返回ClusterNode的com.fr.cluster.engine.base中的方法

限定符和类型	方法和说明
static ClusterNode	ClusterEngineUtils.transformAddress(Address address)

返回变量类型为ClusterNode的类型的com.fr.cluster.engine.base中的方法

限定符和类型	方法和说明
static java.util.List<ClusterNode>	ClusterEngineUtils.translateMembers(java.util.List<Address> members) 批量转换成员

参数类型为ClusterNode的com.fr.cluster.engine.base中的方法

限定符和类型	方法和说明
static Address	ClusterEngineUtils.transformAddress(ClusterNode node, java.util.List<Address> members) 将上层地址转化为JGroups地址

com.fr.cluster.engine.core中ClusterNode的使用

类型变量类型为ClusterNode的com.fr.cluster.engine.core中的方法参数

限定符和类型	方法和说明
EventTrigger	ClusterCore.getClusterEventTrigger(Filter<ClusterNode> filter)

com.fr.cluster.engine.event中ClusterNode的使用

类型变量类型为ClusterNode的com.fr.cluster.engine.event中的构造器参数

构造器和说明
ClusterEventTrigger(Filter<ClusterNode> filter)

com.fr.cluster.engine.member.persistence中ClusterNode的使用

实现ClusterNode的com.fr.cluster.engine.member.persistence中的类

限定符和类型	类和说明
class	PersistenceClusterNode Created by juhaoyu on 2018/3/7.

返回ClusterNode的com.fr.cluster.engine.member.persistence中的方法

限定符和类型	方法和说明
ClusterNode	FineClusterPersistence.getCurrent()
ClusterNode	FineClusterPersistence.getNode(java.lang.String nodeID)
ClusterNode	ClusterPersistence.getNode(java.lang.String nodeID) 获取持久化的某节点

返回变量类型为ClusterNode的类型的com.fr.cluster.engine.member.persistence中的方法

限定符和类型	方法和说明
java.util.List<ClusterNode>	FineClusterPersistence.getAll()

com.fr.cluster.engine.member.view中ClusterNode的使用

返回ClusterNode的com.fr.cluster.engine.member.view中的方法

限定符和类型	方法和说明
ClusterNode	FineClusterMergeView.getCreator()
ClusterNode	FineClusterMergeSubView.getCreator()
ClusterNode	FineClusterView.getCurrent()
ClusterNode	FineClusterView.getNodeById(java.lang.String id)

返回变量类型为ClusterNode的类型的com.fr.cluster.engine.member.view中的方法

限定符和类型	方法和说明
java.util.List<ClusterNode>	FineClusterMergeView.getMembers()
java.util.List<ClusterNode>	FineClusterMergeSubView.getMembers()
java.util.List<ClusterNode>	FineClusterView.listNodes()
java.util.List<ClusterNode>	FineClusterView.listNodes(Filter<ClusterNode> filter)

参数类型为ClusterNode的com.fr.cluster.engine.member.view中的方法

限定符和类型	方法和说明
void	FineClusterMergeSubView.setCreator(ClusterNode creator)

类型变量类型为ClusterNode的com.fr.cluster.engine.member.view中的方法参数

限定符和类型	方法和说明
java.util.List<ClusterNode>	FineClusterView.listNodes(Filter<ClusterNode> filter)

参数类型为ClusterNode的com.fr.cluster.engine.member.view中的构造器

构造器和说明
FineClusterMergeSubView(ClusterNode creator, java.util.List<ClusterNode> members)
FineClusterMergeView(ClusterNode creator, java.util.List<ClusterNode> members, java.util.List<ClusterMergeSubView> subViews)

类型变量类型为ClusterNode的com.fr.cluster.engine.member.view中的构造器参数

构造器和说明
FineClusterMergeSubView(ClusterNode creator, java.util.List<ClusterNode> members)
FineClusterMergeView(ClusterNode creator, java.util.List<ClusterNode> members, java.util.List<ClusterMergeSubView> subViews)

com.fr.cluster.engine.rpc.proxy.components中ClusterNode的使用

参数类型为ClusterNode的com.fr.cluster.engine.rpc.proxy.components中的方法

限定符和类型	方法和说明
void	DefaultRemoteResultHandler.onError(ClusterNode marker, Invocation invocation, java.lang.Throwable error)
void	DefaultRemoteResultHandler.onSuccess(ClusterNode marker, Invocation invocation, java.lang.Object result)

com.fr.cluster.engine.transport.context中ClusterNode的使用

返回变量类型为ClusterNode的类型的com.fr.cluster.engine.transport.context中的方法

限定符和类型	方法和说明
java.util.Map<ClusterNode,ClusterMessage>	ClusterMessageSender.cast(ClusterMessageReceiver receiver, ClusterMessage message, RequestOptions options) 对特定接受者广播消息

参数类型为ClusterNode的com.fr.cluster.engine.transport.context中的方法

限定符和类型	方法和说明
ClusterMessage	ClusterMessageSender.send(ClusterNode node, ClusterMessageReceiver receiver, ClusterMessage message, RequestOptions options) 指定节点和接收者发送消息
void	ClusterMessageSender.send(ClusterNode address, ClusterMessageReceiver receiver, ClusterMessage message, RequestOptions options, ClusterMessageSender.Callback callback) 异步发送

类型变量类型为ClusterNode的com.fr.cluster.engine.transport.context中的方法参数

限定符和类型	方法和说明
void	ClusterMessageSender.CastCallback.done(java.util.Map<ClusterNode,ClusterMessage> messageMap)

com.fr.cluster.engine.transport.context.impl中ClusterNode的使用

返回变量类型为ClusterNode的类型的com.fr.cluster.engine.transport.context.impl中的方法

限定符和类型	方法和说明
java.util.Map<ClusterNode,ClusterMessage>	FineClusterMessageSender.cast(ClusterMessageReceiver receiver, ClusterMessage message, RequestOptions options)

参数类型为ClusterNode的com.fr.cluster.engine.transport.context.impl中的方法

限定符和类型	方法和说明
ClusterMessage	FineClusterMessageSender.send(ClusterNode node, ClusterMessageReceiver receiver, ClusterMessage message, RequestOptions options)
void	FineClusterMessageSender.send(ClusterNode address, ClusterMessageReceiver receiver, ClusterMessage message, RequestOptions options, ClusterMessageSender.Callback callback)

com.fr.cluster.entry中ClusterNode的使用

参数类型为ClusterNode的com.fr.cluster.entry中的方法

限定符和类型	方法和说明
void	ClusterTicket.catchUpWith(ClusterNode node) 进场成功，跟随某个节点的状态（通常使用进场时注册的通信组件） 如果是第一台机器，则不会调用这个方法

com.fr.cluster.extension中ClusterNode的使用

返回ClusterNode的com.fr.cluster.extension中的方法

限定符和类型	方法和说明
ClusterNode	MasterNodeExtension.getMasterNode() 得到主节点。

参数类型为ClusterNode的com.fr.cluster.extension中的方法

限定符和类型	方法和说明
boolean	MasterNodeExtension.isMaster(ClusterNode node) 判断 node 是否为主节点。

com.fr.cluster.extension.strategy中ClusterNode的使用

返回ClusterNode的com.fr.cluster.extension.strategy中的方法

限定符和类型	方法和说明
ClusterNode	MasterNodeChooseStrategy.getMasterNode() 得到主节点

com.fr.cluster.extension.strategy.impl中ClusterNode的使用

返回ClusterNode的com.fr.cluster.extension.strategy.impl中的方法

限定符和类型	方法和说明
ClusterNode	DefaultMasterChooseStrategy.changeMasterTo(ClusterNode node) 将 node 设置为当前节点。

参数类型为ClusterNode的com.fr.cluster.extension.strategy.impl中的方法

限定符和类型	方法和说明
ClusterNode	DefaultMasterChooseStrategy.changeMasterTo(ClusterNode node) 将 node 设置为当前节点。

com.fr.cluster.message中ClusterNode的使用

返回变量类型为ClusterNode的类型的com.fr.cluster.message中的方法

限定符和类型	方法和说明
java.util.Map<ClusterNode,Response>	ClusterClient.cast(Request request) 广播

参数类型为ClusterNode的com.fr.cluster.message中的方法

限定符和类型	方法和说明
Response	ClusterServer.handle(ClusterNode address, Request request) 处理请求并返回结果
Response	ClusterClient.send(ClusterNode address, Request request) 发送
void	ClusterClient.send(ClusterNode address, Request request, MessageResultHandler<Response> resultHandler) 异步发送

com.fr.cluster.message.components中ClusterNode的使用

类型变量类型为ClusterNode的com.fr.cluster.message.components中的方法参数

限定符和类型	方法和说明
void	MessageCastHandler.done(java.util.Map<ClusterNode,Response> resMap)

com.fr.cluster.rpc.base中ClusterNode的使用

返回变量类型为ClusterNode的类型的com.fr.cluster.rpc.base中的方法

限定符和类型	方法和说明
java.util.Map<ClusterNode,Result>	ClusterInvoker.invokeAll(Invocation invocation) 调用所有机器

参数类型为ClusterNode的com.fr.cluster.rpc.base中的方法

限定符和类型	方法和说明
void	ClusterInvokeHandler.done(ClusterNode marker, Invocation invocation, Result result) 结果处理器，用于异步rpc
static <T> T	ClusterInvokerHelper.invoke(ClusterInvoker invoker, ClusterNode node, Invocation invocation)
Result	ClusterInvoker.invoke(ClusterNode node, Invocation invocation) 调用指定机器
void	ClusterInvoker.invoke(ClusterNode node, Invocation invocation, ClusterInvokeHandler handler) 异步调用指定机器

com.fr.cluster.rpc.proxy中ClusterNode的使用

参数类型为ClusterNode的com.fr.cluster.rpc.proxy中的方法

限定符和类型	方法和说明
void	RemoteResultHandler.onError(ClusterNode marker, Invocation invocation, java.lang.Throwable error) RPC抛出异常时 包括网络异常、对端执行时异常等
void	RemoteResultHandler.onSuccess(ClusterNode marker, Invocation invocation, java.lang.Object result) 正常结束返回结果

类型变量类型为ClusterNode的com.fr.cluster.rpc.proxy中的方法参数

限定符和类型	方法和说明
static void	RemoteResultHandlerHelper.finish(RemoteResultHandler remoteHandler, Invocation invocation, java.util.Map<ClusterNode,Result> remoteResults)

com.fr.decision.webservice.v10.backup中ClusterNode的使用

参数类型为ClusterNode的com.fr.decision.webservice.v10.backup中的方法

限定符和类型	方法和说明
void	BackupModuleJob.run(com.fr.third.v2.org.quartz.JobExecutionContext context, ClusterNode node)

com.fr.decision.webservice.v10.backup.module中ClusterNode的使用

参数类型为ClusterNode的com.fr.decision.webservice.v10.backup.module中的方法

限定符和类型	方法和说明
void	BackupFactory.JarBackupClusterTicket.catchUpWith(ClusterNode node)

com.fr.decision.webservice.v10.log中ClusterNode的使用

参数类型为ClusterNode的com.fr.decision.webservice.v10.log中的方法

限定符和类型	方法和说明
void	LogCleanJob.run(com.fr.third.v2.org.quartz.JobExecutionContext jobExecutionContext, ClusterNode clusterNode)

com.fr.decision.webservice.v10.user.sync中ClusterNode的使用

参数类型为ClusterNode的com.fr.decision.webservice.v10.user.sync中的方法

限定符和类型	方法和说明
void	SyncUserJob.run(com.fr.third.v2.org.quartz.JobExecutionContext context, ClusterNode node)

com.fr.io.context.manager中ClusterNode的使用

参数类型为ClusterNode的com.fr.io.context.manager中的方法

限定符和类型	方法和说明
void	ResourceModuleManagerTicket.catchUpWith(ClusterNode node)

com.fr.io.sync中ClusterNode的使用

参数类型为ClusterNode的com.fr.io.sync中的方法

限定符和类型	方法和说明
void	CacheSyncExecutorTicket.catchUpWith(ClusterNode node)

com.fr.schedule.feature.job中ClusterNode的使用

参数类型为ClusterNode的com.fr.schedule.feature.job中的方法

限定符和类型	方法和说明
void	AbstractScheduleJob.run(com.fr.third.v2.org.quartz.JobExecutionContext context, ClusterNode node)

com.fr.scheduler.job中ClusterNode的使用

参数类型为ClusterNode的com.fr.scheduler.job中的方法

限定符和类型	方法和说明
abstract void	FineScheduleJob.run(com.fr.third.v2.org.quartz.JobExecutionContext context, ClusterNode node)

com.fr.transaction中ClusterNode的使用

参数类型为ClusterNode的com.fr.transaction中的方法

限定符和类型	方法和说明
void	ValidateProxy.catchUpWith(ClusterNode node)