akka-http

3熱度

1回答

如何使用akka-http websocket客戶端監聽websocket服務器關閉事件

我有websocket客戶端連接到akka-http websocket服務器，如何監聽服務器上發生的連接關閉事件（即服務器關閉/服務器關閉websocket連接）？ object Client extends App { implicit val actorSystem = ActorSystem("akka-system") implicit val flowMater

0熱度

1回答

解組器可以解組一個http實體到一個映射[String，AnyRef]

我努力創建一個反編組器，它可以使httpEntity中的一個Map [String，AnyRef]，使流動路由定義將工作 path("cedt"/"processRow3") { post { entity(as[java.util.Map[String, AnyRef]]) { rowobj => rowProcessorActor ! rowobj compl

0熱度

1回答

使用akka http分塊響應流式傳輸JSON對象

是否濫用或以某種方式使用akka-http這種危險？在服務器 def source(consumerOffset: UUID) = readJournal.eventsByTag(「MyTag", consumerOffset).map(_.asJson) pathPrefix("stream"/Segment.map(UUID.fromString)) { offset =>

1熱度

1回答

如何設置內容類型？

我用阿卡HTTP客戶端2.4.6爲JSON發佈到服務器（服務器需要消息的內容類型是一個應用/ JSON處理）： val request = HttpRequest(uri = "http://localhost:9000/auth/add-user", method = HttpMethods.POST, entity = ByteString(write(createUs

2熱度

2回答

Akka-Http：How to TestProbe請求

我有一個請求，其響應取決於actor的回覆。我想測試一下這種方式： val myActor:TestProbe = TestProbe() val route = new MyRoute() { override def myServiceActor:ActorRef = { myActor.ref } }.route "return a query re

1熱度

1回答

如何在Akka-http（客戶端）HttpRequest中使用.withoutSizeLimit？

我使用Akka 2.4.7來讀取一個Web資源，它本質上是一個JSON對象流，用換行符分隔。溪流的大小實際上是無限的。當週圍8MB已經消耗掉，我得到一個異常： [error] (run-main-0) EntityStreamSizeException: actual entity size (None) exceeded content length limit (8388608 bytes)

2熱度

1回答

Scala akka-http客戶端超時錯誤

我有一個使用Akka並查詢REST服務器的Scala Play應用程序。該請求可能需要很長時間才能做出響應，並且出現超時：「服務器無法及時響應您的請求，請稍後重試！」我已經嘗試使用Play WSClient和卡卡-Http客戶端，並得到相同的錯誤，我已經設置每個超時屬性，我可以找到。的WSClient注入演員，我把它稱爲，這是在我的演員 val resp = ws.url("myurl").

2熱度

1回答

Websocket單元測試：從ScalaTestRouteTest WS不做websocket請求

我想爲websocket進行單元測試。從doc，我應該能夠使用WS 看到一個SSCCE低於 package com.streamingout import akka.http.scaladsl.model.ws.TextMessage import akka.http.scaladsl.server.Directives._ import akka.http.scaladsl.server

0熱度

1回答

Akka HTTP客戶端akka-http akka-http-jackson

我想讓一名演員在休息服務上調用一個簡單的GET。爲此我使用akka-http-experimental_2.11和akka-http-jackson-experimental_2.11。嘗試我可能找不到易於理解的java示例。該調用將被設置爲異步，並將該響應映射到POJO。你能幫忙嗎？我在Sink s，Flow s和CompletionStage<HttpResponse> s之間輸了。謝謝的

2熱度

2回答

如何爲akka-http查詢參數提供自定義的Deserializer？

的akka-http 2.4.7 reference指出，這是可以做到的定製Deserializer s到轉換查詢參數，而不將它們存儲在一箇中間變量：參數「量」爲Int的 "amount".as[Int]提取物價值，你需要在範圍上匹配的解串器該工作（也見解組）具有顯式解串器然而的參數「量」 "amount".as(deserializer)提取值，則Deserialized parameter該