Broadcast-Nachricht an Schauspieler, die einen bestimmten Schauspieler sehen?

Question

Wie kann ich eine Nachricht an alle Schauspieler senden, die einen bestimmten Schauspieler sehen?

Für den Kontext angenommen, ich habe eine AuctionActor (die möglicherweise ein Remote-Actor ist), die von einer großen Anzahl von AuctionParticipantActor Typen beobachtet wird. Ich möchte die AuctionActor verschiedene Nachrichten an AuctionParicipantActor Arten senden.

Eine Möglichkeit wäre für die AuctionActor, eine Sammlung aller Teilnehmer ActorRef Instanzen zu halten und dann diese Sammlung zu durchlaufen, wenn jemals eine Nachricht an alle Teilnehmer gesendet werden muss. Dies scheint ineffizient und ich für eine bessere Lösung bin der Hoffnung, ...

Answer 1

Wenn Sie von Diego Martinoia wie erwähnt nicht mit PubSub gehen wollen, würde ich mit Routers mit BroadcastingLogic vorschlagen. Dies geht in die Richtung, die Sie mit der Sammlung von ActorRefs erwähnt haben, verwendet jedoch die Akka-Funktionalität, um effizienter zu sein, als nur über eine Sammlung in Ihrem AuctionActor zu iterieren.

Von Akka Docs

Router sind so konzipiert, extrem effizient sein bei Empfang von Nachrichten und Leiten sie schnell auf routees.

Ein normaler Akteur kann für das Routing von Nachrichten verwendet werden, aber die Singlethread-Verarbeitung eines Actors kann zu einem Engpass werden. Router können einen viel höheren Durchsatz mit einer Optimierung der üblichen Nachrichtenverarbeitungspipeline erzielen, die gleichzeitiges Routing ermöglicht.

In Ihrem Fall könnte es so aussehen:

class AuctionActor extends Actor { 
    var router = Router(BroadcastRoutingLogic(), Vector[ActorRefRoutee]()) 

    def receive = { 
    case AddParticipant(ref) => 
     router = router.addRoutee(ref) 
    case RemoveParticipant(ref) => 
     router = router.removeRoutee(ref) 
    case update: ImportantUpdate => 
     router.route(update, self) 
    } 
}