您实际上不需要订阅
ClusterDomainEvent或
MemberEvent。您可以只访问
state集群扩展的成员,例如,
val cluster = akka.cluster.Cluster(context.system)val members = cluster.state.members.filter(_.status == MemberStatus.Up)
欢迎分享,转载请注明来源:内存溢出
您实际上不需要订阅
ClusterDomainEvent或
MemberEvent。您可以只访问
state集群扩展的成员,例如,
val cluster = akka.cluster.Cluster(context.system)val members = cluster.state.members.filter(_.status == MemberStatus.Up)
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)