【发布时间】:2021-01-30 13:47:27
【问题描述】:
假设我们有两个节点。节点 1 包含演员 A,节点 2 包含演员 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 的“Future”会发生什么?我假设由于节点死亡,未来不再存在。实际上,B 的回复将落空。
我的理论正确吗?
【问题讨论】:
标签: akka akka-cluster akka-persistence