Làm thế nào để cấu hình xuống trong cụm akka khi một singleton là hiện tại

Question

Tôi đọc trong Akka của documentation rằng khi sử dụng cụm singleton nên tránh sử dụng tự động downing. Tôi không hiểu làm thế nào nên downing được cấu hình trong trường hợp đó. Tôi hiểu rằng tôi có thể đăng ký các sự kiện thành viên nhóm và lập kế hoạch chiến lược của mình theo những thông điệp đó. Tuy nhiên, tôi không hiểu làm thế nào thực tế nó sẽ khác với downing tự động. Khi một nút bằng cách nào đó được phân đoạn từ cụm, nếu tự động downing được sử dụng, nút phân vùng sẽ "nghĩ" rằng toàn bộ cụm bị mất và bắt đầu một cụm của riêng nó (với singleton riêng của nó). Nhưng, mặt khác, tôi không thể giữ các nút không thể truy cập ở trạng thái không thể truy cập được vì cụm sẽ không đạt được hội tụ (các nút mới sẽ không thể tham gia) và nếu nút được phân đoạn là bản thân singleton mới nút sẽ không được chỉ định và theo đó, theo sự hiểu biết của tôi, điều duy nhất còn lại để làm là loại bỏ các nút không thể truy cập sau một số thời gian gia hạn mà chính xác là những gì tự động downing nào.

Tôi bỏ lỡ điều gì ở đây?

Answer 1

kiểm tra mã bên dưới. Tôi đã tắt tính năng auto-down-unreachable-after như tài liệu đã nói. Thay vào đó, tôi thực hiện một logic tùy chỉnh khác một chút so với bình thường. Chìa khóa của mã bên dưới là nếu phân vùng mạng xảy ra, chỉ các nút cụm có phần lớn sẽ giảm xuống UnreachableMember sau một số 5s có ​​thể định cấu hình. Mặt khác, thiểu số các nút cụm sẽ đi theo số UnreachableMember (là nhóm đa số là unreachable và không đưa chúng xuống để tạo thành một hòn đảo. Ý tưởng về số lượng đa số là vay từ MongoDB mà tôi nghĩ là không phải là mới trong lĩnh vực khoa học máy tính.

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

}