akka

0熱度

1回答

我正在嘗試使用akka-http爲AccountActors的REST API和akka actors創建一個貨幣交易系統。 post { (path("accounts"/"move-money") & entity(as[MoveMoneyRequest])) { moveMoneyRequest => complete( (bankActor ? moveMo

0熱度

1回答

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

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

2熱度

1回答

訪問演員郵箱的消息

我想讀取ShardRegions郵箱中的消息。在以前的版本阿卡，我們可以使用下面的代碼只得到郵箱的大小： getContext().getMailboxSize(); 有什麼辦法來獲取信息的郵箱類型？

1熱度

1回答

在Akka Actor中撰寫多個接收函數

我有一個Akka Actor，負責管理一些消息，如Find,Query，它將一條新消息轉發給其他類型的演員。這些演員將以新類型的消息作出迴應。 class Actorbase extends Actor { override def receive = { /* The two message below are related to each other */ ca

0熱度

1回答

從Java API使用Akka AbstractActorWithTimers

我試圖在Java（很好，Groovy，真的）應用中使用新的Akka Timers API，當然使用Akka/Java API（我使用的Gradle座標是'com.typesafe.akka:akka-actor_2.11:2.5.4' ）。當我試圖製作我的新的定時器股價的演員，我得到的編譯器錯誤： class MyTimeAwareActor extends AbstractActorWithTi

1熱度

1回答

Akka http高吞吐量拋出異常 - java.io.IOException：在系統中打開的文件太多

我想發送200k郵件給AKK-HTTP。 protected val someRouts: Route = pathPrefix("foo") { pathEndOrSingleSlash { put { entity(as[Foo]) { foo => log.debug(s"/foo update $foo") compl

0熱度

1回答

阿卡/播放配置文件

我有下面的示例配置，對於工作我 blocking-io-dispatcher { db-backup-context { thread-pool-executor { core-pool-size-factor = 3 core-pool-size-max = 10 } } } 我沒讀核心池的大小，以及核心池大小max和種類如何涉及有界隊列。以上是我

0熱度

1回答

如何從akka流源獲取迭代器？

我正在嘗試創建一個可以通過類似Iterator的東西來消費的流。我正在實現一個公開類似於迭代器的接口的庫，所以這對我來說是最簡單的東西。我目前設計的圖形本質上是Source<Iterator<DataRow>>。有一件事我看到到目前爲止是將其壓扁到Source<DataRow>然後用後跟https://docs.oracle.com/javase/8/docs/api/java/util/st

0熱度

1回答

使用ClusterSharding將實體ID存儲在Akka集羣中

我有一個akka.net集羣，我打算使用ClusterSharding在集羣中的節點之間分割實體（actors）。坐在集羣之上的是一個層，它將成爲提供端點來創建和檢索實體的標準REST樣式API。我還希望能夠通過此API返回集羣中當前所有實體的ID（就像您通常在REST樣式API中一樣，例如通過GET on/api/entity） - 這些ID會是實體的屬性，或者可以是ClusterShardin

0熱度

1回答

如何管理使用TTL

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