私はakka.netを初めて使い、できるだけ読み込もうとしています。私は2つのシナリオを持っていますが、どのように対処するか分からず、例に対する助けや指針を感謝します。プロデューサーのakka.netルーターへのスロットリングを扱う方法
1)私は、ファイルシステム上に着陸するzipファイルを探し、zipファイルに含まれる数千のXMLファイルを10個処理する必要があります。私はすでに処理主体を作成し、動的ルーターを使用して数百の要求を処理しています。私の質問は、ルータのプールに数十万のメッセージを押し入らせないように、プロデューサ(この場合は各XMLファイルを循環するイテレータ)をどのように抑制するかです。本質的に、私は俳優のプールを常に忙しくしたいと思っています。これにはいくつかの標準的なパターンがありますか?
2)ある時点で、各アクターが最後のアクターが完了するまで、各アクターがその出力を次のアクターにパイプラインで送信する複数のアクターで、XMLメッセージを処理する必要があります。私はこのパイプラインを柔軟にしたいと思います。つまり、1つのメッセージに対してアクタ1 - >アクタ2 - >アクタ3が必要ですが、もう1つはアクタ1 - アクタ2だけが必要な場合があります。ストリームを見ると、これは私が何をしているのか、あるいはある俳優から別の俳優にメッセージを渡すように見えますか?
任意のポインタは感謝
マイクが