Akka Cluster Sharding - 实体到 Actor 的通信

Akka Cluster Sharding - Entity to Actor communication

我在将我的应用重写为 Akka Cluster Sharding 时遇到问题。我有一个分片实体,我们称它为 A,每个节点上有一堆本地参与者,我们称其中一个为 B。现在我发送一条包含 (String, ActorRef[B]) 的消息 B -> A,我想使用上一条消息中提供的 ref 来响应 A -> B

一方面,文档表明它应该可以工作 https://doc.akka.io/docs/akka/current/typed/cluster-sharding.html#basic-example

但据我了解,A 应该不可能在集群中找到参与者 B,因为它不是 entityID。

它是如何工作的?我是否也必须使 B 成为一个实体?

ActorRef 是位置透明的:它包含将消息路由到不同 ActorSystem 中的参与者所需的信息(通常将 1:1 映射到集群节点)。如果你有 actor B 的 ActorRef,那么无论你在集群中的哪个位置,你都可以向它发送消息。

那么,当您始终可以跨集群发送消息时,为什么还要集群分片?

集群分片允许实体独立于任何参与者的生命周期进行寻址:一个实体的化身作为一个参与者运行,分片管理产生一个参与者作为按需的化身,将实体限制为最多一个化身给定的时间,并保留将实体移动到不同节点上的化身的权利(通常是为了响应集群成员的变化)。如果您不需要特定类型的参与者的这些方面,则无需将其作为分片实体。