akka-cluster

0熱度

1回答

我已經有3名演員和下面列出 RMQreaderActor的actorsystem執行只在一個節點一個演員 - 這是從RMQ讀取郵件演員並告訴下面的兩個演員的消息和處理將其轉換 ConverterActor ProcessorActor 我的要求是在4個節點羣集actorsystem但我不希望所有節點中的RMQreaderactor讀取隊列中的消息。只有一個節點應該讀取該消息並告訴其他參與者進行處理

0熱度

1回答

使用akka在網絡中搜索節點。

有沒有辦法在網絡中搜索節點，這樣如果任何節點關閉，我們可以在它重新連接時重新連接它。目前我正在使用mdns，但我想用akka來實現。我正在使用Java的akka。

3熱度

1回答

如何正確部署Akka羣集

場景現在我們只有一個節點運行整個系統。我們想要的是區分「前端」節點和單個「後端」節點。「前端」的節點（N節點）：維護通過網頁套接字連接與客戶端的持久連接「後端」節點（1個節點）：處理所有的請求未來形式的所有查詢到前端節點數據庫，並處理所需的域邏輯。這種區分是必要因爲某些原因：沒有達到limit of 70-100k persistent connections per frontend

2熱度

1回答

單身團隊演員未啓動

以下羣集單身人員未啓動。 commander = system.actorOf( ClusterSingletonManager.props(Commander.props(this), terminationMessage = PoisonPill.getInstance, settings = ClusterSingletonManagerSettings.crea

0熱度

1回答

阿卡集羣 - 集羣事件

我用阿卡集羣和我要聽上MemberJoined和MemberLeft的事件： override def preStart(): Unit = { cluster.subscribe(self, classOf[MemberEvent], classOf[MemberJoined], classOf[MemberLeft]) } 的問題是，它需要以下依賴： "com.typesafe

1熱度

2回答

帶有播放框架的Akka羣集設置

我目前正在嘗試使用自動發現服務實現羣集播放+ akka實現。但是，我似乎遇到了包含在遊戲中的Guice DI加載器的問題。從他們的文檔的摘錄指出： https://www.playframework.com/documentation/2.5.x/ScalaAkka#Integrating-with-Akka 雖然我們建議您使用內置的演員系統，因爲它設置了一切，如正確的類加載器，生命週期掛鉤，等等

6熱度

1回答

始終如一地處理Akka中的網絡分區和裂腦場景

看起來像akka.cluster.split-brain-resolver是付費功能。（我從this line in the docs獲得了這樣的印象）：這是Typesafe Reactive Platform的一項功能，它專爲Typesafe Project Success Subscription客戶提供。這是否意味着我將不得不付出處理導致腦裂的網絡分區的策略，還是有辦法處理可用的開放源

5熱度

1回答

遷移到玩！ 2.5導致此錯誤：NoSuchMethodError：akka.actor.LocalActorRefProvider.log（）Lakka/event/LoggingAdapter

我正在更新我的Play！斯卡拉應用從2.4到2.5.10和我得到這個運行時異常： java.lang.NoSuchMethodError: akka.actor.LocalActorRefProvider.log()Lakka/event/LoggingAdapter; 約阿卡的build.sbt部分並沒有改變，是如下（與akkaVersion 2.4.14）： "com.typesafe.a

1熱度

2回答

如何從akka中檢索分割區域形成不同的集羣節點？

在下面的代碼中，集羣節點FrontendNode如何獲取已在其他集羣節點BackendNode中啓動的分區區域「SomeShardRegion」的引用？當我嘗試下面的代碼，我得到這個異常：碎片類型[SomeShardRegion]必須首先啓動。注意：我不想在FrontendNode中啓動另一個「SomeShardRegion」！ object BackendNode extends App

0熱度

1回答

更新Akka版本：ClusterClient不是軟件包成員akka.contrib.pattern

我用akka-2.3.9和akka.contrib.pattern.ClusterClient。已經更新了版本akka-2.3.9 - >akka-2.4.9我有以下錯誤： ClusterClient is not a member of package akka.contrib.pattern 我應該使用akka.cluster.client.ClusterClient，而不是以前的akk