akka

0熱度

1回答

我想聽聽使用阿卡流SQS阿卡流的狀態，我得到的消息從它的Q 使用此代碼段： implicit val system = ActorSystem() implicit val mat = ActorMaterializer() implicit val ec = ExecutionContext.fromExecutor(Executors.newFixedThreadPool(ConfigUt

1熱度

1回答

如何在Akka Stream Kafka中指定Kafka Zookeeper端點ConsumerSettings

我有一個在雲中運行某處的Kafka Broker，當我試圖通過命令行消費者工具使用它時，我可以使用消息。但是，當我將相同的端點放在我的akka-stream卡巴消費者設置中時，它不起作用。例如： - bin/kafka-console-consumer.sh --zookeeper主機名：2181/xxx/yyy - 主題名稱這對我有用。但是當我通過ConsumerSetting做同樣的事

1熱度

1回答

在Groovy中實現Akka AbstractActor會產生編譯器錯誤

Groovy 2.4.7這裏使用了具有Gradle座標的Akka Java API：com.typesafe.akka:akka-actor_2.11:2.5.4。我想實現一個AbstractActor，並運行到Java /阿卡API和Groovy本身之間的潛在衝突： class MyActor extends AbstractActor { @Override Receiv

0熱度

1回答

如何跟蹤Akka消息傳遞

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

-1熱度

1回答

Akka執行上下文與未來全局上下文

我知道Akka調度程序與全局執行上下文之間的基本區別。我嘗試這個代碼與scala.concurrent.ExecutionContext.Implicits.global import scala.concurrent.ExecutionContext.Implicits.global val resultF = (0 to 100).map( x => Futur

0熱度

1回答

基於Akka的Runnable Jar

我試圖從嵌入了幾個akka進程的命令行運行一個可運行jar。雖然我不是應用程序的原始作者，但我知道代碼在日食中運行得非常愉快。但是，當我嘗試導出然後作爲可運行Jar運行時，它會在一段時間後崩潰，並且這會在啓動akka進程時啓動。我使用Java 8運行它 java -jar something.jar {options} 錯誤： at akka.actor.ActorInitializat

10熱度

1回答

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

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

0熱度

1回答

com.typesafe.config.ConfigException $ Missing：在運行jar文件時未找到關鍵字'akka.stream'的配置設置

我試圖運行Akka流應用程序，但在Linux上運行時得到異常。當我使用Windows調試器運行它時，它正在工作。我想這兩個命令： java -jar ./myService.jar -Dconfig.resource=/opt/myservice/conf/application.conf java -jar ./myService.jar -Dconfig.file=/opt/myServ

0熱度

2回答

如何使用Akka actors管理數據庫連接？

我一直在研究Akka一段時間，我正在構建一個利用actor模型並需要維護與數據庫的連接的應用程序，但我有一個兩難的問題：我在哪裏放置這個連接，以及如何管理它？這是我的推理至今：連接應僅進行一次初始化。由於連接代表一個狀態，它應該駐留在一個actor中。我們稱這個actor爲DatabaseConnection（只是爲了創造性）。由於我不想分享演員的狀態，因此所有查詢都應該在演員內部發生。

1熱度

1回答

我是否安全地在我的akka演員中變異或者這不是線程安全的？

如果我安全地改變我的演員內部的可變映射/隊列，我有點困惑。有人可以告訴我，如果這段代碼是線程安全和正確的？ class SomeActor extends Actor { val userQ = mutable.Queue.empty[User] val tranQ = mutable.Map.empty[Int, Transaction] def receive