Akka集群Leader地址

Question

如何在 Akka 集群中获得对领导者的引用，以便我可以向领导者节点发送消息？

在代码中：

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

Answer 1

您可以从集群域事件中获取其地址Cluster(system).state.leader或侦听LeaderChanged集群域事件，以便在其更改时获得通知。