akka

    3熱度

    2回答

    我處於一種典型的情況,我有一羣工作人員正在從隊列中接受工作。工作人員失敗可能是暫時的,也可能是由於環境造成的,或者是永久性的,並且是由於工作無效造成的 在工作者角色內部,我正在處理永久性故障案例,但是如何對暫時案例實施重試?有了監督員,我可以讓演員重新啓動,希望嘗試重置到工作狀態,但是如何才能重試當失敗時正在處理的消息? 謝謝!

    1熱度

    1回答

    我正在測試我正在處理的新0123'如何處理意外消息。在這些情況下,我想斷言它會拋出GibberishException。這裏的測試也是迄今爲止實現: 測試: """throw a GibberishException for unrecognized messages""" in { //define a service that creates gibberish-speaking r

    2熱度

    2回答

    我正在嘗試使用Akka TypedActors(1.1.2)。我有一個接口,如 trait Namespace { def cellCount: Int def isEmpty: Boolean def cell(key: String): Option[CellOperations[_]] def cellsLike(key: String): List[

    5熱度

    1回答

    我正在嘗試使用Akka實現具有重試語義的作業。如果工作人員在工作中失敗(拋出異常),除了重新啓動它之外,我想重新提交正在處理的工作。 我正在嘗試的方法是自定義管理員,但我無法獲取它以重新啓動失敗時的工作人員。例如運行與阿卡1.1.3下面的代碼,你永遠也看不到重啓的消息: import akka.actor.ActorRef; import akka.actor.UntypedActor;

    7熱度

    1回答

    根據我的理解,沒有,有兩種方法可以通過擴展Actor類和實現接收或通過使用actor方法之一創建匿名Actor來創建actor。到現在爲止還挺好。 Akka有一個調度員的概念(http://akka.io/docs/akka/1.1.3/scala/dispatchers.html),所以這意味着一旦我創建一個actor並實現接收,通過默認情況下,我得到的事件調度器類似於在Scala中的反應?當然

    8熱度

    2回答

    我試圖在akka Actor中獲得容錯行爲。我正在研究一些依賴於系統中的Actor的代碼,這些代碼可用於長時間的處理。我發現我的處理在幾個小時後停止(應該大約需要10個小時),而且沒有太多的事情發生。我相信我的演員並沒有從例外中恢復過來。 我需要做些什麼才能讓演員永久重啓?我希望這可以從該文檔http://akka.io/docs/akka/1.1.3/scala/fault-tolerance

    9熱度

    1回答

    我正在嘗試創建一個包含Akka,Spray和Jetty的獨立JAR。理想情況下,我將整個應用程序分發到單個文件中,無需任何外部文件。 我知道如何創建一個嵌入式Jetty服務器實例 def main(args: Array[String]): Unit = { val server = new Server(9012); server.start(); server.j

    1熱度

    1回答

    我正在製作一款紙牌遊戲,看起來像演員 - 特別是遠程演員 - 將會非常合適。我無法弄清楚如何實現使用遠程參與者登錄的概念。如果玩家啓動胖客戶端並輸入用戶名和密碼,接下來會發生什麼?如果客戶端: 有一個用戶遠程actor,其中一些狀態發生變化以表示成功登錄? 在身份驗證遠程actor上調用一個方法並取回登錄的用戶遠程actor的句柄? 其他東西完全? 我也想知道這將如何適應網絡問題後重新連接。

    3熱度

    1回答

    我最近發現了akka框架,並覺得它與我的一個項目非常匹配。我必須說,迄今爲止我對它印象非常深刻。 在我的項目中,我需要讓1M +實體以非常快的速度接收狀態更新。自然,阿卡演員似乎是第一選擇。然而,我不知道我是否更好地使用代理來存儲狀態更新(到目前爲止,我的演員只有兩條消息 - 一條用於更新狀態,另一條用於閱讀狀態),我不相信永遠改變)。 看看代理的幾個例子,我感覺他們並不是想要存儲大型複雜狀態。我

    3熱度

    4回答

    這是我無法理解的東西。 在java.lang.Object中,clone()用protected修飾符定義。根據定義,它可以通過名稱在其自己的類定義中進行訪問,也可以通過名稱在派生自它的任何類中進行命名,也可以通過同名包中任何類的定義中的名稱來進行訪問。 這裏Sample類是在另一個包中,顯然它不能從Object類訪問clone()。但由於Sample隱含地從Object派生,爲什麼它無法訪問它?