akka.net-cluster

0熱度

1回答

我正在尋找所有可用的參數及其允許值，這些參數的含義與我可以在使用Akk.Net的HOCON配置中配置的含義相同。我有一些聯繫，但他們沒有所有可用paraments的列表，否則它們不可用： http://getakka.net/articles/concepts/configuration.html https://github.com/petabridge/akka-bootcamp/tree/m

0熱度

1回答

是ReceiveTimeout應用到藏匿的消息

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

1熱度

1回答

Akka.net集羣分片：無法註冊協調器

我試圖通過創建simple project來設置akka.net集羣分片。項目佈局：演員 - 類庫，它定義了一個演員和消息。由其他項目引用入站 - 啓動ShardedRegion並且是參與集羣分片的唯一節點。而且應該是主持協調員的人。 MessageProducer - 將只承載shardedregion代理將消息發送到ProcessorActor。燈塔 - 種節點 Uploaded im

6熱度

1回答

Akka .NET連接池超時問題

我們正在創建一個使用Akka.NET的新系統，並具有分片和持久性的基本集羣設置。我們已經使用官方文檔以及一些Petabridge博客帖子來使分片正常工作。但是，我們遇到了分片超過SQL Server連接池允許的最大連接數的問題。因此，我們得到以下信息... 2017年4月20日14：04：31.433 +01：00【警告】「超時過期的超時時間已過獲取連接之前，發生這種情況的原因可能是因爲所有

0熱度

1回答

Akka.Net ClusterClientReceptionist多節點故障

我試圖創建一個示例，創建一個能夠處理訂單和發送訂單的客戶端的集羣。爲此，我使用ClusterClientReceptionist和ClusterClient在客戶端和集羣網絡之間進行通信。羣集節點的代碼： namespace ClusterNode { class Program { static void Main(string[] args)

0熱度

1回答

如何使用Akka.Net羣集僅在一個節點上擁有一個實體，並且從所有節點都有消息到達

我有一個包含客戶參與者的測試角色系統。它跟蹤客戶的狀態。事件消息和查詢消息被髮送到協調器。如果消息中沒有Customer actor，則協調員創建一個。做工精細，看起來像這樣：現在我想添加集羣。我希望系統對於很多客戶來說足夠大，並且當出現故障時，仍然可以處理其他節點的消息。所以在閱讀和修改一下之後，我想我知道該怎麼做，但我一定是誤會。這是我的方法。我在協調器上面添加了ConsistentHash

1熱度

2回答

集羣中的節點停止偵聽連接

我們有兩個具有相同代碼的節點，它們在羣集中使用akka.net並使用它們之間的遠程發送消息。 Akka.Net版本是1.2.0，我們使用dot-netty進行傳輸。這是相關的配置部分： actor { provider = "Akka.Cluster.ClusterActorRefProvider, Akka.Cluster" } remote { dot-netty.tcp { port = 3

2熱度

2回答

集羣一致的散列池爲相同的映射生成新的routee

我有一個解決方案，包含2個命令行項目，創建一個帶有種子和客戶端進程的akka.net集羣。種子啓動羣集，然後實例化一個一致的散列簇路由器，該路由器對實現我的接口「IHasRouting」的任何消息執行散列映射。因此，任何IHasRouting消息（來自種子或客戶端）應最終在該消息散列的路由器上種子。項目正常啓動並且羣集表單沒有錯誤。種子和客戶端實例化路由器。來自種子和客戶端的所有消息都具有相

2熱度

1回答

我如何讓運行在一個進程上的actor將消息發送給在另一個進程上運行的另一個actor？

我想讓在各種進程（或節點）上運行的參與者向不同進程（或節點）運行的其他參與者發送消息，同時保持容錯和負載平衡。我目前正在嘗試使用Akka.Cluster的Sharding功能來完成此操作。但是，我不知道如何做到這一點... 我有以下的代碼，反映了我的種子節點： let configurePort port = let config = Configuration.parse ("""

0熱度

1回答

是否有使用「Akkling.Cluster.Sharding」在演員之間發送消息的示例？

這可能是duplicate。因此，我已經取得了一些進展。但是，我認爲將reference documentation from the C# API解釋爲期望的Akka.FSharp API具有挑戰性。有沒有使用「Akkling.Cluster.Sharding」在actor之間發送消息的例子？截至目前，我只能從我的客戶端程序發送消息，而不是演員。 let consumer (actor:A