我在 Akka 的 documentation 中读到，在使用集群单例时，应避免使用自动停机。 我不明白在这种情况下应该如何配置downing。 我了解我可以订阅集群成员活动并根据这些消息计划我的策略。但是，我不明白它与自动停机有何不同。
当一个节点以某种方式从集群中分区时，如果使用自动关闭，分区节点将“认为”整个集群丢失并启动自己的集群（具有自己的单例）。 但是，另一方面，我不能将无法访问的节点永远保持在无法访问的状态，因为集群不会达到收敛（新节点将无法加入），并且如果分区节点是单例本身，那么一个新的单例节点不会被分配，因此，根据我的理解，唯一要做的就是在一段时间后删除无法访问的节点，这正是自动关闭所做的。
我错过了什么？
【问题讨论】：
标签： singleton akka akka-cluster
查看以下代码。正如文档所说，我已经关闭了auto-down-unreachable-after 功能。相反，我实现了一个与正常情况有点不同的自定义逻辑。下面代码的关键是如果发生网络分区，只有拥有多数的集群节点会在经过一些可配置的 5s 后删除UnreachableMember。另一方面，集群中的少数节点会踩到它们的UnreachableMember（即unreachable的多数组，不会将它们取下来形成孤岛。多数数的想法是从MongoDB借来的我认为这在计算机科学领域并不新鲜。
class ClusterListener extends Actor with ActorLogging {
val cluster = Cluster(context.system)
var unreachableMember: Set[Member] = Set()
// subscribe to cluster changes, re-subscribe when restart
override def preStart(): Unit = {
//#subscribe
cluster.subscribe(self, initialStateMode = InitialStateAsEvents, classOf[UnreachableMember], classOf[ReachableMember])
//#subscribe
}
override def postStop(): Unit = cluster.unsubscribe(self)
def receive = {
case UnreachableMember(member) =>
log.info("Member detected as unreachable: {}", member)
val state = cluster.state
if (isMajority(state.members.size, state.unreachable.size)) {
scheduletakeDown(member)
}
case ReachableMember(member) =>
unreachableMember = unreachableMember - member
case _: MemberEvent => // ignore
case "die" =>
unreachableMember.foreach { member =>
cluster.down(member.address)
}
}
// find out majority number of the group
private def majority(n: Int): Int = (n+1)/2 + (n+1)%2
private def isMajority(total: Int, dead: Int): Boolean = {
require(total > 0)
require(dead >= 0)
(total - dead) >= majority(total)
}
private def scheduletakeDown(member: Member) = {
implicit val dispatcher = context.system.dispatcher
unreachableMember = unreachableMember + member
// make 5s config able!!!
context.system.scheduler.scheduleOnce(5 seconds, self, "die")
}
}
【讨论】：