Akka Supervisor Strategy 簡介 (Deprecated)

Introduction of Akka Supervisor Strategy

每一個 Akka Actor 都會有一個 supervisor。Supervisor 會監控它的子 Actor，並且決定在有 Exception 發生時，該如何處理。我們實作 Actor 時，可以不去 override 它，Akka 本身有預設的 supervisor strategy.

Akka 的 supervisor strategy 有兩種：

• OneForOneStrategy
• AllForOneStrategy

簡單來說，OneForOneStrategy 是其中某個 actor 發生問題時，不會去影響到它的兄弟姊妹，而 AllForOneStrategy 則會。Akka 自身預設是 OneForOneStrategy。

Akka 提供四種決定，

• Resume：繼續，不會 reset Actor 的資料
• Restart：重啟 Actor，會 reset Actor 的資料
• Stop: 中止 Actor
• Escalate: 將問題往上報，讓上層的 supervisor 來決定。

Akka Actor 有一個特性，就是 Actor 的資料跟工作是分開的，因此我們可以選擇用 Resume 的方式，保留資料，繼續往下處理。

Akka 預設的 strategy 處理方式

• ActorInitializationException => Stop
• ActorKilledException => Stop
• 其他的 Exception => Restart
• 其他的 Throwable => Escalate

所以如果我們都不作任何修改的話，當有 Exception 發生時，Akka 會自動重啟 Actor。這樣子的方式，已經符合大部分的需求。

參考資料：

• Akka Supervision and Monitoring
• Fault Tolerance

實作

Sample Code

延用 吃飯睡覺打東東 的企鵝笑話，來 demo Akka Strategy 的功能，名叫 東東 的企鵝，在被打第 4 次時，會說 不要打擾我，在第 6 次時，會 爆炸，在超過第 6 次後，牠就成仙了。本程式，主要是由 Reporter 來產生 Penguin，也因此 Reporter 是 Penguin 的 supervisor。各位可以在 Reporter 的程式碼中，修改

override val supervisorStrategy = 
    OneForOneStrategy(maxNrOfRetries = 10, withinTimeRange = 1 minute) {
    //AllForOneStrategy(maxNrOfRetries = 10, withinTimeRange = 1 minute) {

    case _ : DontBotherMeException => Resume
    case _ : ExplodeException => Restart
    case _ : IamGodException => Stop
    case _ : Exception => Escalate
    }

或註解掉這一段程式，來了解 Akka Stragegy 的運作方式。

尤其注意在 Resume 後，Penguin 的 hit 值，並沒有被 reset。

你可以依照以下的方式修改程式，觀察輸出的結果，來了解 Akka 的 Supervisor Strategy 運作方式

• 在本 sample code 中，如果都不修改的話，是不會進到 IamGodException，因為在 ExplodeException後，會重啟 Actor，而 hit 值就會被改成 0，重頭計算。

• 修改 ExplodeException => Resume，則會進到 IamGodException, 此時 東東 就會停止了，不能再使用。

• 修改 ExplodeException => Escalate，則會發現全部的 Penguin actor 都被重啟了，也包括 Reporter。

• 將 OneForOneStrategy 改成 AllForOneStrategy，則如果 東東 被重啟了，其他的 企鵝 也會被重啟。

可參考前兩篇的內容：

• Akka 簡介
• Akka Remote 簡介