Come configurare downing nel cluster akka quando è presente un singleton

Question

Ho letto in Akka documentation che quando si utilizza il singleton cluster si dovrebbe evitare l'utilizzo del downing automatico. Non capisco come debba essere configurato downing in quel caso. Capisco che potrei iscrivermi agli eventi di appartenenza al cluster e pianificare la mia strategia in base a quei messaggi. Tuttavia, non capisco quanto sarà praticamente diverso dal downing automatico.

Quando un nodo è partizionato in qualche modo dal cluster, se viene utilizzato il downing automatico, il nodo partizionato "penserà" che l'intero cluster è scomparso e avvierà un cluster proprio (con il proprio singleton). Ma, d'altro canto, non posso mantenere i nodi irraggiungibili in uno stato non raggiungibile per sempre perché il cluster non raggiungerà la convergenza (i nuovi nodi non saranno in grado di unirsi) e se il nodo partizionato è il singleton stesso un nuovo singleton il nodo non sarà assegnato e quindi, secondo la mia comprensione, l'unica cosa che rimane da fare è rimuovere nodi irraggiungibili dopo un certo periodo di grazia che è esattamente ciò che fa il downing automatico.

Cosa mi manca qui?

Answer 1

controlla il codice seguente. Ho disattivato la funzione auto-down-unreachable-after come indicato dal documento. Invece, implemento una logica personalizzata che è leggermente diversa dalla norma. La chiave del codice qui sotto è se la partizione di rete si verifica, solo i nodi cluster che hanno la maggioranza proveranno UnreachableMember dopo alcuni 5 configabili. D'altro canto, la minoranza dei nodi del cluster calpesterà il proprio UnreachableMember (che è il gruppo maggioritario come unreachable e non li porterà giù per formare un'isola. L'idea del numero di maggioranza è presa in prestito da MongoDB che penso sia non è nuovo nella zona di informatica.

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") 
    } 

}