如何确保在actors进程重新启动时邮箱消息不会丢失- Akka.NET？

Question

我已经阅读了Akka.NET的在线文档。

我看到持久性插件可以使用事件源模式来存储参与者的状态。

但是我没有在邮箱中找到任何关于邮件的具体信息。

当一个进程死亡或重新启动时，参与者的邮箱会恢复消息吗？

Answer 1

根据文档和经验，持久化的不是参与者状态，而是更改状态的事件，这些事件随后在参与者重新启动后应用。

Persist()或Recover()期间的消息将被存储，并且在执行元重新启动时邮箱和存储都将被保存

(“执行元重新启动仅替换实际的执行元对象；邮箱的内容不受重新启动的影响，因此消息处理将在PostRestart挂钩返回后恢复。不会再次接收触发异常的消息。在执行元重新启动时发送给执行元的任何消息都将照常排队到其邮箱中。”和“存储由Akka.NET在actor实例之外处理，就像邮箱一样，因此如果actor在处理消息时死亡，则存储将被保留。”)

但这是为了正常重启，看看AtLeastOnceDeliveryActor，也许这就是你想要的保证交付。并注意preRestart()方法在重启时保存当前正在处理的消息。

Answer 2

Actor的邮箱始终只在内存中。在actor系统中，消息不仅是与用户域相关的命令，而且是用于控制actor生命周期、实现协议通信等的各种信号。因此，传输中的消息量比使用消息代理时高得多。它们必须以更高的速度传递和处理，而邮箱持久性将大大减慢这一过程。

如果你需要持久化你的域中的命令，最简单的方法就是使用某种类型的持久化消息队列--比如RabbitMQ、Azure Service Bus甚至Kafka --作为actor系统前面的一个门面来处理传入的用户请求。