Anders Hesselbom

Om aktörer

2015-05-22

Det finns tre olika typer av aktörer i Akka .NET. Nedan använder jag en ReceiveActor som utmärker sig genom att den använder funktionen Receive för att ta emot ett meddelande. Exemplen som följer förutsätter att namnrymden Akka.Actor är inläst. Alla aktörer har en sökväg som är oberoende av vilken CLR-klass som beskriver dem. Givet att system är ett initierat aktörssystem med namnet MittSystem och att vi har två aktörer…

public class EnRootActor : ReceiveActor
{
}

public class EnAnnanActor : ReceiveActor
{
}

…så kommer denna kod att fallera eftersom båda aktörerna, trots sina olika klasser, gör anspråk på samma sökväg:

var a = system.ActorOf<EnRootActor>("MinRoot");
Console.WriteLine(a.Path);
var b = system.ActorOf<EnAnnanActor>("MinRoot");
Console.WriteLine(b.Path);

Jag använder Akka .NET lokalt, vilket syns på sökvägen som är akka://MittSystem/user/MinRoot vilket innebär protokollet akka, aktörssystemet MittSystem följt av sökvägen user/MinRoot. Alla användardefinierade aktörer ligger under user.

Både a och b kan samexistera givet att vi ger dem unika namn.

Aktörer behöver inte skapas på rootnivå. Om en aktör skapar en aktör organiseras den nya aktören under den som skapar aktören.

public class EnRootActor : ReceiveActor
{
   public EnRootActor()
   {
      this.Receive<Message>(m =>
      {
         var c = Context.ActorOf<EnAnnanActor>("Child");
         Console.WriteLine(c.Path);
      });
   }
}

I ovanstående fall har c sökvägen akka://MittSystem/user/MinRoot/MinChild, och eftersom vi har ett villkorslöst skapande så stöter vi på problem nästa gång vi skickar ett meddelande till EnRootActor eftersom MinChild inte kan skapas mer än en gång.

Akka .NET erbjuder möjligheten att erhålla referenser till existerande aktörer genom funktionen ActorSelection som kan agera antingen på systemet eller i kontexten för någon existerande aktör.

I detta exempel (en Console Application) är skapas en tredje aktör när aktör a hanterar meddelandet som skickas till den. Den tredje aktören får sedan ett meddelande skickat till sig från Main, vilket är en annan tråd.

class Program
{
   private static ActorSystem system;

   static void Main(string[] args)
   {
      var system = ActorSystem.Create("MittSystem");
      var a = system.ActorOf<EnRootActor>("MinRoot");
      Console.WriteLine(a.Path);
      var b = system.ActorOf<EnAnnanActor>("EnTillRoot");
      Console.WriteLine(b.Path);
      a.Tell(new Message("Helloooooo!"));

      //Godtycklig paus eftersom childaktören
      //skapas på en annan tråd.
      System.Threading.Thread.Sleep(1000);

      //Erhåll en referens till childaktören
      //och skicka ett meddelande.
      system.ActorSelection(
         "akka://MittSystem/user/MinRoot/Child").Tell(
         new Message("Snodd ref."));

      Console.ReadLine();
   }
}

public class EnRootActor : ReceiveActor
{
   public EnRootActor()
   {
      this.Receive<Message>(m =>
      {
         Console.WriteLine(m.Text);
         //Skapa en ny.
         var c = Context.ActorOf<EnAnnanActor>("Child");
         Console.WriteLine(c.Path);
      });
   }
}
   
public class EnAnnanActor : ReceiveActor
{
   public EnAnnanActor()
   {
      this.Receive<Message>(m => Console.WriteLine(m.Text));
   }
}

public class Message
{
   public string Text { get; private set; }
   public Message(string text)
   {
      this.Text = text;
   }
}

För att inte programmet ska krascha nästa gång EnRootActor tar emot meddelandet, kan man kort och gott kolla om childaktören redan är skapad.

public class EnRootActor : ReceiveActor
{
   public EnRootActor()
   {
      this.Receive<Message>(m =>
      {
         Console.WriteLine(m.Text);

         //Skapa en ny om det behövs.
         if (Context.GetChildren().Count() <= 0)
         {
            var c = Context.ActorOf<EnAnnanActor>("Child");
            Console.WriteLine(c.Path);
         }
      });
   }
}

Skulle man till äventyrs vara intresserad av vilka aktörer som är childaktörer går det bra att läsa av deras sökväg eller kanske bara deras namn:

foreach (var x in Context.GetChildren())
   Console.WriteLine(x.Path.Name);

Så här ser samma exempel ut i Visual Basic (förutsatt att du lagt på Akka .NET med NuGet):

Imports Akka.Actor

Module Module1

   Private sys As ActorSystem

   Sub Main()
      sys = ActorSystem.Create("MittSystem")
      Dim a = sys.ActorOf(Of EnRootActor)("MinRoot")
      Console.WriteLine(a.Path)
      Dim B = sys.ActorOf(Of EnAnnanActor)("EnTillRoot")
      a.Tell(New Message("Helloooooo!"))
      System.Threading.Thread.Sleep(1000)
      sys.ActorSelection( _
         "akka://MittSystem/user/MinRoot/Child").Tell( _
         New Message("Snodd ref."))
      a.Tell(New Message("Tjo!"))
      Console.ReadLine()
   End Sub

End Module

Public Class EnRootActor
   Inherits ReceiveActor

   Public Sub New()
      Me.Receive(Of Message)(AddressOf Me.ReceiveMessage)
   End Sub

   Private Sub ReceiveMessage(m As Message)
      Console.WriteLine(m.Text)
      If Context.GetChildren().Count() <= 0 Then
         Dim c = Context.ActorOf(Of EnAnnanActor)("Child")
         Console.WriteLine(c.Path)
      End If
   End Sub

End Class

Public Class EnAnnanActor
   Inherits ReceiveActor

   Public Sub New()
      Me.Receive(Of Message)(AddressOf Me.ReceiveMessage)
   End Sub

   Private Sub ReceiveMessage(m As Message)
      Console.WriteLine(m.Text)
   End Sub

End Class

Public Class Message

   Public Property Text() As String

   Public Sub New(Text As String)
      Me.Text = Text
   End Sub

End Class

Förutom ReceiveActor som alltså anropar funktionen Receive för att ta emot meddelanden, så har vi även TypedActor och UntypedActor.

En TypedActor anropar inte funktionen Receive för att ta emot meddelanden, utan har en överlagring av Handle för varje meddelandetyp som aktören kan hantera. En TypedActor ärver därför inte bara från basklassen TypedActor, utan även från det generiska interfacet IHandle<> för varje meddelandetyp som aktören ska hantera. Om man jobbar med klassen TypedActor betalar man med lite minskad flexibilitet, men vinner i ökad struktur. I detta exempel kan aktören ta emot både meddelande av typen A och B (där A och B är vanliga CLR-klasser).

class Program
{
   private static ActorSystem system;

   static void Main(string[] args)
   {
      var system = ActorSystem.Create("MittSystem");
      var actor = system.ActorOf<MyTypedActor>("MinActor");
      actor.Tell(new A());
      actor.Tell(new B());
      Console.ReadLine();
   }
}

public class MyTypedActor : TypedActor, IHandle<A>, IHandle<B>
{
   public void Handle(A message)
   {
      Console.WriteLine("Tack för A!");
   }

   public void Handle(B message)
   {
      Console.WriteLine("Tack för B!");
   }
}

public class A
{
}

public class B
{
}

En UntypedActor fungerar enligt samma princip, fast utan typer. Den har en enda funktion som blir anropad vid inkommande meddelande, och den funktionen tar emot meddelandet i object-format. Jag personligen kan inte se någon speciell poäng i att välja att ärva från UntypedActor, för om man inte har behov av typlåsningen så är ReceiveActor ett bättre val. Notera att UntypedActor skriver över funktionen OnReceive.

class Program
{
   private static ActorSystem system;

   static void Main(string[] args)
   {
      var system = ActorSystem.Create("MittSystem");
      var actor = system.ActorOf("MinActor");
      actor.Tell(new A());
      actor.Tell(new B());
      Console.ReadLine();
   }
}

public class MyUntypedActor : UntypedActor
{
   protected override void OnReceive(object message)
   {
      if (message.GetType() == typeof(A))
         Console.WriteLine("Tack för A!");
      else if (message.GetType() == typeof(B))
         Console.WriteLine("Tack för B!");
   }
}

public class A
{
}

public class B
{
}

Categories: C#, VB.NET

Tags: Akka .NET