Akka 集群分片 - 实体到 Actor 的通信

如何解决Akka 集群分片 - 实体到 Actor 的通信

我在将我的应用程序重写为 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，因为它不是实体 ID。

它是如何工作的？我是否也必须将 B 设为实体？

解决方法

console.log(doc.data()['name']) 是位置透明的：它包括将消息路由到不同 ActorRef 中的参与者所需的信息（通常以 1:1 映射到集群节点）。如果您有参与者 B 的 ActorSystem，则无论您在集群中的哪个位置，都可以向其发送消息。

既然您始终可以跨集群发送消息，那么为什么要使用集群分片？

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