Akka集群单例创业的正确道路是什么

Question

null

10:52:41.691UTC INFO  akka.tcp://system@127.0.0.1:9401/user/singletonOfEvents - ClusterSingletonManager state change [Start -> Younger]

我看到“singleton actor总是在具有指定角色的最老成员上运行。”在Akka集群中，单例Doc。但我不明白singleton是怎么开始的。也许所有的单例都必须在第一个种子节点中实现和启动？

Answer 1

如Akka文档中所述，集群单例参与者实例由每个集群节点上的ClusterSingletonManager参与者启动和维护，该参与者具有为单例指定的角色。ClusterSingletonManager在任何时间点以指定的角色在集群的最早节点上最多维护一个单例实例。如果最老的节点（可能是第一个种子节点）失败，将选择下一个最老的节点。若要访问集群单例参与者，请使用ClusterSingletonProxy，它存在于具有指定角色的所有节点上。

下面是启动集群单例的示例应用程序的样子：

object Main {

  def workTimeout = 10.seconds

  def main(args: Array[String]): Unit = {
    // Validate arguments host and port from args(0) and args(1)
    // ...

    val role = "worker"

    val conf = ConfigFactory.parseString(s"akka.cluster.roles=[$role]").
      withFallback(ConfigFactory.parseString("akka.remote.netty.tcp.hostname=" + host)).
      withFallback(ConfigFactory.parseString("akka.remote.netty.tcp.port=" + port)).
      withFallback(ConfigFactory.load())

    val system = ActorSystem("ClusterSystem", conf)

    system.actorOf(
      ClusterSingletonManager.props(
        Master.props(workTimeout),
        PoisonPill,
        ClusterSingletonManagerSettings(system).withRole(role)
      ),
      name = "master"
    )

    val singletonAgent = system.actorOf(
      ClusterSingletonProxy.props(
        singletonManagerPath = "/user/master",
        settings = ClusterSingletonProxySettings(system).withRole(role)
      ),
      name = "proxy"
    )

    // ...
  }

  // ...
}

object Master {
  def props(workTimeout: FiniteDuration): Props =
    Props(classOf[Master], workTimeout)

  // ...
}

class Master(workTimeout: FiniteDuration) extends Actor  {
  import Master._

  // ...
}

群集配置可能如下所示：

akka {

  actor.provider = "akka.cluster.ClusterActorRefProvider"

  remote.netty.tcp.port = 0
  remote.netty.tcp.hostname = 127.0.0.1

  cluster {
    seed-nodes = [
      "akka.tcp://ClusterSystem@10.1.1.1:2552",
      "akka.tcp://ClusterSystem@10.1.1.2:2552"
    ]

    auto-down-unreachable-after = 10s
  }

  // ...
}