akka-cluster

1熱度

1回答

我有一個簡單的POC有兩個參與者： public final class Task1Actor extends AbstractLoggingActor { public Task1Actor() { final UnitPFBuilder<Object> builder = ReceiveBuilder.create() .matchAny(message ->

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回答

什麼是阿卡集羣辛格爾頓啓動

正確的方式我嘗試實施方案的阿卡集羣啓動：運行羣集種簡單的演員（集羣監控，這表明其他成員的加入）運行一些羣集成員，它採用ClusterSingletonManager和ClusterSingletonProxy演員爲Singleton實施但是我有一個問題： 10:52:41.691UTC INFO akka.tcp://[email protected]:9401/user/singleton

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

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

6熱度

1回答

Akka集羣加入DNS負載平衡

看看akka cluster documentation它似乎必須知道服務器&至少1個「種子節點」的端口值加入羣集。這個例子application.conf清楚地表明，開發者需要知道的「主機1」和「主機2」寫入文件時： akka.cluster.seed-nodes = [ "akka.tcp://[email protected]:2552", "akka.tcp://[em

0熱度

1回答

Akka不會選擇現有的工作節點作爲種子節點，一旦種子節點被殺死

我是一個新手，帶着阿卡。擁有一個種子節點和一個非種子節點的非常簡單的配置。請在下面找到，操作的順序： - 種子節點開始： - val pConfig = ConfigFactory.load("application.conf").getConfig("PrimaryNode") val demoSystem = ActorSystem("DemoSystem", pConfig) [

0熱度

1回答

akka.cluster.ClusterActorRefProvider找不到

我想用akka集羣運行我的遊戲應用程序。我在我的build.sbt文件中添加了依賴關係，並且更改反映在我的jar列表中。仍然在運行我的應用程序時，它給了我「java.lang.ClassNotFoundException：akka.cluster.ClusterActorRefProvider」錯誤。任何想法？？這是快照從我build.sbt文件這是從罐子文件夾

0熱度

1回答

阿卡：用戶處理多主題

公共類用戶擴展UntypedActor { public Subscriber() { ActorRef mediator = DistributedPubSub.get(getContext().system()).mediator(); // subscribe to the topic named "content" mediator.tell(n