akka-http

0熱

2答えて

AkkaのStrictとStreamed WebSocketメッセージの両方を消費する

私は、Akka HTTPを使用してWebソケットサービスを構築することを試しています。私は完全に到着する厳密なメッセージを処理する必要があり、m個のフレームに到着するストリームメッセージを処理する必要があります。私はhandleWebSocketMessages（）でWebソケットの処理をフローに渡すためにルートを使用しています。 val route: Route = get {

1熱

1答えて

アッカのHttp Iはアッカ-HTTP &アッカ・ストリームと透過プロキシを実装しようとしている

ヘッダ解析をオフにしてください。しかし、私はアッカ-HTTP maniuplates問題に実行すると、上流のサーバからのレスポンスヘッダを解析しています。 Expires: "0" アッカは、ヘッダが有効期限にこれを解析して値を修正します： Expires: "Wed, 01 Jan 1800 00:00:00 GMT" が、開始上流のサーバは、次のヘッダを送信する例について unix時間が"0

0熱

1答えて

Akka HTTP「actor per request」パターン

現在、私はAkka HTTPに"actor-per-request" pattern proposed by NET-A-PORTER devsを実装しようとしています。私が直面している問題は、このパターンはドキュメントのどこにも書かれていないということです。 IO(Http) ! Http.Bind(serviceActor, "localhost", port = 38080) リクエスト

0熱

1答えて

スプレイリバースプロキシ：クライアントが切断された後にデータを転送し続ける

私はSpray/AkkaでリバースHTTPプロキシを実装しようとしていますが、問題が発生します。クライアントが切断された後でも、プロキシサーバーはアップストリームサーバーからデータを受信し続けることがあることがわかっています。は、ここで私は私のスプレープロキシディレクティブ（bthuillier's implementationにほんの少しの変更）を実装する方法は次のとおりです。 trait P

2熱

1答えて

Akka-httpでHTTPSリクエストを処理する[java]

小さなプロキシを作成して、すべてのローカルhttpリクエストを傍受し、リモートプロキシで認証しました。コードスニペットは次のとおりです。 Source<IncomingConnection, CompletionStage<ServerBinding>> serverSource = Http.get(system).bind(ConnectWithHttps.toHost("lo

1熱

1答えて

play-json - パラメータumの暗黙の値を見つけることができませんでした

私はこの質問が何度も尋ねられていることを知っていますが、それらのすべてがspray-jsonを使用しています。私はplay-jsonを使いたかったのです。これは、提案された解決策が問題を解決しない理由である可能性があります。 routeの形質はRestApi.scalaという別のファイルにあります。それを利用するHttp.bindAndHandleはMain.scalaという名前のファイルにありま

0熱

3答えて

実行中にエラーが発生しましアッカ-HTTP-microserviceのアクティベーターテンプレート

akka-http-microservice Activator template 実行することができません。例えば、テンプレート実行しているエラー：アクティベータープロジェクトからアッカ-HTTP-microserviceを構築しますが、実行している上、URLにアクセスすることができない、 http://localhost:9000/ip/8.8.8.8 なっ '内部サーバーエラー' 実行

1熱

1答えて

Akka-http違法リクエストヘッダ

2つのクエリパラメータを取り込む単純なエンドポイントを公開しました。私がローカルでコードをテストするとき、私は何の問題もありません。しかし、私は次のメッセージが表示さprodに配備されたとき：あなたは、私は任意の提案をいただければ幸いです import akka.actor.{ActorSystem, Props} import akka.http.scaladsl.Http import a

3熱

1答えて

Akka Http Client +ロードバランサ

akka httpを使用してロードバランサを起動する正しい方法は何ですか？現在、私は、コードのフォローピースを使用しています：私は前に接続を開くので val poolClientFlow = Http().cachedHostConnectionPool[String](host, port) source .map(url => HttpRequest(uri = url) ->

5熱

1答えて

Webソケット接続のサブスクライバからパブリッシャへのリアクティブストリームでメッセージを送信する方法

私のアプリケーションには、Akka-Websocketインターフェイスがあります。 Webソケットは、アクタ - サブスクライバとアクタパブリッシャで構成されています。サブスクライバは、対応するアクタにコマンドを送信してコマンドを処理します。パブリッシャーはイベントストリームをリッスンし、ストリームに更新情報を公開します（最終的にクライアントに公開します）。これはうまくいく。私の質問：サブスクラ