【问题标题】:Akka Cluster Leader AddressAkka 集群领导地址
【发布时间】:2015-11-25 11:24:49
【问题描述】:

如何在 Akka 集群中获取对领导者的引用,以便向领导者节点发送消息?

在代码中:

// assume there exists /user/Supervisor actor at the leader node
val leader = { code to get the leader ref }
leader ! SomeMessage

【问题讨论】:

  • context.actorSelection("akka.tcp://SysName@localhost:port/user/Supervisor").resolveOne??
  • @johny 那行不通。因为领导节点的地址(SysName@localhost:port)未知。

标签: scala akka akka-cluster


【解决方案1】:

您可以从Cluster(system).state.leader 获取它的地址或监听LeaderChanged 集群域事件,以便在它发生变化时得到通知。

【讨论】:

    猜你喜欢
    • 2019-04-13
    • 1970-01-01
    • 2017-06-07
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多