在 Akka 中,当一个 actor 在处理消息时死亡(内部onReceive(...) { ... }
,该消息丢失。有没有办法保证无损?有没有办法配置 Akka 始终保留消息before将他们发送到onReceive
,以便在演员死亡时可以恢复并重播?
也许像持久邮箱之类的东西?
是的,看看阿卡持久化 http://doc.akka.io/docs/akka/2.3.11/scala/persistence.html,特别是 AtLeastOnceDelivery。这会将邮件存储在发送方,以便弥补传递过程中的损失,否则邮件可能永远不会到达目标邮箱。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)