akka-cluster

0熱度

2回答

我們計劃在我們的項目中使用akka pub-sub。我有以下2個查詢註冊。 akka pub-sub行爲。如果發佈者在任何actor已經訂閱之前開始發送消息會怎麼樣？在任何用戶存在之前發佈的那些消息將會發生什麼。這些會被安靜地丟棄嗎？如果訂閱者參與者死亡會怎麼樣？[根本沒有訂閱者]發佈者發送的消息是否會累積到某個位置，或者是否會被pub-sub系統丟棄。

1熱度

1回答

Akka沒有自動加入種子節點

我用play app定義了一個akka集羣。 application.conf akka { actor { provider = "akka.cluster.ClusterActorRefProvider" } remote { log-remote-lifecycle-events = off netty.tcp { ho

0熱度

1回答

阿卡路由器具有多個行動者無法接收消息正確

在這裏，我創建的路由器與SmallestMailboxRouter ActorRef actorRouter = this?.getContext()?.actorOf(new Props(RuleStandardActor.class).withRouter(new SmallestMailboxRouter(38)),"standardActorRouter") 現在，在for循環我創建3

0熱度

1回答

在不使用路由器的情況下多次遠程部署阿卡的Actor

有沒有辦法在不使用路由器的情況下在多臺機器上部署遠程參與者？在以下配置中，我可以在遠程中放置多個地址嗎？ akka { actor { deployment { /sampleActor { remote = "akka.tcp://[email protected]:2553" } } } }

5熱度

2回答

NAT後面的akka集羣節點（使用docker）

是否可以在NAT後面運行akka節點（每個節點位於單獨的nat後面，公共端口是DNAT'ed爲private）？目前我正試圖在Docker容器中部署akka節點。 Docker將公共端口NAT爲實例私有端口，問題在於akka節點的地址是從akka.remote.netty.tcp.hostname創建的，但是在natted環境中它不同於面向公衆的主機名。來自公共接口的消息被拒絕，導致akka被綁定

29熱度

2回答

Akka中的羣集和遠程處理之間的區別

我已經在單個JVM上使用Akka開發了我的應用程序。現在我想在許多機器上分配工作負載。我開始閱讀文檔並感到困惑。有兩種方法可以通過羣集和遠程處理來分配Akka應用程序。我沒有得到兩者之間的區別。如果我理解正確二者在配置不包括本身相互因爲一個需要使用的演員參考不同的供應商： akka.remote.RemoteActorRefProvider akka.cluster.ClusterActo

2熱度

2回答

Akka應用程序中的JMX監控/統計信息

除了Cluster MBean之外是否還有任何內置的JMX公開的監控/統計信息可以在Akka（Java）中啓用？我已經看過Typesafe Console，但是由於它需要使用從多個節點收集數據的許可證，所以我希望能夠用普通的JMX實現同樣的功能。我已經在這個主題上檢查了Akka文檔，沒有任何運氣。

4熱度

2回答

測試角色發件人是本地還是遠程

我需要確定消息的發件人是否是Akka羣集中的本地或遠程角色之一。目前我發現要做到這一點的唯一方法是 def isLocal(sndr: ActorRef) = sndr.path.address.toString == context.system.toString 什麼是更好的方法？我用阿卡2.3 更新：要解釋爲什麼我想這樣做，萬一有完全避免這個問題的一種方式。在每個節點上，路由器管理

0熱度

1回答

如何在啓動期間啓動特定數量的工人演員？

我創建了基於的聚集akka應用程序。 https://github.com/typesafehub/activator-akka-distributed-workers-java/blob/master/tutorial/index.html 是否有在未來的任何構建運行在集羣給定類型的角色的具體數量。我應該創建路由器還是有更好的方法？ http://doc.akka.io/docs/akka/sn

0熱度

1回答

如何在Akka中加載application.conf

任何人都可以幫助我解決以下問題。我正在使用播放框架工作和Akka。我的編程語言是Java。我正在嘗試使用Akka Cluster。在Akka文檔中，據說application.conf應該放在src/main/resources中。但是在播放框架工作中，沒有名爲src的文件夾。所以我必須創建文件夾src並將application.conf放在那裏。另外我把我的代碼放在src/main/java/