了解 Akka 容错

Question

我正在研究Akka，只是查看他们的fault tolerance example，并试图理解它。

1. 为什么我不能在“纯 Java”（没有 Akka）中实现所有这些相同的类型（Worker、Listener、CounterService 等）。 Akka 开箱即用地添加了哪些基础设施？
2. 在该图中，Storage 代表什么？关系数据库管理系统？监控 RDBMS 的 Java 应用程序？ JDBC 驱动程序？
3. 如果Storage 是一个Java 应用程序并且可以将StorageException 返回给请求者，那就太好了，但是如果Storage 和CounterService 之间的网络被切断或存在传输级问题怎么办？整个图表是否仍然有效（如果是，如何？！？）还是 Akka 仅提供“应用层”容错？在后一种情况下，Java/Akka 如何处理硬件或网络级别的故障？

Answer 1

1. Akka 基于 Actor 的设计模式，您可以自己实现该模式，就像使用 MVC 一样。我想说的是，akka 为您做的最好的事情就是所有能够最小化参与者所需资源数量的反应性东西。

2. 您可以将存储视为只是一种状态或保持应用程序的某些状态。

3. 我认为人们在谈论容错时主要指的是因为您可以轻松地拥有分布式参与者，并使用诸如可靠代理模式http://doc.akka.io/docs/akka/snapshot/contrib/reliable-proxy.html 之类的东西，您可以让您的应用程序以它的方式将继续运行，直到最后一个节点死亡，如果您始终实施该模式，您将不会丢失任何消息。所以它指的是消息丢失。一切都是在akka中的消息方面，你通常不会有不是一个好主意的请求，因为它是阻塞的，如果需要的话你可以使用Futures。如果您的硬件停止运行，您将无法在您指定的时间内检索到未来的值，您可以自己处理故障。