akka-cluster

1熱度

1回答

akka { actor { provider = "akka.cluster.ClusterActorRefProvider" } remote { enabled-transports = ["akka.remote.netty.tcp"] netty.tcp { hostname = "127.0.0.1"

0熱度

1回答

如何在加入akka中的新節點時創建遠程參與者？

解釋我的阿卡集羣設置：我有一個多節點集羣阿卡遠程演員。參與者位於Singleton類型的路由器之後。 Singleton路由器位於集羣Singleton代理之後。另外，在附註中，我有N類演員，每個演員做不同類型的任務並由不同的路由器管理。代碼段（JAVA） Config config = ConfigFactory.parseString( "akka.remote.nett

4熱度

1回答

卡夫卡和阿卡集羣

以下是我的使用情況的應用程序在不同的主題在排隊卡夫卡消息一羣。將每個主題的用戶分配給集羣中的工作者。這項工作可以分爲長時間運行，記憶密集型，簡單等，並且相應地選擇工人。這讓我探索Akka集羣的工作分配，路由和縮放。我可以使用Akka「Supervisor」作爲Kafka消費者，並根據分類將相關工作分配給相應的工作人員。但我仍然試圖瞭解的是在Akka集羣中實施主管和工作人員之間靈活的通信方式

1熱度

2回答

從將來返回到「發件人」演員

我想要做這樣的事情裏面 - class MyActor extends Actor { .... override def receive = { case msg => .... // do something Future { ... // calculate response sender ! response } }

0熱度

1回答

分佈式電子郵箱的Akka演員系統設計

我想創建基於Akka的分佈式電子郵箱系統。當我的應用程序啓動時，我想創建所有收件箱的演員，並啓動調度程序，以10秒爲間隔接收郵件。但是，如何創建這些收件箱演員存在問題？是否有可能在集羣上創建actor或在其存在時獲取對它的引用？角色名稱可以是數據庫中的郵箱UUID，並且羣集中只能存在一個具有特定UUID的角色。最重要的問題是如何使用uuid作爲cluster中的名稱創建actor，或者如果它存

6熱度

1回答

Akka Streams在羣集節點上運行

我想了解Akka Streams的縮放部分，我在這裏看到了各種回覆，但仍然無法理解如何實現此功能。有ActorPublisher /訂閱者，據我所知，它們是爲了與流進行交互，但同時它說這些不能是遠程的。我該如何完成能夠使用akka集羣與流一起？我是否必須讓GraphStage將其工作「外包」給遠程演員？或者graphStage本身可以在羣集節點上運行？我的用例是有一個管道包含幾個繁重的計算階

2熱度

1回答

Akka集羣單例作爲調度程序

我正在運行使用Akka集羣播放。我需要一個「Singleton Scheduler」來每小時執行一些任務。我到目前爲止發現的是，我應該使用ClusterSinglegonManager。但我不確定演員的外觀如何。在我看來，我不需要一個「接收」方法。也就是說，我怎麼instatiate我辛格爾頓： system.actorOf( ClusterSingletonManager.pr

2熱度

1回答

可以Akka羣集客戶端發送消息到羣集節點不在初始聯繫人？

使用Akka 2.3.14，我試圖創建各種服務的Akka集羣。到目前爲止，我已經將所有「服務」放在了一個集羣跨多個節點的工件中，但現在我試圖將這個工件分解成多個服務，這些服務都存在於同一個集羣中。因此，在打破這種情況下，我們設計了它，以便羣集上的任何節點都將首先嚐試連接到種子節點。如果沒有種子節點，它將查看它是否是作爲種子節點運行的候選（如果它位於種子節點可以在的同一主機上），在這種情況下，它將

1熱度

1回答

Akka ActorSelection over a cluser

我有一個簡單的羣集，每個節點上都有一個名爲「service」的服務actor。此服務分別使用ClusterClientRecptionist公開，以便能夠使用集羣外部的ist，並使用ClusterClient。客戶端然後註冊在羣集的隨機節點上創建的用戶（因爲ClusterClient隨機調度）。例如節點1上的/user/service/user1和節點2上的/user/service/user2

0熱度

1回答

如果演員失敗，附加到遠程演員的郵箱會發生什麼變化

如果遠程演員死去，父母演員會收到通知，但郵箱連接到遠程演員會發生什麼情況？如果沒有辦法檢索它，那麼我們怎麼能說akka是容錯的？