您实际上不需要订阅
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)
上一篇 如何在Java中将FileInputStream转换为字符串?
下一篇 Class.forName(“ com.mysql.jdbc.Driver”)。newInstance();到底做了什么?