akka.net

    1熱度

    1回答

    我已經建立了我的根演員: topicRootActor = actorSystem.ActorOf(actorSystem.DI().Props<RootActor>(), typeof(RootActor).Name + '.' + topic); topicRootActor.Tell(initMessage); 當它停止,因爲永久連接失敗或別的東西,我想停止的應用程序。 我

    0熱度

    1回答

    我不確定這個問題究竟在哪裏(或甚至如何問),所以我希望這裏有人能指引我朝着正確的方向前進。 我有一個服務,我正在建設。該服務在內存中有不同的對象 - 每個都有自己的狀態。每當創建一個對象時,它都會從數據庫中加載狀態並保存它。對對象進行更改時,它們對數據庫也是持久的。 我想擴展這項服務。我研究過諸如akka.net(演員模型)等解決方案,他們有一個集羣解決方案。從我讀過的內容來看,它將狀態與他們稱之

    0熱度

    1回答

    比方說,我有2個狀態 Ready和Busy抽象的演員。 在忙碌狀態下,我只想接收特定類型的消息,例如PauseJob,CancelJob,所有其他消息如StartNewJob都被隱藏。 問:如果我忙碌狀態設置SetReceiveTimeout(),它是在這種狀態下只適用於郵件,我居然過程(PauseJob,CancelJob)或藏匿的消息也算? 在此先感謝

    0熱度

    1回答

    我正在做一些示例以瞭解一些關於Akka.NET的內容。我試圖實現每個實體的子模式(如Akka.NET Design Patterns所示),其中每個用戶有一個角色(跨羣集)。 要做到這一點,我試圖使用ConsistentHashingPool的一個ClusterRouterPool,它將消息分發給一些父類actor,這些父類actor通過id代表索引的child actors(int,IActor

    0熱度

    1回答

    我有以下消息流 ConnectionActor - (RawMessage) - > ParserActor - (ParsedMessage) - > ProcessingActor - (DataMessage) - > DataStoreActor。 我想測試一下,當ParserActor收到一些特定的RawMessage時,我的ProcessingActor發送正確的DataMessage

    2熱度

    1回答

    當我編寫測試時涉及在EventStream上訂閱事件或觀看演員並列出「終止」列表時,測試可以一個一個地正常運行它們,但是當我運行整個測試套件那些測試失敗。 如果每個測試都在與Xunit單獨的測試課程中,那麼測試也可以使用。 怎麼回事? 這些類型的測試回購:https://github.com/Lejdholt/AkkaTestError

    2熱度

    1回答

    我不知道如何使用FSharp API生成羣集單例。我應該使用[spwane]還是[spawnOpt]?以及如何做到這一點?

    1熱度

    1回答

    Akka.Net羣集需要單個ActorSystem,但是如果我有幾個需要同步或異步協調的ActorSystems(分佈式應用程序)會怎樣? 如何處理共享消息庫?也許最好不要共享任何東西(除了通用消息庫)並使用動態消息,如:DynamicJsonMessageBase。 如何處理服務發現? 背景:我正在設計一個使用Akka.Net的微服務架構,它可能會使用Lighthouse作爲發現,REST HT

    0熱度

    1回答

    我已經設置了ActorSystem來對一組數據執行MapReduce。我現在有了最後一位演員來整理所有結果。我怎樣才能將結果反饋給啓動此演員系統的「服務」? //in below call i wire up all Actors var getActorSystem = CreateActorSystem(); //I wait for ActorSystem to complete g

    3熱度

    1回答

    以下行: let system = System.create "MyActorSystem" <| Configuration.load() ...產生這樣的輸出在F#互動窗口: Binding session to 'C:\Program Files (x86)\Microsoft Visual Studio 12.0\Blend\Newtonsoft.Json.dll'... System.