如果分片的 Actor A 询问另一个 Actor B，但 A 在 B 响应之前被重新定位，会发生什么？

问题描述

假设我们有两个节点。节点 1 包含 Actor A，节点 2 包含 Actor B。

假设两个actor之间的通信是这样实现的：

val B_ref = sharding.entityRefFor(BTypeKey,B_ID)

//inside A

context.ask(B_ref,message(replyTo =_) {
   //... Translate B reply to A command
}

消息发送后，节点 1 死亡，角色 A 被重新定位。等待 B 回复的 Ask 的“未来”会怎样？我假设自从节点死了，未来不再存在。实际上，B 的回复将陷入僵局。

我的理论正确吗？

解决方法

1.5 不会导致未来，而是一个改编的消息。由于 context.ask 不知道此参与者只是集群分片实体的化身，因此您的基本直觉是有效的：来自 B 的回复将不会被传递。