akka-http

0熱度

2回答

我正在嘗試將akka-http導入到我的Scala項目中。我使用IntelliJ作爲IDE。以下是我的build.sbt： import sbt._ name := "hello" version := "1.0" scalaVersion := "2.12.1" libraryDependencies ++= Seq( "com.typesafe.akka" %% "ak

1熱度

1回答

使用akka-http websockets上傳和處理文件

我正在使用一些示例Scala代碼來使服務器通過websocket接收文件，臨時存儲該文件，在其上運行bash腳本，然後通過TextMessage返回stdout。示例代碼取自this github project。我在echoService中稍微編輯了代碼，以便它運行另一個處理臨時文件的函數。 object WebServer { def main(args: Array[Strin

3熱度

1回答

Akka HTTP api路由結構

我正在編寫基於Akka-HTTP的REST API。由於我是Akka和Scala的新手，我不確定在我的項目中組織代碼的最佳方式是什麼。我將約。具有基本CRUD的7個不同實體。這意味着我將在API中擁有超過25條路線。我想保留根據它們在邏輯上與之關聯的實體分組的路線。什麼可能是一個很好的方法來實現這一目標？目前，我從GitHub上提供的一些項目中獲得靈感，並將這些路線分組爲特徵。我有一個主要特徵，其

1熱度

1回答

閱讀Akka-Http的請求正文，並將每一行發送給演員的消息隊列

我正在搜索一個可以適合我的用例的示例，但到目前爲止我還沒有找到任何示例。我正在寫一個Akka WebService，它應該處理一個潛在巨大的純文本請求主體，將每一行發送給一個Actor的傳入消息隊列。難道你們中的任何一個人在這裏寫一些代碼或只是帶我到一個示例頁面？其實我沒有從哪裏開始的想法：大問題我是處理與一般的流（在我的情況下，我想用阿卡流庫）

1熱度

1回答

如何爲Akka http websockets添加錯誤流程

我一直在撞牆的時間很長，因爲我無法弄清楚如何爲akka http websocket流程添加錯誤流程。我想要實現的是：消息從WS客戶它的解析與瑟茜從JSON 如果消息是正確的格式發送所解析的消息給演員進來如果消息是錯誤的格式返回錯誤信息到客戶端演員還可以將消息發送到客戶端 Withou處理這個錯誤非常容易，但我無法弄清楚如何添加錯誤。下面是我有： type GameDecodeResult

1熱度

1回答

Akka HTTP客戶端websocket流的定義

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

0熱度

2回答

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

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

1熱度

1回答

Akka Http - 獲取多部分表單數據

我使用Akka-Http創建Post Call，其中用戶將填寫表單並提出請求。我希望這種形式的數據轉換爲斯卡拉Map[String, String] 任何一個可以告訴如何做到這一點。這裏是代碼片段 post { entity(as[Multipart.FormData]) { body => complete { //How to process Multi Part Fo

2熱度

3回答

SHA256的數據流

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

2熱度

1回答

卡夫卡主題websocket

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