Akka集群分片到分片

Question

我有一个使用案例，集群中的一个分片需要向同一集群中的另一个分片询问一些信息。

我知道我可以通过这样做来获得ShardRegion：

val counterRegion: ActorRef = ClusterSharding(system).shardRegion("Counter")

然后像这样提出我的请求：

counterRegion ? InfoRequest(entityIdShardId)

但是，有没有办法从分片本身获取分片区域参与者ref呢？这似乎是一种更干净、更有效的获取ActorRef的方式。

Answer 1

您指定的方式是正确的。

可以在分片实体中调用context.parent，返回分片地域的ActorRef。但这是一个不太明确的选项，因为它依赖于shard region是shard实体的父实体这一事实。

我认为你应该继续使用你的选择。

此外，与你的问题无关的是，你不应该在参与者中使用ask模式。它增加了处理Future的复杂性，并且需要指定超时。只需使用send/tell或!。您可以在receive分部函数中处理发回给参与者的响应。