1

作为 Akka Singleton 集群的实例成员，如何在 Akka Cluster Singleton Pattern 中订阅成为 LEADER 的事件。

application.conf 如下：

akka {
actor {
  provider = "akka.cluster.ClusterActorRefProvider"
  deployment {
    /singleton/registerService/workerRouter {
      router = consistent-hashing-pool
      nr-of-instances = 100
      cluster {
        enabled = on
        max-nr-of-instances-per-node = 3
        allow-local-routees = on
        use-role = registers
      }
    }
  }
}
remote {
  log-remote-lifecycle-events = off
  netty.tcp {
    hostname = "127.0.0.1"
    port = 0
  }
}

cluster {
  seed-nodes = [
    "akka.tcp://PashRegister@127.0.0.1:2051",
    "akka.tcp://PashRegister@127.0.0.1:2052"]

  auto-down-unreachable-after = 5s

  roles = ["registers"]
}
}
4

2 回答 2

4

集群单例的想法是它将代表您启动 - 所以当这样的参与者启动时，它是“领导者”（如“运行单例”）。

于 2014-07-29T08:24:26.863 回答
0

如果要在领导者更改时通知问题（例如，当第一个启动的单例被关闭时），那么我发现知道谁是领导者的唯一方法是执行以下操作：

  • 让演员订阅所有 MemberEvents
  • 每当发生 MemberUp 或 MemberRemoved 事件时：
    • 更新单例角色的成员的排序列表（按 Member.ageOrdering 排序）
    • 此列表的第一个元素是当前领导者

基本上，我正在重新实现选择新领导者背后的逻辑。希望有帮助。

于 2016-11-24T15:31:49.833 回答