在 Akka 中使用重新启动的 Actor 进行消息持久性和回放

Question

Akka Java 在这里。我有两个演员，Parent 和 Child，前者是后者的父级。如果Child 抛出一个特定的异常（比如UnrulyTeenagerExcepton），那么我正在寻找的行为如下：

• Parent 保存了对抛出异常时Child 正在处理的消息的引用；那么
• Child重启，持久化消息“回放”到Child；但是
• 如果此保存 -> 重新启动 -> 重播循环发生 3 次，Child 抛出 UnrulyTeenagerException 3 次，那么我们 SupervisorStrategy.escalate()

迄今为止我最好的尝试：

// Groovy pseudo-code
class ChildFailureDecider extends Function<Throwable,Directive> {
    int maxRetries = 3
    int numRetries = 0

    @Override
    Directive apply(Throwable childFailure) {
        if(childFailure instanceof UnrulyTeenagerException) {
            numRetries++

            if(numRetries <= maxRetries) {
                // TODO: #1 How to persist the message that caused the ‘childFailure’?

                return SupervisorStrategy.restart()

                // TODO: #2 How to ‘play back’ the persisted message to Child?
            }
        }

        SupervisorStrategy.escalate()
    }
}

但正如您所见，我正在为消息持久性和回放而苦苦挣扎。有任何想法吗？ 非常感谢 Java 代码示例，Akka 足够强悍，无需学习 Scala 象形文字！

Answer 1

Akka 持久性是关于以持久的方式（例如记录到磁盘或数据库）以持久的方式记录事件（与消息不同），以便在整个应用程序终止时（例如 JVM 崩溃或硬件失败），可以在重新启动时重建该参与者的状态。在您的情况下，您希望记住发送给单个演员的消息并在该演员因故障重新启动时重新发送，所以我认为在这种情况下您不需要持久性 API。

当参与者抛出异常时，该异常会呈现给主管，但导致异常的消息不会。我认为没有一种内置的方法可以实现这一目标。监督者可以通过设置适当参数的监督策略来管理只重启3次的规则：http://doc.akka.io/japi/akka/2.4-M3/akka/actor/OneForOneStrategy.html#OneForOneStrategy-int-scala.concurrent.duration.Duration-akka.japi.Function-

消息的重放需要由发送者处理。您可以通过让接收方在处理完消息后向发送方发送确认来实现至少一次语义，如果没有收到确认，则让发送方定期重试。有关更多信息，请参阅此问题：Akka Message Delivery Guarantees

很抱歉缺少代码，但我使用的是 Scala API 而不是 Java。