akka

0熱度

2回答

我在谷歌搜索，但沒有任何其他鏈接，除了Cassandra閱讀文檔頁面。所以，我只想問是否有任何API或函數已經包含在Akka-Cassandra包中用於批量行插入，或者我必須多次調用插入代碼來插入多行。注意： - 我不是在詢問插入多個事件，我只是想以密鑰對格式存儲一些json數據。所以包含Json對象的單個事件可能需要多行。在PHP和其他語言中，我們可以提供具有多行的Array，但Akka的Ca

1熱度

1回答

瞭解akka actor在崩潰時的默認行爲

actor的默認行爲是重新啓動。爲了得到更好的理解，我創建了兩個演員和崩潰導致重啓： class PingActor extends Actor with ActorLogging { import PingActor._ override def postRestart(reason: Throwable): Unit = { log.info(s"RESTART

2熱度

1回答

使用TestActorRef創建的參與者有時無法解析

如果使用TestActorRef.apply（）創建參與者，則可能無法通過在Future中調用actorSystem.actorSelection.resolveOne來解決。 TestActorRef的文檔說它可以在單線程環境中使用，但我想知道下面的測試失敗的原因是什麼。阿卡版本：2.4.16 最少的測試失敗，如果有錯誤akka.actor.ActorNotFound: Actor not f

2熱度

2回答

爲什麼Source.tick在一百個HttpRequests之後停止？

使用akka流和akka HTTP，我創建了一個每3秒輪詢一次api的流，將結果解組爲一個JsValue對象並將此結果發送給一個actor。如在下面的代碼可以看出： // Source wich performs an http request every 3 seconds. val source = Source.tick(0.seconds, 3.seconds,

1熱度

2回答

如何擴展超級演員在akka中的行爲

我想使用akka actor實施CRUD操作。我是一個新的阿卡，所以不知道阿卡演員的設計基礎。我想分享多個子角色中的akka角色的行爲。我想保存並刪除學生，老師和其他實體的杉木例子。我已經創建了男演員StudentDao.scala class StudentDao extends Actor with ActorLogging{ override def Receive = {

0熱度

1回答

與Akka演員取得方差是否正確？

使用泛型和阿卡演員時，我經常遇到以下問題： trait AuctionParticipantActor[P <: AuctionParticipant[P]] extends StackableActor { override def receive: Receive = { case message: Handled => participant =

1熱度

1回答

Akka Stream回調

我是Akka Streams的新手，我有一個問題。所以我可以從服務器操作和處理數據的一些客戶（從下面的官方文檔的源代碼）。 private static final ActorSystem system = ActorSystem.create("Client"); private static final Materializer materializer = ActorMaterializ

0熱度

1回答

阿卡卡夫卡流監理策略不工作

我運行一個阿卡流卡夫卡應用程序，我想結合的流消費者的監督策略，例如，如果經紀人下降，流消費者停止超時後死亡，主管可以重新啓動消費者。這裏是我的完整代碼： UserEventStream： import akka.actor.{Actor, PoisonPill, Props} import akka.kafka.{ConsumerSettings, Subscriptions} import

1熱度

1回答

使用Actor將數據發送到Akka websockets

我正在使用Akka websockets將數據推送到某個客戶端。這是我迄今所做的：「你好！」 import java.io.BufferedReader; import java.io.InputStreamReader; import java.util.concurrent.CompletionStage; import java.util.concurrent.TimeUnit;

1熱度

1回答

Akka應該如何限制隱藏能力？

我試圖驗證StashOverflowException何時投入Actor with Stash。爲此，我已經設置了stash-capacity一些上限如下： akka.actor.deployment.default-mailbox.stash-capacity = 10 ，並實現了一個簡單的演員是儲物箱，它收到的所有郵件。該演員然後通知發件人，如果積攢的成功與否： import akka.a