Dynamische Hinzufügen/Entfernen von Routes zu einem Router-Actor

Question

Würdest du einen schönen Weg in Akka/Scala zum Hinzufügen/Entfernen von Routes zu einem Broadcaster-Router kennen?

Ich habe mir den Resizer angeschaut - aber nicht meine Bedürfnisse (ich kann nicht sehen, wie man den Resizer explizit dazu anfordert, die Größe zu ändern (routees hinzufügen) und zu entfernen scheint, dass man dem Akteur eine Giftpille schicken muss welches dann entfernt wird).

Bisher habe ich einen Router mit einer Liste von ActorRef und ich schicke AddRoutee und RemoveRoutee Nachrichten ....

Mein Business Case: Ich habe einen Schauspieler Daten aus dem Netz bekommen (über einen Proxy) und muss diese Daten an unabhängige Akteure zur parallelen Verarbeitung senden. Aufgrund der Diagrammnatur der Empfänger (DAG) kann sich der Graph zur Laufzeit entwickeln, Scheitelpunkte/Kanten werden modifiziert, daher müssen Routen hinzugefügt und entfernt werden

Es muss einen saubereren Weg geben, dies zu tun.

Danke für die Zeiger.

Beispiel für Code, den ich Akka zu handhaben möchte:

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

Wenn Sie feststellen, dass Ihnen ein Feature in einem Router fehlt, ist es ein guter Zeitpunkt, um in die andere Richtung zu denken: Was stimmt nicht mit dem Code, den Sie präsentieren? Wenn Sie nicht mehr als ein paar Millionen Nachrichten pro Sekunde routen müssen (was Ihrer Beschreibung nach unwahrscheinlich ist), ist ein solcher Akteur genau die richtige Lösung. Router sind ein sehr spezialisiertes Konstrukt, das nicht als Ersatz verwendet werden sollte; verwende sie nur, wenn sie genau deinen Anforderungen entsprechen und du hast festgestellt, dass ein normaler Schauspieler nicht ausreicht.

Answer 2

nicht sicher, dass es wirklich ein besserer Weg als Staat über die routees zu halten und einen neuen Router bei jeder Änderung bauen oder benutzen Sie nicht ein Router und verwenden Sie einen einfachen Schauspieler. Ich habe mir das auch kürzlich angeschaut. Die favorisierte Lösung wird wahrscheinlich darin bestehen, den alten Router und/oder die Sammlung wegzuwerfen und einen neuen zu bauen (Router oder Set/Karte von Aktoren).

Bevorzugung der Unveränderlichkeit -

Sie können Ihre Aktoren einfach verfolgen und den Router überhaupt nicht verwenden - dies ist eine gute Lösung und wird in der akka Dokumentation als einfachere Alternative zu einem Router empfohlen. Router sollen einen Leistungsvorteil gegenüber einem vollwertigen Schauspieler haben.

Sie können Router mit Listen von Aktoren erstellen, wie hier gezeigt. Tun Sie dies einfach jedes Mal, wenn sich etwas ändert. (Quelle: akka Dokumentation - 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))) 

zeigt hier den Roundrobin-Router, aber das ist nicht anders als die Sendung einer verwenden.

Es ist ein bisschen funktionaler, um das neu zu erstellen.