问题描述
我在将我的应用程序重写为 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
,则无论您在集群中的哪个位置,都可以向其发送消息。
既然您始终可以跨集群发送消息,那么为什么要使用集群分片?
集群分片允许实体独立于任何参与者的生命周期进行寻址:实体的化身作为参与者运行,分片管理产生参与者以按需充当化身,将实体限制为在给定的一个化身时间,并保留将实体移动到不同节点上的化身的权利(通常是为了响应集群成员资格的变化)。如果您不需要特定类型演员的这些方面,则无需将其设为分片实体。