akka.net

    1熱度

    2回答

    我們在加入akka.net演員遺留系統的一部分的過程。 其基本思想是,一條消息從外部系統進入,它被交給一個由akka.net演員管理的邏輯,然後與傳統組件進行對話,這些組件將數據保存到數據庫中。 傳統代碼依賴於在CallContext中設置userId,然後在數據庫寫入之前可以檢索(存儲諸如「CreatedBy」和「LastModifiedBy」之類的東西)的事實。看起來很清楚,一旦消息傳遞給ac

    5熱度

    1回答

    在羣集環境中,我有一個種子節點和node1和node2。 從節點1我想發送一條消息給在node2上創建的Actor。節點2上此節點的本地路徑是akka:MyAkkaSystem/user/AnActor。 現在我想用這樣的ActorSelection從一個演員從節點1發送消息到這個特定的演員: var actorSystem = ActorSystem.Create("MyTestSystem")

    5熱度

    1回答

    將Akka.net與遠程處理結合使用。 This article有以下說關於使用ActorSelection: 其他時候,我傾向於使用ActorSelection是當我最初 與遠程演員系統通信。 我不太明白的是如何將最初的ActorSelection轉換爲IActorRef,我可以繼續使用。

    2熱度

    1回答

    我正在嘗試主管策略工作。這是一個場景的例子。 A diagram of a demo app the implements a SupversiorStrategy 我有個演員,FloorTrader使得在的onReceive(對象消息),創建一個FederalRegulator演員: var regulator = Context.ActorOf(Props.Create(() => new F

    1熱度

    1回答

    我想知道Akka.net如何與IIS和asp.net一起工作,因爲Asp.net會爲請求/響應創建線程池。 如果這些線程被Actor系統使用,那麼我們正在爲請求服務提供一些線程,這將對可伸縮性產生負面影響。 如果Akka.net沒有使用線程,它將如何創建一個併發工作來完成。

    1熱度

    1回答

    我正在爲遠程服務上的actor創建重試/重新連接功能。演員應該在prestart上調用選擇參考以訂閱來自遠程服務上演員的消息。如果由於某種原因演員不在那裏,我希望我的演員在報告連接失敗之前重試幾次。 我正在使用TestKit tdd的功能。我遇到的問題是,當演員拋出超時異常之後,即使我有停止策略,也會調用prestart。 我是我誤解演員的生命週期?看起來很奇怪,如果策略在失敗後停止,PreSta

    0熱度

    1回答

    我使用Akka.net並尋找推行「DDD庫」的反應性等價物,從我從這裏http://qnalist.com/questions/5585484/ddd-eventsourcing-with-akka-persistence和https://gitter.im/petabridge/akka-bootcamp/archives/2015/06/25 看到我的理解根據一些實時內存計數或一些經過時間,讓

    2熱度

    1回答

    我有巨大的內存對象,我只是想知道,如果我可以創建一個ConsistentHashing路由器,並能分裂負載演員。 主要問題是我需要在創建之後用數據攝取演員,所以只是想知道如何實現這一點。 主對象有很多記錄,這些記錄將按Id字段分組。 這是我的想法: 創建演員的時候 - 我可以得到它的hashPool從主對象檢索所需的證書? 當創建actor時我可以包裝接收消息ConsistentHashableE

    3熱度

    2回答

    我正嘗試在F#中獲得一些Akka.NET參與者的一些經驗。當一個演員需要將另一個演員作爲自己的孩子時,我有這種情況。第一個演員會轉換每條消息,然後將結果發送給其他演員。我使用actorOf2函數來派生演員。這裏是我的代碼: let actor1 work1 work2 = let mutable actor2Ref = null let imp (mailbox : Actor

    2熱度

    1回答

    翻譯我使用Akka.Remote從ASP.NET Web應用程序在我的後端(託管作爲Windows服務)調用一個演員。作爲代碼的一部分,我正在查找遠程系統上可能存在或不存在的actor。 在調用如下客戶端... var profileActor = await someRemoteActor.Ask<IActorRef>(new LoadProfile("[email protected]"));