ルータのアクタに経路を動的に追加/削除する

Question

ブロードキャストルータにルートを追加/削除するには、Akka/Scalaの便利な方法をご存知でしょうか？

私はResizerを見ていましたが、私のニーズを満たしていませんでした（私はresizerに経路を追加するよう明示的に要求する方法は見当たりませんし、それを取り除くにはPoison Pillをその後除去される）。

これまでのところ、

私のビジネスケース ....私はActorRefのリストを持つルータを持っていると私はAddRouteeとRemoveRouteeメッセージを送信：私はプロキシ経由（ネットワークからデータを取得する俳優を持っています）、このデータを独立したアクターにディスパッチして並列処理する必要があります。受信者（DAG）のグラフの性質上、グラフは実行時に進化し、頂点/辺が変更されるため、ルートを追加したり削除したりする必要があります。

これを行うにはもっとクリーンな方法が必要です。

ありがとうございます。

私はアッカが処理したいコードの例：

は

class MDActor extends Actor { 
    @volatile var routees = Set[ActorRef]() 

    def receive = { 
    case ar: AddRoutee => routees = routees + ar.actorRef 
    case rr: RemoveRoutee => routees = routees - rr.actorRef 
    case msg => routees.foreach(r => r forward msg) 
    } 
} 

Answer 1

ルーターの機能が不足している場合は、他の方向に向かって考え始めるのがよいでしょう。存在するアクターコードは何ですか？ 1秒間に数百万件以上のメッセージをルーティングする必要がある場合を除いて（あなたの説明によればそうは思わない）、そのような俳優は正確な解決策です。ルーターは非常に特殊な構成であり、代わりに使用すべきではありません。彼らがあなたの要件を正確に満たしている場合にのみ使用し、通常のアクターでは十分ではないとベンチマークしました。

Answer 2

わからない本当にrouteesについての状態を維持し、すべての変更に新しいルータを構築したり、使用しないためのより良い方法がありますルーターを使用し、プレーンアクターを使用します。私は最近これも見ました。

不変性 - 好都合な解決策は、古いルータやコレクションを捨てて、新しいルータ（ルータやルータのセット/マップ）を構築することです。

あなたはアクターを追跡して、ルータをまったく使用しないことができます。これは良い解決策であり、akkaドキュメントではルータのより簡単な代替手段として推奨されています。ルーターは、フル吹き出しの俳優に比べてパフォーマンスの優位性があると考えられています。

ここに示すように、俳優のリストを使ってルータを構築することができます。 変更があるたびにこれを行うだけです。 （ソース：アッカドキュメント - http://doc.akka.io/docs/akka/snapshot/scala/routing.html）

val actor1 = system.actorOf(Props[ExampleActor1]) 
val actor2 = system.actorOf(Props[ExampleActor1]) 
val actor3 = system.actorOf(Props[ExampleActor1]) 
val routees = Vector[ActorRef](actor1, actor2, actor3) 
val router2 = system.actorOf(Props().withRouter(
    RoundRobinRouter(routees = routees))) 

ここでは、ラウンドロビンルータを示していますが、それは放送1を使用するよりも何が違うのではないのです。

これを再作成するにはもう少し機能があります。