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



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

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

整个类型安全堆栈都是围绕微服务构建的。如果你有疑问,那就去读他们的演讲。Akka流Alla HTTP它们都在这个方向…看来你对微服务的看法和我不一样…尽管你没有抓住要点。分布式容错架构问题应该由Akka来解决。如果你正在使用rabbitmq,那么你将无法获得akka的所有好处。比如位置透明度…Actor层次结构,请将您的架构图发布到Akka论坛,看看您会得到什么响应

最新更新