akka-http

0熱

1答えて

私は、次の手順を実行して、アッカのhttp 10.0.10を使用してルーティングするために、基本的な認証を追加しようとしています： def myUserPassAuthenticator(credentials: Credentials): Option[String] = credentials match { case p @ Credentials.Provided(id

0熱

1答えて

akkaストリームの接続kafkaとakka http

現在、akkaストリームで遊んでいて、次の例を試しました。特定のHTTPエンドポイントを要求するときに、kafkaから最初の要素を取得します。これは私が書いたコードとその動作です。 get { path("ticket"/IntNumber) { ticketNr => val future = Consumer.plainSource(consumerSetting

0熱

1答えて

[Scala、Akka]：未来onCompleteは送信者の外部では実行されません

私はルートクラス（送信者）、アクターとヘルパークラスを持っています。ルートクラスから、私は俳優にリクエストを送り、将来の応答を得る。今、私はヘルパーに将来の対応を渡し、そこで解決したいと思います。 TestRoute.scala： val response: Future[Any] = (actor ? request) (timeout) handler(response)(execution

0熱

1答えて

Akka HTTPがHTTP要求を完了するのにかかる時間の長さ

私は、ケースクラス（Event）をとり、それをHTTPエンドポイントに送り戻すフローを構築しました。それはそうのように実装されています：私は、HTTPリクエストにかかる時間を監視したい def handleResponse(endpoint: String)(responseTuple: (Try[HttpResponse], Event))(implicit actorSystem: Actor

0熱

1答えて

Akkaを使用したリクエストによるデータの受け渡しhttp

私はScala/Akkaを初めて使用しており、Akka Scaladslを使用して呼び出したいサービスがあります。カールを使用して、私はこのようなサービスを呼び出すことができます。 curl -v -d "STRING_DATA" -X GET http://localhost:3838/query?format=json 私はScaladslを使用してこのようなサービスを呼び出すことができま

0熱

2答えて

カスタムrequireParam（）ディレクティブを使用したAkka-HTTPコンパイルエラー

カスタムジェネリックディレクティブが作成されました。 import akka.http.scaladsl.common.NameReceptacle import akka.http.scaladsl.server.Directives._ import akka.http.scaladsl.server.directives.ParameterDirectives.ParamDefAux

0熱

1答えて

ScalaのAuthorizationヘッダ - アッカHTTPはIllegalArgumentException

私が合格/ユーザーの送信要求をするためにScalaでしようとしている：ヘッダーは「ユーザー：パスワード」である def makeRequestWithRadiusHeader(header: String) = { val urlEncHeaderVal = java.net.URLEncoder.encode(s"Basic $header", "utf-8") val re

0熱

1答えて

Akka HTTP - 生の（URLデコードされていない）リクエストURLを取得する方法は？

私はアッカのHTTPを使用して、次のHTTPリクエスト持っています： http://www.example.com?p1=1&p2=2&p3=http://www.example.net?a=1&b=2%203 をフル生（いないURLデコード）リクエストURLを取得するアッカHTTPでの方法はありますか？そのままの生のリクエストURLをそのまま取得したいと思います。 http://www.ex

0熱

1答えて

Source.actorRefまたはJavaのSource.queueに要素を送信する方法

私は現在、個人的なプロジェクトのためにAkka Streams（Java）で作業しています。 Source。アイデアはWebSocketを使用してコンテンツをユーザーのWebブラウザにプッシュすることです。私はAkka Streamsを使ってAkka HTTPのドキュメントに従って要求応答システムを作成しましたが、これは私がしたいことではありません。 Akka Streamsのドキュメントを見る