akka.net

1熱度

1回答

我試圖通過創建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【警告】「超時過期的超時時間已過獲取連接之前，發生這種情況的原因可能是因爲所有

2熱度

1回答

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

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

0熱度

1回答

Akka.net演員是否適合GET和搜索操作？

我們在當前項目中使用akka.net actor模型。我用一個實體actor來處理插入，更新和刪除操作。在搜索或獲取的情況下演員模型不適合？如果是在UI支持它怎麼可能得到的結果（天氣用於向功能）這豈不是很好的做法，使用get和查詢數據akka.net角色模型？

0熱度

1回答

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

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

0熱度

1回答

Akka.net持久性actor沒有從Fallback Config獲取連接字符串？

我在app.config文件中有我的主要hocon配置，並嘗試從使用後備配置的代碼後面設置連接字符串。但是演員系統啓動時不起作用。這裏是我的hocon配置和C＃代碼如下。有人能幫助我嗎？ Hocon配置我有註釋connnection串把它從備用配置 akka.persistence {隱藏文件 journal { plugin = "akka.persistence.journal.

0熱度

2回答

如何部署角色來分離進程/機器並使用ConsistentHashingGroup路由器？

如何部署角色來分離進程/機器並使用ConsistentHashingGroup路由器？我的策略是利用ConsistentHashingGroup路由器通過動態構建一個配置文件和我的系統上的節點地址。這些節點並不都在同一個進程中，但也可以在單獨的進程上運行。下面的配置文件示例依賴於靜態地址。但是，我相信我需要動態生成一個配置文件，因爲其他節點/機器上的actor路徑在編譯時並不知道。 let

0熱度

1回答

Akka.Net羣集簡單解釋

我嘗試使用akka.net做一個簡單的羣集。目標是讓服務器接收請求，並通過它的羣集akka.net處理它。爲了測試和學習，我創建了一個接收數學方程的簡單WCF服務，並且我想發送這個方程來解決。我有一個項目服務器和另一個客戶端。在服務器端的配置是： <![CDATA[ akka { actor { provider = "Akka.Cluster.C

1熱度

1回答

如何使用F實現Props.Create＃

我試圖將工作的C＃示例移植到OOP version of F#。遠程參與者（在單獨的進程上）沒有接收消息。我收到以下錯誤： [ERROR][3/23/2017 4:39:10 PM][Thread 0008][[akka://system2/system/endpointManage r/reliableEndpointWriter-akka.tcp%3A%2F%2Fsystem1%40lo

0熱度

1回答

兒童演員沒有得到重新啓動失敗

我有一個父演員是： public sealed class PersistenceSupervisor : ReceiveActor { protected override void PreStart() { base.PreStart(); Become(Active); } protected override Supe