如何在Akka集群中获得对领导人的引用,以便我可以向领导者节点发送消息?
代码:
// assume there exists /user/Supervisor actor at the leader node
val leader = { code to get the leader ref }
leader ! SomeMessage发布于 2015-12-14 15:46:11
您可以从Cluster(system).state.leader获取其地址,也可以侦听LeaderChanged集群域事件,以便在其更改时得到通知。
https://stackoverflow.com/questions/33915270
复制相似问题