akka

3熱度

3回答

我對AKKA比較陌生，所以想要學習基礎知識。我的用例是不斷從JMS隊列讀取消息並將每個消息輸出到新文件。我已經得到了基本設置與工作： Source<String, NotUsed> jmsSource = JmsSource .textSource(JmsSourceSettings .create(connectionFactory) .withQueue("myQue

2熱度

2回答

從HttpEntity獲取JSON

我正在使用akka.http.scaladsl.model.HttpResponse，HttpEntity。得到響應後，它的格式爲responseEntity（Content-type：'application/json'，{MyJSONHERE}）。有沒有一種方法可以從實體中提取我的json？我試過entity.getDataBytes，它以ByteString格式給出了實體的內容。我想正確

0熱度

2回答

如何從WS呼叫處理的阿卡演員裏面超時

我有以下的演員，它發送到WebService的請求： class VigiaActor extends akka.actor.Actor { val log = Logging(context.system, this) context.setReceiveTimeout(5 seconds) import VigiaActor._ def receiv

0熱度

1回答

context.become改變阿卡演員的

我正在學習如何使用context.become來控制我的演員狀態的行爲，我使用這個代碼： class MyActor extends Actor { override def receive: Receive = { println("Happens here") active(Set.empty) } def active(isInSet:

0熱度

2回答

Akka-http - 請求和主機級池的配置

請求級API使用的超級池與主機級API創建的高速緩存池之間的池設置有何關係？爲了提供更多上下文：我需要以快速響應的請求和更昂貴的請求來查詢同一主機/端點。我目前的策略是使用便宜的查詢使用Http().singleRequest()，並使用緩存的主機池來「隔離」更昂貴的查詢。我想確保昂貴的查詢不會耗盡超級池中的所有可用連接。我對我的期望是否確實是2個獨立的池，即使它們指向相同的主機？如果是這樣，

1熱度

1回答

如何在Akka Streams中使用集合作爲源？

我是使用Akka Streams API的新手。我正在嘗試創建自定義圖形階段。對於我的每個階段，我希望每個「元素」都是一個scala集合，例如整數向量。但是，當我使用Source（Vector（1,2,3））或沿着這些行時，它會單獨傳遞元素1,2,3。有沒有一種方法可以在整個矢量中傳遞，因爲階段的結果取決於矢量內項目之間的關係？目前我使用List作爲「包裝」，但我不喜歡這種解決方案。提前致謝。示

0熱度

1回答

在rxjava中傳播slf4j MDC（映射診斷上下文）觀察對象

我在我的play framework（with akka）應用程序中使用了rxjava observables（v 1.1.8）。我想知道是否有辦法將MDC信息傳播到rxjava Observables。我在日誌報表中看不到MDC信息，這些信息打印在Observable/Subscriber中。我知道rxJava使用單獨的線程池，並且需要有一種機制將MDC信息從akka線程複製到rxjava線程中

7熱度

1回答

Flink和Play之間的Akka版本衝突2.5

在我們的項目中，我們有一個Flink（1.1.3）流作業，它從一個kafka隊列讀取數據，執行映射函數轉換並寫入另一個隊列。直到我們將流出的REST請求作爲流的一部分引入之後，這一切運行良好。要做到這一點，我們使用了PlayFramework WSClient（因爲它是在我們的堆棧的其他地方使用），並以這種方式創造了它的代碼： val config = new AhcWSClientConfi

0熱度

2回答

如何在spray/akka中手動拋出HTTP 404 Not Found異常？

在我的倉庫功能，我讀一個用戶，然後更新該用戶： def update(u: User): Future[Int] = { this.read(u.id).flatMap { case Some(existingUser) => db.run( userTable .filter(_.id === user.id) .upda

1熱度

2回答

如何向父代演員傳播錯誤

我嘗試瞭解使用akka和futures的故障處理。例如，我有父母和孩子的演員。兒童演員有兩個失敗的案例：情況1），而消息處理情況2）內部的將來發生錯誤發生錯誤我需要在這兩種情況下傳播錯誤的父母，但在第二種情況不會發生。我做錯了什麼？ import akka.actor.SupervisorStrategy.{Decider, Stop} import akka.actor.{Actor,