永続アクタを使用したAkka Shardingの背圧

Question

Akkaストリーム背圧モデルまたは永続アクタを使用したakkaシャーディングを使用するためのものはありますか？

私には問題があるため、永続的なアクターを持つAkkShardingクラスタがあります。 （ジャーナルプラグインとしてcassandraを使用）。
多くの場合、複数のアクターを同時に作成する必要があります。 （たとえば、すべてのユーザにブロードキャストメッセージを送信する場合）
と数千の永続アクタが短時間（たとえば3.秒）に回復しようとします。重い負荷では、時間と多くの時間で応答しますアクターは複数回の回復に失敗し、決して再び回復しません。

Answer 1

あなたが望むのは、指数バックオフを使った監督戦略です。したがって、再起動（すなわち、データベースからの回復）が失敗した場合、直ちに再試行されるのではなく、データベースを過負荷にしないように、時間間隔を長くする。 AkkaはBackoffSupervisorを提供しています。 （このGithub issueで説明したように、それ自体がプラグ可能ではないクラスタシャーディング監督戦略）

クラスタシャーディングでこれを使用するには、Cluster Sharding docsを参照して、監督の戦略を定義し、あなたのエンティティのための中間親俳優を作成する必要があります。