如何在存在单例时配置akka集群中的downing

Question

我在Akka的documentation中读到了使用集群单例时应该避免使用自动downing。 我不明白在这种情况下如何配置downing。 我知道我可以订阅集群成员事件并根据这些消息计划我的策略。但是，我不明白它与自动降档的区别。

当某个节点以某种方式与集群分区时，如果使用自动切换，分区节点将“认为”整个集群失踪并启动自己的集群（使用自己的单例）。但是，另一方面，我无法永远将无法访问的节点保持在不可达状态，因为集群不会达到收敛（新节点将无法加入），并且如果分区节点是单例本身，则会生成一个新的单例根据我的理解，节点将不会被分配，因此根据我的理解，唯一需要做的就是在一段宽限期后删除无法访问的节点，这正是自动降级所要做的。

我在这里错过了什么？

Answer 1

请看下面的代码。正如文档所述，我已关闭auto-down-unreachable-after功能。相反，我实现了一种与正常情况有点不同的自定义逻辑。下面的代码的关键是如果网络分区发生，只有拥有多数的集群节点将在一些可配置的5之后取下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") 
    } 

}