akka-http

15熱度

1回答

阿卡HTTP和噴霧提供authenticateOAuth2指令，但their documentation states是此指令不會實現完整的OAuth2協議，而是能夠實現它，從HTTP報頭中提取所需要的令牌。我也找不到任何爲Akka HTTP或Spray實現OAuth2的庫。有什麼我想念的，或者這只是這些圖書館的狀態呢？

0熱度

1回答

Akka流和委託處理給演員

我有以下情況，我試圖將處理委託給角色。我想要發生的是每當我的流程處理消息時，它就會將它發送給演員，演員會將其大寫，並將其作爲響應寫入流中。所以我應該能夠連接到端口8000，輸入「hello」，讓流發送給演員，並讓演員將其發回給流，以便它回傳給我uppercased。演員本身非常基本，來自文檔中的ActorPublisher示例。我知道這段代碼不起作用，我清理了我的實驗以便編譯它。現在，它只是兩

1熱度

1回答

Akka-Http WebSocket：Akka流使用WebSocket作爲接收器

使用Akka-Http和Akka-Streams版本2.4我如何構造一個流，使其具有一個接收器，它是一個websocket。例如，我想要一個生成隨機數的源代碼，這些數字會被過濾，讓我們說保存偶數，然後作爲接收器流入WebSocket。感謝

5熱度

1回答

帶異步處理程序的Websocket

我無法使Akka http websockets與connection.handleWithAsyncHandler一起使用。這是我在Scala代碼（我使用的是最新版本的阿卡的HTTP） import akka.actor.ActorSystem import akka.http.scaladsl.Http import akka.http.scaladsl.model.HttpMethods

0熱度

1回答

Scala，Spray - 解組到列表[Int]

我試圖從JSON api獲取整數[1,2,3,...]的列表，但我看到轉換爲泛型類型不起作用，Spray文檔僅顯示解組到特定對象。任何想法如何使它工作/谷歌什麼來得到我的答案？ API端點：https://hacker-news.firebaseio.com/v0/newstories.json import java.io.IOException import akka.actor.Acto

1熱度

2回答

如何得到正確的參數驗證錯誤

我有一個簡單的路線，其中的參數應該被提取到case類： val myRoute: Route = get { path("resource") { parameters('foo, 'x.as[Int]).as(FooParams) { params => ... } ~ parameters('bar, 'x.as[Int])

1熱度

1回答

MongoDb中零星（身份驗證??）失敗和過期

我連接到我的MongoDB副本集有幾個問題。我創建了一個用於讀寫的mongodb管理員用戶。我可以成功登錄終端上的mongo shell，並且會話從未過期。在我的scala應用程序中，我運行帶有reactivemongo 0.11.9和MongoDB 3.2.1的akka-http，並將3個獨立服務器上的mongo複製集合放在Docker容器中，持久存儲分配給它們各自的主機。我在服務器啓動

1熱度

2回答

在Akka中啓用安全Web套接字支持HTTP

如何在Akka HTTP 2.0版中啓用對安全Web套接字的支持。我無法在官方文檔中找到任何具體指令或任何提示，請幫助。我目前的做法是： val handler:Flow[Message, Message, Unit] val route:Route = path("ws") { get { handleWebsocketMessages(wsService(wsHand

0熱度

1回答

獲得「一紙空文遭遇」使用噴霧客戶

我寫簡單的噴塗的客戶端代碼： // ActorSystem("main-actor-system") initialized earlier in code implicit val system = actorSystem implicit val execctx: scala.concurrent.ExecutionContext = system.dispatcher implicit

0熱度

2回答

淘金：通用方法來編碼/對象

我想實現一個通用的模式，由此產生使用淘金一個阿卡HTTP REST服務marshallers和unmarshallers，同時處理實體和集合級別的請求和響應的解碼陣列。我有一個實現實體水平，這樣沒有問題： case class Foo(foo: String) object Foo { implicit val FooJsonCodec = CodecJson.derive[Foo]