领导层活动处理

终端节点组可以根据授予或撤销的领导权分别启动和停止。 这在共享资源必须仅由单个实例使用的集群场景中非常有用。 这方面的一个例子是轮询共享目录的文件入站通道适配器。 (请参阅读取文件)。spring-doc.cadn.net.cn

为了参与领导者选举并在当选领导者、撤销领导者或未能获得成为领导者的资源时收到通知,应用程序会在应用程序上下文中创建一个称为“领导者发起方”的组件。 通常,leader 发起方是SmartLifecycle,因此它会在上下文启动时启动(可选),然后在领导层发生变化时发布通知。 您还可以通过设置publishFailedEventstrue(从版本 5.0 开始),用于您希望在发生故障时采取特定作的情况。 按照惯例,您应该提供Candidate接收回调。 您还可以通过Context对象。 您的代码还可以监听o.s.i.leader.event.AbstractLeaderEvent实例(OnGrantedEventOnRevokedEvent) 并相应地响应(例如,通过使用SmartLifecycleRoleController). 这些事件包含对Context对象。 下面的清单显示了Context接口:spring-doc.cadn.net.cn

public interface Context {

	boolean isLeader();

	void yield();

	String getRole();

}

从版本 5.0.6 开始,上下文提供对应聘者角色的引用。spring-doc.cadn.net.cn

Spring 集成提供了 leader 发起方的基本实现,该实现基于LockRegistry抽象化。 要使用它,你需要创建一个实例作为 Bean,如下例所示:spring-doc.cadn.net.cn

@Bean
public LockRegistryLeaderInitiator leaderInitiator(LockRegistry locks) {
    return new LockRegistryLeaderInitiator(locks);
}

如果 lock registry 正确实现,则最多只有一个 leader。 如果 lock registry 还提供引发异常的锁(理想情况下,InterruptedException),则无领导时段的持续时间可以尽可能短,具体取决于锁定实施中的固有延迟所允许的最短。 默认情况下,busyWaitMillis属性添加了一些额外的延迟,以防止在锁不完美(更常见)的情况下出现 CPU 匮乏,并且只有在您尝试再次获取锁时才知道它们已过期。spring-doc.cadn.net.cn

有关领导层选举和使用 Zookeeper 的事件的更多信息,请参阅 Zookeeper 领导层事件处理。 有关领导层选举和使用 Hazelcast 的事件的更多信息,请参阅 Hazelcast 领导层事件处理spring-doc.cadn.net.cn