akka

0熱度

1回答

我正試圖將我的ask要求限制在consumerActor。 val throttler: ActorRef = Source.actorRef(bufferSize = 1000, OverflowStrategy.dropNew) .throttle(10, 1.second, 1, ThrottleMode.Shaping) .to(Sink.foreach[Any](m

0熱度

1回答

有沒有辦法跟蹤Akka中的每條消息？

對於調試和測試，我想跟蹤發送給演員並由演員接收的每條消息。有沒有辦法在不改變代碼的情況下打開這種日誌記錄？或者，也許有任何免費的圖書館或其他工具可以做到這一點？

0熱度

1回答

水槽倍的阿卡流Source.actorRef緩衝和OverflowStrategy

這裏是akka documentation val sinkUnderTest = Flow[Int].map(_.toString).toMat(Sink.fold("")(_ + _))(Keep.right) val (ref, future) = Source.actorRef(3, OverflowStrategy.fail) .toMat(sinkUnderTest)(K

1熱度

1回答

X3D的Scala庫

我目前正在用Akka Http編寫一個Scala REST API。該REST API應提供有關3D模型的信息。格式爲x3d。我現在正在尋找一個將純XML文件轉換爲scala數據結構來處理的庫。我想避免自己寫這個數據結構。我已經做了一些研究，我只能找到支持渲染的庫，但我只想要數據結構，因爲這將在一個統一的客戶端上呈現。在此先感謝亞歷克斯

0熱度

1回答

Java akka將常用的東西放到一個地方

我正在使用java akka框架。我的一些演員在接受方法上會做同樣的事情。有沒有辦法避免這種情況，並讓他們到一個共同的位置。（可能使用繼承）問題詳細如下。在某些演員中，它根據條件發送ack消息。這個ACK 被另一個演員發送到外部系統。這是重複在幾個類。

1熱度

1回答

如何在崩潰後重新創建動態創建的持久性AKKA演員

我正在評估Akka的項目，並試圖通過將演員狀態保存在高可用數據中來確定是否可以通過Akka-Persistence實現服務的高可用性商店。（我不是indending使用Akka集羣）我理解保存演員國家的概念，但我很努力找到一種方法來重新創建演員（不是演員國家）恢復我的失敗（墜毀）服務在備份主機上。在我的設計中，有很多動態創建的角色，只有少數是在服務啓動時創建的。如何找出在恢復時需要創建的演

0熱度

1回答

如何重用Akka TCP連接來寫消息？

我想弄清楚一些使用Akka TCP模塊的基本功能 - 我也是Akka的新手。我想創建一個TCP客戶端角色，然後發送該角色消息來寫入數據到TCP通道。 TCP客戶端的執行情況（非常類似於TCP客戶端的例子 - http://doc.akka.io/docs/akka/current/scala/io-tcp.html#connecting）在應用 val actorSys = ActorSystem

2熱度

1回答

使用LibGDX與阿卡

我使用的是LibGDX一起阿卡試驗和我有以下問題 ERROR] [09012017 174508.522] [WorldMap-akka.actor.default-dispatcher-3] [akkaWorldMapusergame] No OpenGL context found in the current thread. java.lang.RuntimeException No Op

1熱度

1回答

Akka調度程序未在Play/Scala應用程序中配置異常

我正在執行磁盤密集型操作，我想使用自己的線程池而不是默認的線程池。我閱讀下面的鏈接，我面對完全一樣的問題 Akka :: dispatcher [%name%] not configured, using default-dispatcher 但我的配置文件是稍有不同，我已經試過了建議，但它不能正常工作。我在戲application.conf具有以下 jpa-execution-context

0熱度

1回答

我如何保證我使用的不是缺省的/全球隱式上下文

我有了這個導入Scala的文件 import scala.concurrent.ExecutionContext.Implicits.global 這正常爲Future我用我在方法精品工程文件。但是，我已經創建了一個用於磁盤IO的獨立方法，並且我有一個新的執行上下文。我希望此方法使用此上下文，而其他方法可以繼續使用默認上下文。我如何保證？我目前做如下 private def testConte