問題タブ [akka-http]

akka http websocket connections に問題があります。handleMessagesWithSinkSource(sinkUsesActor , SFPTextMessage ) で websocket メッセージを処理します。sinkUsesActor はアクターを使用し、SFPTextMessage はアクターパブリッシャーからのソースです。ブラウザーを更新すると、接続を再確立しようとすると、次のエラーが表示されます。

このシナリオで、actorpublisher (SFPTextMessage) から同じソースを使用するにはどうすればよいですか?

私は現在、私のプロジェクトのためにakkaを探しています。主にWebソケットで通信するWebサーバーを構築したいと考えています（1時間に約1〜5 GBのデータの複数（たとえば数千）のストリームを収集するため）。

これは、水平方向のスケーリングが必要なプロジェクトになる予定です。私がやりたいことは、基本的に http 要求を受け入れますが、リモート アクター (おそらく別のマシン上) を開始して、接続を WebSocket 接続にアップグレードすることです。これは Akka(-http) で可能ですか? 私の現在の知識では、それは可能ではないと言っていますが、確かではありません。

また... アクター システムを scala で作成する場合、akka で作成されたアクターを C#.net で開始したり、その逆は可能ですか?

Akka Server HTTP を使用して着信要求を処理するサービス (サービス A と呼びましょう) があります。また、いくつかの Web サービスを提供するサードパーティ アプリケーション (サービス B) もあります。サービス A の目的は、クライアント要求を変換し、サービス B の 1 つまたは複数の Web サービスを呼び出し、結果をマージ/変換してクライアントに返すことです。

一部の部分にはアクターを使用し、他の部分にはフューチャーのみを使用しています。サービス B を呼び出すには、Akka HTTP クライアントを使用します。

問題は、各サービス A 要求ごとに新しいフローが作成され、複数の同時接続がある場合、次のようになることです。akka.stream.OverflowStrategy$Fail$BufferOverflowException: Exceeded configured max-open-requests value of [32] error

私はすでにこの質問をして、単一のフローを使用する提案を得ました複数の (10k - 100k) リクエストに対して Akka HTTP クライアントを適切に呼び出すには?

単一の場所からのリクエストのバッチに対しては機能しますが、すべての同時リクエスト ハンドラーから単一のフローを使用する方法がわかりません。

それを行うための正しい「Akka-way」は何ですか?

スプレー/ akka httpでは、次のようにケースクラスをマーシャリング/アンマーシャリングできます:

ただし、これは aLatitude(42)を objectにマーシャリングします{value:42}。私はむしろそれを JsNumber だけにマーシャリングしたいと思っています42。そのために、次のことを行いました。

ただし、「単純な値のケースクラス」ごとにこれを行いたくありません。jsonFormat1私の目標は、たとえば、使用するケース クラスに応じて、オブジェクトの書き込み/読み取りではなく単純な値を除いて、スプレーとまったく同じように機能する関数 (またはマクロ) を作成することです。

残念ながら、jsonFormat1 関数から返される jsonRootFormat オブジェクトを拡張または構成する方法はないようです。関数自体は既に非推奨のもの ( などClassManifest) を使用しているように見えるので、必要に応じてコピーして調整するかどうかはわかりません。このような単純なケースクラスを JsValue 関数に取得/作成するためのこの状況での最良のオプションは何ですか?

特定のパス パターンに一致させるためにakka ディレクティブを使用しています。

例は

可能な項目 (「りんご」、「バナナ」など) は事前にわからないため、使用する項目をハードコーディングすることpathはできません。

しかし、パスの先頭を抽出する PathMatcher が見つかりません。私はフォームの何かを探しています

どこ

パスの最初のセグメントを抽出する方法はありますか?

path(segment)数量がパスにある場合、マッチャーは一致しません。

path(segments)もちろん、パス要素を取得するために使用できますList[String]が、リストの先頭と末尾を手動で抽出する必要があり、エレガントではないようです。

事前のご検討とご対応をよろしくお願いいたします。

特定のルート インスタンスのドキュメントを生成できる、スプレー ルーティング DSL/Akka HTTP 用のカスタム拡張機能/ディレクティブはありますか?

私は Akka ストリームを扱うことを学んでいて、とても気に入っていますが、実体化の部分はまだ私にとって謎です。

http://doc.akka.io/docs/akka-stream-and-http-experimental/snapshot/scala/http/client-side/host-level.html#host-level-apiからの引用

... プール クライアント フローがマテリアライズされる HostConnectionPool インスタンスで shutdown() を呼び出すことにより、特定のプールの即時シャットダウンをトリガーします

HostConnectionPool インスタンスを取得するにはどうすればよいですか?

さらに重要なことは、具体化された値にアクセスして何らかの操作を実行したり、そこから情報を取得したりする方法を一般的に理解したいということです。

ドキュメントのポインタや説明を事前に感謝します。