如何在节点崩溃的情况下恢复 akka actor 中排队的消息?

How to recover queued messages in akka actor in case of node crash?

如果节点崩溃并且此时消息在邮箱中排队,那么将如何重新处理这些消息? 如果它们不能被重新处理那么我们怎么能说 akka 编程模型是容错的。这是我们现在必须使用持久队列的最基本的用例。

消息不会被处理,会丢失; Akka 不保证消息传递 - 这在其文档的开头明确说明。但是,这并不排除使程序具有容错性。最简单的方法之一是实现带有确认的消息,并让参与者重新发送未确认的消息。

整个类型安全堆栈都是围绕微服务构建的。如果您有疑问,请阅读他们的介绍。Akka streams Alla HTTP 他们都在这个方向上......看来你对微服务的看法与我的不同......尽管你错过了要点..分布式容错架构问题应该由 Akka 解决..如果你使用的是 rabbitmq 那么你将不会获得 akka 的所有好处..比如位置透明..Actor heiraarchy..do post 把你的架构图发到 Akka 论坛看看你得到什么回应