akka-stream

1熱度

1回答

我過去成功地使用了Akka Streams，但是我目前很難理解爲什麼客戶端Websocket Streams在Akka-HTTP中被定義並且作爲它顯示在documentation中。由於WebSocket連接允許全雙工通信，我期望這種連接由Akka HTTP中的兩個單獨的流表示，一個用於傳入流量，另一個用於傳出流量。並且實際上，文檔指出以下幾點：甲的WebSocket由消息的兩個流的[...]

0熱度

2回答

Akka Streams scala DSL和Op-Rabbit

我已經開始使用Akka Streams和Op-Rabbit，並且有點困惑。我需要根據謂詞拆分流，然後將它們組合起來，就像我在創建圖形和使用分區和合並時完成的一樣。我已經能夠做這樣的事情使用GraphDSL.Builder，但似乎無法得到它與AckedSource /流程/水槽工作圖形看起來像： | --> flow1 --> | source--> partition --> |

3熱度

3回答

在AKKA-Streams中使用動態水槽目的地？

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

0熱度

1回答

交替，以減少發送實時統計數據（的減少）

我有一個愚蠢的問題，但不可能不知道的原因： import akka.{Done, NotUsed} import akka.actor.Status.Success import akka.actor.{ActorRef, ActorSystem} import akka.stream.scaladsl.{Flow, RunnableGraph, Sink, Source} import

0熱度

1回答

優化複雜查詢（使用分頁）

假設某些數據庫（PostgreSQL）中有N表。每個表Ti包含字段(time, label)，其中time是某個數字（例如長timestamp）。 label是一些文字。有N條件。每個條件Ci適用於特定表Ti。每個條件可能很複雜（使用自己的子查詢，也可以加入）。我需要從條件中收集所有表格T的記錄並獲得排序結果的頁面。該任務由SQL和UNION ALL解決。下面的僞說明了在抓取了一些網頁： (S

2熱度

3回答

SHA256的數據流

我有一個用例，我正在使用GET請求從URL下載文件。是否有可能計算文件流的SHA256而不保存到磁盤或將整個對象保存在內存中？

1熱度

1回答

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

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

2熱度

1回答

卡夫卡主題websocket

我想實現一個安裝程序，我有多個Web瀏覽器打開一個websocket連接到我的akka-http服務器，以便讀取發佈到卡夫卡主題的所有消息。所以消息流應該走這條路 kafka topic -> akka-http -> websocket connection 1 -> websocket connection 2 -> websocket conne

0熱度

2回答

Kafka - scala - 處理多個郵件

是否可以通過Kafka Producer對象發送字符串數組。我想從'topic1'中接收一些消息 - 文本行然後將其分割爲單個單詞並將其發送到另一個主題。 object KafkaConsumer extends App { implicit val actorSystem = ActorSystem("test-actor-system") implicit val s

0熱度

1回答

停止Akka演員在WebSocket斷開連接或空閒時間後

我目前正在使用Akka actors，streaming和http的組合來處理客戶端告訴服務器想要接收事件的速度有多快，並且服務器發送客戶端事件的速度。這裏的客戶端消息到服務器： { "uuid": "d30711c6-6bbf-4f11-9471-638ef7e19dfd", "startTime": "1501254050", "rate": "1.5" } 這是由看起來像這樣一