2016-09-22 3 views
1

私はakka.netを初めて使い、できるだけ読み込もうとしています。私は2つのシナリオを持っていますが、どのように対処するか分からず、例に対する助けや指針を感謝します。プロデューサーのakka.netルーターへのスロットリングを扱う方法

1)私は、ファイルシステム上に着陸するzipファイルを探し、zipファイルに含まれる数千のXMLファイルを10個処理する必要があります。私はすでに処理主体を作成し、動的ルーターを使用して数百の要求を処理しています。私の質問は、ルータのプールに数十万のメッセージを押し入らせないように、プロデューサ(この場合は各XMLファイルを循環するイテレータ)をどのように抑制するかです。本質的に、私は俳優のプールを常に忙しくしたいと思っています。これにはいくつかの標準的なパターンがありますか?

2)ある時点で、各アクターが最後のアクターが完了するまで、各アクターがその出力を次のアクターにパイプラインで送信する複数のアクターで、XMLメッセージを処理する必要があります。私はこのパイプラインを柔軟にしたいと思います。つまり、1つのメッセージに対してアクタ1 - >アクタ2 - >アクタ3が必要ですが、もう1つはアクタ1 - アクタ2だけが必要な場合があります。ストリームを見ると、これは私が何をしているのか、あるいはある俳優から別の俳優にメッセージを渡すように見えますか?

任意のポインタは感謝

マイクが

答えて

0

はいakka.netストリームは何が必要であるように思わ事前に

感謝を受け取ったことになります。あなたは消費者の速度に合わせて生産者に背を向けさせることができます。 stream integration with actors

2番目の部分では、単純にXMLメッセージの処理ステップ(入力と出力)であるフローを使用したい場合、柔軟に追加/削除できます。始めるのに最適な場所Akka.net streams

関連する問題