Einfaches Beispiel von RoudnRobinGroup in Akka

Question

Ich konnte nicht finden, bearbeitet von RoundRobingGroup in Akka (Beispiele in der Dokumentation konnte mir nicht helfen). Ich möchte zwei Akteure in einer RoundRobinGroup binden und einfach eine einfache Nachricht mit Akka (via Router-Variable) senden, aber ich erhalte immer den Deadletter in Logs.

object Main extends App { 
     val system = ActorSystem() 

     val paths = List("w1", "w2") 
     val w1 = system.actorOf(Props[HelloActor], name = "w1") 
     val w2 = system.actorOf(Props[HelloActor], name = "w2") 
     val router = system.actorOf(new RoundRobinGroup(paths).props(), "shard") 

     router ! "hello" 
} 

Ich würde gerne wissen, wo ist mein Fehler.

Answer 1

Es gelöst mein Problem

class Master extends Actor {  
      var router = { 
      val routees = Vector.fill(2) { 
       val mappings = context.actorOf(Props[HelloActor]) 
       context watch mappings 
       ActorRefRoutee(mappings) 
      } 
      Router(RoundRobinRoutingLogic(), routees) 
      } 

      def receive = { 
      case message: String => 
       router.route(message, sender()) 
      case Terminated(a) => 
       router = router.removeRoutee(a) 
       val r = context.actorOf(Props[HelloActor]) 
       context watch r 
       router = router.addRoutee(r) 
      } 
     } 

     class HelloActor extends Actor { 
      override def receive: Receive = { 
      case "hello" => println("Another actor said hello") 
      case _ => println("Unrecognized message") 
      } 
     } 

     object Main extends App { 
      val system = ActorSystem() 
      val master = system.actorOf(Props[Master], name = "parent") 
      master ! "hello" 
     } 

Answer 2

Sie können einen Router mit zwei Instanzen von HelloActor und Routern erstellen und RoundRobinRoutingLogic als Routing-Logik verwenden. Sie können eine detaillierte Information hier erhalten: http://doc.akka.io/docs/akka/current/scala/routing.html

Ich hoffe, ich habe dein Problem gelöst!