Diffuser un message aux acteurs qui regardent un acteur en particulier?

Question

Comment puis-je diffuser un message à tous les acteurs qui regardent un acteur en particulier? Pour le contexte, supposons que j'ai un AuctionActor (qui est potentiellement un acteur distant) qui est surveillé par un grand nombre de types AuctionParticipantActor. Je voudrais que le AuctionActor diffuse divers messages aux types AuctionParicipantActor.

Une possibilité serait que le AuctionActor conserve une collection de toutes les instances ActorRef du participant, puis boucle sur cette collection chaque fois qu'un message doit être envoyé à tous les participants. Cela semble inefficace et j'espère une meilleure solution ...

Answer 1

Si vous ne voulez pas aller avec PubSub comme mentionné par Diego Martinoia, je suggère d'utiliser Routers avec BroadcastingLogic. Cela va dans la direction que vous avez mentionnée avec la collection de ActorRefs, mais utilise la fonctionnalité Akka pour y parvenir étant plus efficace que simplement itérer sur une collection dans votre AuctionActor.

De Akka Docs

Les routeurs sont conçus pour être extrêmement efficace à la réception de messages et de les transmettre rapidement à routées.

Un acteur normal peut être utilisé pour le routage des messages, mais le traitement mono-thread d'un acteur peut devenir un goulot d'étranglement. Les routeurs peuvent atteindre un débit beaucoup plus élevé avec une optimisation du pipeline de traitement des messages habituel qui permet le routage simultané.

Dans votre cas, il pourrait ressembler à ceci:

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) 
    } 
}