【发布时间】:2017-12-26 02:43:31
【问题描述】:
如果节点崩溃并且在那个时间点消息在邮箱中排队,那么这些消息将如何被重新处理? 如果它们不能被重新处理,那么我们怎么能说 akka 编程模型是容错的。这是我们现在必须使用持久队列的最基本用例。
【问题讨论】:
标签: akka akka-stream akka-persistence
如果节点崩溃并且在那个时间点消息在邮箱中排队,那么这些消息将如何被重新处理? 如果它们不能被重新处理,那么我们怎么能说 akka 编程模型是容错的。这是我们现在必须使用持久队列的最基本用例。
【问题讨论】:
标签: akka akka-stream akka-persistence
消息不会被处理,会丢失; Akka 不保证消息传递 - 这在其文档的开头明确说明。然而,这并不妨碍使程序具有容错性。最简单的方法之一是实现带有确认的消息,并使参与者重新发送未确认的消息。
【讨论】:
整个类型安全堆栈都是围绕微服务构建的。如果您有疑问,请阅读他们的演示文稿。Akka 流 Alla HTTP 他们都在这个方向上...似乎您对微服务的看法与我的不同...尽管您错过了要点..分布式容错架构问题应该由 Akka 解决..如果您使用的是 rabbitmq,那么您将无法获得 akka 的所有好处..就像位置透明.. Actor heiraarchy..发布您的架构图到 Akka 论坛,看看你得到什么回应
【讨论】: