此版本仍在开发中,尚未被视为稳定版本。对于最新的稳定版本,请使用 Spring Integration 6.4.0! |
领导层活动处理
终端节点组可以根据授予或撤销的领导权分别启动和停止。 这在共享资源必须仅由单个实例使用的集群场景中非常有用。 这方面的一个例子是轮询共享目录的文件入站通道适配器。 (请参阅读取文件)。
为了参与领导者选举并在当选领导者、撤销领导者或未能获得成为领导者的资源时收到通知,应用程序会在应用程序上下文中创建一个称为“领导者发起方”的组件。
通常,领导发起方是 ,因此它在上下文启动时启动(可选),然后在领导层发生变化时发布通知。
您还可以通过将 设置为 (从版本 5.0 开始) 来接收失败通知,以便在发生故障时希望采取特定操作。
按照惯例,您应该提供接收回调的 a。
您还可以通过框架提供的对象撤销领导权。
您的代码还可以侦听实例(和 的超类)并相应地响应(例如,通过使用 a )。
事件包含对对象的引用。
下面的清单显示了接口的定义:SmartLifecycle
publishFailedEvents
true
Candidate
Context
o.s.i.leader.event.AbstractLeaderEvent
OnGrantedEvent
OnRevokedEvent
SmartLifecycleRoleController
Context
Context
public interface Context {
boolean isLeader();
void yield();
String getRole();
}
从版本 5.0.6 开始,上下文提供对应聘者角色的引用。
Spring 集成提供了基于抽象的 leader initiator 的基本实现。
要使用它,你需要创建一个实例作为 Bean,如下例所示:LockRegistry
@Bean
public LockRegistryLeaderInitiator leaderInitiator(LockRegistry locks) {
return new LockRegistryLeaderInitiator(locks);
}
如果 lock registry 正确实现,则最多只有一个 leader。
如果 lock registry 还提供在过期或损坏时引发异常(理想情况下)的锁,则无领导期的持续时间可以尽可能短,以锁定实现中的固有延迟所允许的最短。
默认情况下,该属性会添加一些额外的延迟,以防止在锁不完美(更常见)的情况下出现 CPU 匮乏,并且只有在尝试再次获取锁时才知道它们已过期。InterruptedException
busyWaitMillis
有关领导层选举和使用 Zookeeper 的事件的更多信息,请参阅 Zookeeper 领导层事件处理。 有关领导层选举和使用 Hazelcast 的事件的更多信息,请参阅 Hazelcast 领导层事件处理。