当在akka集群中变得无法访问时,是否有任何适当的方法来关闭节点。我想在节点无法访问时将 api 暴露给它,但我更喜欢以编程方式找到另一种方式或某些东西。自动关机不再是一种选择,因为我一直有脑裂问题。
我可以在接收 方法中关闭节点吗:
def 接收:接收 = { case MemberUp(member) =>
case UnreachableMember(member) => {
Cluster(context.system).down(member.address)
}