問題タブ [akka-io]

与えられた:

私がするなら：

コードが 25 の非同期リクエストを起動することを期待します。代わりに、4 つの要求が開始されます。彼らは応答を待ちます。4 つすべてへの応答が戻ってくると、25 個すべてが処理されるまでさらに 4 つが送信されます。

カスタムディスパッチャーを作成するためにSprayの構成を微調整しようとしましたが、これは効果がありませんでした...

25 個のリクエストすべてを非同期で送信するように Akka/Spray を構成するにはどうすればよいですか?

使用: Akka 2.2.3、Spray 1.2.0

Scala と Akka アクターを使用してインタラクティブ ブローカー API を作成しています。

サーバーに接続し、IO マネージャーと通信して要求を送信し、TWS からの応答を受信するクライアント アクターがあります。接続は正常に機能し、リクエストを送信してレスポンスを取得できます。

その後、1 分後に IO マネージャーから PeerClosed メッセージを自動的に受け取ります。明示的に閉じない限り、接続を開いたままにしたいと思います。設定しようとしましkeepOpenOnPeerClosed = trueたが、何も変わりません。

アクターは次のとおりです。

IBJts API (標準の Java Socket を使用) を使用して接続した場合、同じ動作はし​​ません。

私は古い学校のテキスト ベースの telnet サーバーを作成していますが、これは現在、Akka アクター ベースの IO を備えた Scala の栄光のチャット ルームです。何が起こっているかというと、クライアントが何かを入力し始めると、イベントが発生し、それが書き込まれると、既に入力されたものはすべて消去されます。次の例では、Tom が「say How are you?」と入力し始めています。しかし、フレッドは「say How ar」と入力しただけで到着し、この入力は消去されます。

まだフラッシュされていない出力バッファを telnet に再表示させる方法はありますか?

サーバーは次のとおりです。

以下は、ConnectionHandler、そのコンパニオン オブジェクト、およびそれが使用するメッセージ ケース クラスです。

akka I/O の使用方法を学習しながら、akka I/O の上に単純なプロトコルを実装しようとしており、こちらのドキュメントに従っていました。

ただし、私のgradleファイルでは、以下に示すようにバージョン2.3.9を使用しています

パイプライン固有のいくつかのもののインポート

generate はシンボル エラーを解決できません。

したがって、私の質問。

1. これらが削除されたか、gradle ファイルに追加する必要がある依存関係があります。
2. それらが削除された場合、エンコード/デコード段階はどのように処理されますか?

1 つのアクターから複数のアクターに akka-cluster で約 200MB のサイズの大きなメッセージを送信する必要があります。akka メッセージを使用してみましたが、時間がかかるためタイムアウトします。

これを実装する最良の方法は何ですか? このようなタスクには Akka IO を使用する必要があるとどこかで読んだことがありますが、使用方法に関する十分なドキュメントが見つかりませんでした。

以下を使用してケースクラスを送信します。

それから私は受け取りました：

低レベルのJavaシリアライザーを使用せずにMyCaseClassのデータを一致させる簡単な方法はありますか?

チャンクでアクターに到着するデータがあり、それらのチャンクをPlay のストリームとして返したいと考えていますResult。から応答を取得する唯一の方法Ok.streamは理想的な候補のように見えるため、次のようになります。

アクターからを返し、Enumerator[Array[Byte]]メッセージがアクターに到着すると、アクター内で列挙子にチャンクをプッシュし続けます。ただし、アクターから変更可能な Enumerator を返すことは、何らかの違反のように思えます。

これを達成するためのより適切な方法はありますか？akka-stream問題空間に対処する可能性のある抽象化であるか、抽象化であると考えましakka.ioたが、それらがどのように適用されるかわかりません。