如何解决如果分片的 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 的回复将不会被传递。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。