akka-cluster

0熱度

1回答

我試圖建立一個阿卡集羣中的碼頭工人，在ElasticBeanstalk。節點必須像這樣互相通信： +-------------------------------------------------------+ | ElasticBeanstalk/ECS | | | | +----------------------+ +-----------

2熱度

2回答

如何在集羣中運行一次Akka Scheduler？

我想在羣集中運行Akka調度程序的單個實例。目前我的調度程序在我的本地工作正常，但不像預期的那樣。調度程序從數據庫中選擇訂單並推送到Kafka主題。我正在使用akka 2.5.6（Java）。我已經通過了official Doc，但沒有提供太多的幫助。任何幫助將不勝感激。 public class OrderReprocessActor extends UntypedActor {

2熱度

2回答

Akka集羣應用程序的CoordinatedShutdown超時

我們有一個akka集羣應用程序（分解一些參與者）。有時，當我們部署我們的應用程序應該被關閉，我們看到一些日誌這樣的：協調停機階段[集羣拆分關機區]超時出來後10000毫秒這發生在自上次部署以來超過2天的第一次部署中（例如，星期一）。我們要求阿卡節點退出與JMX助手集羣，我們有下面的代碼太： actorSystem.registerOnTermination { logger.err

0熱度

1回答

阿卡設計：如何添加/從羣集感知路由器刪除routee動態

我有以下的使用情況下，我不知道，如果阿卡工具包提供這個現成的：我有很多的節點（實例/機器）可以在後臺運行有限數量的長時間運行任務，並且在最大容量時不能接受更多工作。每個實例只能處理50個任務。所有實例位於負載均衡器後面。每個任務都可以響應來自啓動該任務的客戶端的消息，因爲客戶端通過負載均衡器發送消息，實例需要將其路由到處理任務的正確實例。我已經嘗試過最初的羣集分片，但似乎沒有辦法限制每個

0熱度

1回答

如何跟蹤Akka消息傳遞

我正在使用具有主 - 工作者模式的Akka集羣將作業分發給工作節點。 Kafka和JMS消息傳遞API可以瀏覽隊列或主題中的消息。我可以知道在所有發送者和接收者之間跟蹤Akka系統中的消息的最佳做法是什麼，以便我可以有效解決問題嗎？是否有基於Akka的框架來實現它？

10熱度

1回答

Akka集羣 - 每節點一個經理角色

我正在研究一個應用程序，該應用程序經常查詢大量的參與者，因此發送/接收的消息數量非常大。當應用程序在單臺機器上運行時，這不是問題，因爲這些消息是在單個JVM的邊界內發送的，速度非常快。但是，當我在多個節點上運行應用程序（使用akka集羣）時，每個節點都託管這些角色的一部分，並且消息通過網絡變得非常緩慢。我想出的一個解決方案是在運行應用程序的每個節點上都有一個ManagerActor。這將大大減少

0熱度

2回答

分片按流量使用阿卡演員

假設你有一個返回餐廳收視率在四個歐洲首都服務：阿姆斯特丹都柏林倫敦巴黎使用阿卡，想象你將每個城市分配給一個演員，然後將這些演員分配到兩個節點（認爲Akka集羣）。如果我們天真地分片我們按字母順序排列的演員，所產生的分工是：節點1：阿姆斯特丹+都柏林的演員（總人口400萬美元）節點2：倫敦+巴黎參與者（總人口1100萬）很明顯，交通將是非常不平衡的。如果你事先不知道城市的人口，Akk

0熱度

1回答

如何將akka sharded actor狀態外部化爲redis或ignite？

我對Akka聚類和研究概念證明非常陌生。在我的情況下，我有一個在羣集上運行的演員，演員的狀態爲Map [String，Any]。因此，對於任何請求，actor根據傳入的消息接收它，它會創建一個新的實體actor和數據映射。這裏的問題是地圖現在在內存中。是否有可能在Redis或點燃某個地方存儲Sharded actor狀態？

0熱度

1回答

我想創建一個簡單的單例集羣並從遠程節點發送消息

在這裏，我創建了一個單身演員。主節點和種子節點是相同的。從一個不同的項目中，我嘗試添加到羣集中並想發送消息。我能夠加入羣集，但無法發送消息。我的主人和種子節點： package Demo import akka.actor._ import akka.cluster.singleton.{ClusterSingletonManager, ClusterSingletonMa

1熱度

1回答

Akka cluster-sharding：根據通信模式移動actor碎片

我正在使用Akka（特別是遠程和集羣軟件包）構建一個開源分佈式經濟仿真平臺。這種仿真中的一個關鍵瓶頸是，參與者之間的通信模式在仿真過程中演變，並且通常參與者最終會通過羣集中節點之間的線路發送大量消息。我正在尋找一種機制來檢測某些節點上正在與某些其他節點上的actor進行大量通信並將它們移動到該另一個節點的actor。這可能使用現有的Akka集羣分片功能嗎？也許這是什麼Roland Kuhn意思是