Akka集群调度器-当节点关闭时会发生什么

Question

我想在我的集群中有一个调度器，它会在一段时间后发送一些消息。从我看到的调度器是每个actorsystem，从我的测试只针对本地actor系统。不是集群那一个。因此，如果在一个节点上调度某个任务，如果它被关闭，那么所有调度的任务都将被丢弃。

如果我创建一个集群单例来负责调度，那么已经制定的调度是否可以在其他节点上重新创建？还是我应该将它作为一个具有已经创建的调度元数据结构的持久执行元，并在预启动阶段重新调度所有被持久化的内容？

Answer 1

如果先前所在的节点被关闭或离开集群，则集群单例将在另一个节点上重生。

那个轮回将从一个干净的石板开始：它不会记得它的“前世今生”。

但是，如果它是一个持久执行元（或者，等价地，它的行为是Akka类型的EventSourceBehavior)，它将在启动时从事件流（和/或快照）恢复其状态。对于持久性执行元，这通常不需要做任何事情prestart:持久性实现将负责重放事件。

根据调度的任务数量以及如果希望在集群完全重新启动时丢弃调度，可以使用Akka分布式数据将调度元数据分布在集群周围（具有可调的一致性），然后让集群单例调度执行元读取该元数据。