Akka.netロードバランシングとスパンアウト処理

Question

私は、5分の処理時間を要するリクエストのストリームを処理できるシステムを構築しようとしています。私の目標は、最小限のリソース占有量で要求処理をスピードアップし、時にはメッセージのバーストにすることです。

service busのようなものを使用して、リクエストをキューに入れ、メッセージを購読して処理を開始できる複数のプロセス（akkaのアクター）を持つことができます。また、サービスバスの待ち行列の長さを調べ、より多くの俳優/俳優システムを作成したり、いくつかを停止したりするウォッチドッグを持つこともできます。

もし私がAkka.netのようなActorシステムでこれをやりたいのであれば、どうすればいいのですか？このような何かを言う：

• 私は

• 私の要求キューの長さに基づいてアップ/新しいリモート俳優・システムを停止スピンにしたいことがあり可能な役者のいずれかにメッセージを送ります送信側で処理する帯域幅を持つ人物を確認することなく処理を開始できます。

• メッセージは失われてはならず、アクターが失敗した場合は、次に使用可能なアクターに渡す必要があります。

これはAkka.netで行うことができますが、これはアクターシステムの有効な使用例ではありません。ある人がいくつかの考えを共有したり、私が詳細を知ることができるリソースを教えてください。

Answer 1

私は私の要求キューの長さ

これはAkka.Clusterで箱から出してサポートされていないに基づいて新しいリモート俳優・システムを/スピンアップを停止することをお勧めします。あなたはそれのために何かカスタムを構築する必要があります。

しかし、Akka .NETには、設定可能なパラメータに従って自動的にサイズ変更できるpool routersがあります。あなたはそれらの周りに何かを構築することができるかもしれません。

送信側で処理する帯域幅を持つユーザーを確認せずに処理を開始できる利用可能な俳優のいずれかにメッセージを送信します。

Akka .NET Routersを見ると、作業を割り当てるためのさまざまな方法があります。 SmallestMailboxはおそらくあなたが行っていることに最も近いでしょう。

メッセージは失われてはならず、アクターが失敗した場合は、次の使用可能なアクターに渡す必要があります。

Akka .NETは、一度に配信します。詳細についてはin the docsまたはat the Petabridge blogをご覧ください。

Answer 2

あなたはAkkaクラスターであなたの目標のいくつかを達成するかもしれませんが、私はそれをアドバイスしません。あなたの要求から、あなたの懸念事項は次のように明確に述べられています。

• 信頼性の高いメッセージ配信（サービスバスとメッセージキューが最適なオプション） MassTransit、NServiceBus、またはキュー（RabbitMQ）のニーズに応じて、ここでは多くのソリューションがあります。
• スケーリング作業者（インフラストラクチャの問題で、アクターフレームワーク自体では解決できません）。あなたが言ったことから、あなたはクラスターさえ必要ない。

ワーカーのようなメッセージ処理ロジックを構築するためにakkaを使用できます。しかし、私が言ったように、あなたの目標が既存のサービスバスを置き換えることであれば、それは必要ありません。