Akka 程式設計 20 容錯處理 一

2021-09-10 18:21:16 字數 2785 閱讀 9907

我們在前面介紹actor系統時說過每個actor都是其子actor的管理員,並且每個actor定義了發生錯誤時的管理策略,策略一旦定義好,之後不能修改,就像是actor系統不可分割的一部分。

實用錯誤處理

首先我們來看乙個例子來顯示一種處理資料儲存錯誤的情況,這是現實中乙個應用可能出現的典型錯誤。當然實際的應用可能針對資料來源不存在時有不同的處理,這裡我們使用重新連線的處理方法。

下面是例子的原始碼,比較長,需要仔細閱讀,最好是實際執行,參考日誌來理解:

1importakka.actor._

2importakka.actor.supervisorstrategy._

3importscala.concurrent.duration._

4importakka.util.timeout

5importakka.event.loggingreceive

6importakka.pattern.

7importcom.typesafe.config.configfactory

8

9/**

10* runs the sample

11*/

12objectfaulthandlingdocsampleextends

13

14importworker._

15

16valconfig=configfactory.parsestring("""

我們在前面介紹actor系統時說過每個actor都是其子actor的管理員,並且每個actor定義了發生錯誤時的管理策略,策略一旦定義好,之後不能修改,就像是actor系統不可分割的一部分。

實用錯誤處理

首先我們來看乙個例子來顯示一種處理資料儲存錯誤的情況,這是現實中乙個應用可能出現的典型錯誤。當然實際的應用可能針對資料來源不存在時有不同的處理,這裡我們使用重新連線的處理方法。

下面是例子的原始碼,比較長,需要仔細閱讀,最好是實際執行,參考日誌來理解:

1importakka.actor._

2importakka.actor.supervisorstrategy._

3importscala.concurrent.duration._

4importakka.util.timeout

5importakka.event.loggingreceive

6importakka.pattern.

7importcom.typesafe.config.configfactory

8

9/**

10* runs the sample

11*/

12objectfaulthandlingdocsampleextends

13

14importworker._

15

16valconfig=configfactory.parsestring("""

mysql 容錯處理 詞典及容錯處理

在前面幾篇文章中都是在講倒排索引的結構,及合併優化方法.這篇博文裡更多談下怎麼根據輸輸入查詢引數來定位到倒排記錄表的指標.其實這跟mysql中對varchar型別加索引後,然後基於該欄位查詢的原理一樣,都是可以基於b tree的經典資料結構來快速定位.mysql中基於記憶體表還可以用hash索引,同...

SparkRDD容錯處理

rdd不同的依賴關係 寬依賴 窄依賴 是spark rdd有不同的容錯處理方式 對spark框架層面容錯機制的三大層面 排程層 rdd血統層 checkpoint層 和spark rdd容錯四大核心要點。1 spark rdd容錯原理 rdd的不同依賴關係導致spark對不同的依賴關係有不同的處理方...

詞典及容錯處理

在前面幾篇文章中都是在講倒排索引的結構,及合併優化方法.這篇博文裡更多談下怎麼根據輸輸入查詢引數來定位到倒排記錄表的指標.其實這跟mysql中對varchar型別加索引後,然後基於該欄位查詢的原理一樣,都是可以基於b tree的經典資料結構來快速定位.mysql中基於記憶體表還可以用hash索引,同...