Akka：如何結合OneForOneStrategy和AllForOneStrategy

Question

如果我在Scala中爲演員定義主管策略，如何使用OneForOneStrategy和AllForOneStrategy？有沒有簡單的方法來組合它們，或者我必須定義一個自定義SupervisorStrategy？ 下面是一個例子：

class MyActor extends Actor { 
    override val supervisorStrategy = OneForOneStrategy() { 
    case _: NullPointerException => Restart 
    case _: FileNotFoundException => Restart // here I want to restart all children 
    case _: Exception    => Escalate 
    } 
} 

如果我有寫我自己的上司的策略，我該怎麼辦呢？我沒有找到這方面的例子。

Answer 1

您將不得不定義自定義主管策略。爲了您的具體使用情況，下面的自定義策略，將工作：

package akka.actor 

import java.io.FileNotFoundException 
import scala.concurrent.duration._ 

case class CustomStrategy(
    maxNrOfRetries:    Int  = -1, 
    withinTimeRange:    Duration = Duration.Inf, 
    override val loggingEnabled: Boolean = true)(val decider: SupervisorStrategy.Decider) 
    extends SupervisorStrategy { 

    import SupervisorStrategy._ 

    private val retriesWindow = (maxNrOfRetriesOption(maxNrOfRetries), withinTimeRangeOption(withinTimeRange).map(_.toMillis.toInt)) 

    def handleChildTerminated(context: ActorContext, child: ActorRef, children: Iterable[ActorRef]): Unit =() 

    def processFailure(context: ActorContext, restart: Boolean, child: ActorRef, cause: Throwable, stats: ChildRestartStats, children: Iterable[ChildRestartStats]): Unit = { 
    if (cause.isInstanceOf[FileNotFoundException]) { 
     // behave like AllForOneStrategy 
     if (children.nonEmpty) { 
     if (restart && children.forall(_.requestRestartPermission(retriesWindow))) 
      children foreach (crs ⇒ restartChild(crs.child, cause, suspendFirst = (crs.child != child))) 
     else 
      for (c ← children) context.stop(c.child) 
     } 
    } else { 
     // behave like OneForOneStrategy 
     if (restart && stats.requestRestartPermission(retriesWindow)) 
     restartChild(child, cause, suspendFirst = false) 
     else 
     context.stop(child) 
    } 
    } 
} 

Here是測試上述戰略的一個要點。規範會創建一個使用CustomStrategy的主管，並創建兩個子項。當一個孩子拋出NullPointerException時，只有該孩子重新啓動;當孩子拋出FileNotFoundException時，兩個孩子都會重新啓動。

有關自定義策略的幾個注意事項：

• 它擴展SupervisorStrategy和定義here現有戰略後爲藍本。
• 它在akka.actor包內部定義爲可以訪問那裏的包 - 私有成員。
• processFailure，必須在延伸SupervisorStrategy的類中覆蓋的方法之一，在Restart和Stop上調用，因此對於您的方案，我們在那裏定義自定義行爲。