领导层活动处理
终端节点组可以根据授予或撤销的领导权分别启动和停止。 这在共享资源必须仅由单个实例使用的集群场景中非常有用。 这方面的一个例子是轮询共享目录的文件入站通道适配器。 (请参阅读取文件)。
为了参与领导者选举并在当选领导者、撤销领导者或未能获得成为领导者的资源时收到通知,应用程序会在应用程序上下文中创建一个称为“领导者发起方”的组件。
通常,leader 发起方是SmartLifecycle
,因此它会在上下文启动时启动(可选),然后在领导层发生变化时发布通知。
您还可以通过设置publishFailedEvents
自true
(从版本 5.0 开始),用于您希望在发生故障时采取特定作的情况。
按照惯例,您应该提供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 发起方的基本实现,该实现基于LockRegistry
抽象化。
要使用它,你需要创建一个实例作为 Bean,如下例所示:
@Bean
public LockRegistryLeaderInitiator leaderInitiator(LockRegistry locks) {
return new LockRegistryLeaderInitiator(locks);
}
如果 lock registry 正确实现,则最多只有一个 leader。
如果 lock registry 还提供引发异常的锁(理想情况下,InterruptedException
),则无领导时段的持续时间可以尽可能短,具体取决于锁定实施中的固有延迟所允许的最短。
默认情况下,busyWaitMillis
属性添加了一些额外的延迟,以防止在锁不完美(更常见)的情况下出现 CPU 匮乏,并且只有在您尝试再次获取锁时才知道它们已过期。
有关领导层选举和使用 Zookeeper 的事件的更多信息,请参阅 Zookeeper 领导层事件处理。 有关领导层选举和使用 Hazelcast 的事件的更多信息,请参阅 Hazelcast 领导层事件处理。