In this lesson, we're going to learn how to decouple our actors from each other a bit and a new way of communicating between actors: ActorSelection. This lesson is shorter than the previous ones, now that we've laid down a solid conceptual foundation.
ActorSelection is a natural extension of actor hierarchies, which we covered in the last lesson. Now that we understand that actors live in hierarchies, it begs the question: now that actors aren't all on the same level, does this change the way they communicate?
We know that we need a handle to an actor in order to send it a message and get it to do work. But now we have actors all over the place in this hierarchy, and don't always have a direct link (IActorRef) to the actor(s) we want to send messages to.
So how do we send a message to an actor somewhere else in the hierarchy, that we don't have a stored IActorRef for? What then?
Enter ActorSelection.
ActorSelection is nothing more than using an ActorPath to get a handle to an actor or actors so you can send them a message, without having to store their actual IActorRefs.
Instead of getting a handle to an actor by creating or passing around its IActorRef, you're "looking up" a handle to the actor by its ActorPath (recall that the ActorPath is the address for an actor's position in the system hierarchy). It's kind of like looking someone up on Skype by their email when you don't already have their username.
However, be aware that while ActorSelection is how you look up an IActorRef, it's not inherently a 1-1 lookup to a single actor.
Technically, the ActorSelection object you get when you do a lookup does not point to a specific IActorRef. It's actually a handle that internally points to every IActorRef that matches the expression you looked up. Wildcards are supported in this expression, so it's an expression that selects 0+ actors. (More on this later.)
An ActorSelection will also match two different IActorRefs with the same name if the first one dies and is replaced by another (not restarted, in which case it would be the same IActorRef).
We think of ActorSelection as both a process and an object: the process of looking actor(s) up by ActorPath, and the object returned from that lookup, which allows us to send messages to the actor(s) matched by the expression we looked up.
In general, you should always try to use IActorRefs instead. But there are a couple of scenarios where ActorSelection are the right tool for the job and we cover those in more detail here: "When Should I Use ActorSelection."
Dynamic behavior is an advanced concept that we dive into in the beginning of Unit 2, but for now just be aware that the behavior of a given actor can be very flexible. This lets actors easily represent things like Finite State Machines so a small code footprint can easily handle complex situations.
Where does ActorSelection come into play on this? Well, if you want to have a very dynamic and adaptable system, there are probably going to be lots of actors coming and going from the hierarchy and trying to store / pass around handles to all of them would be a real pain. ActorSelection lets you easily just send messages to well known addresses of the key actor(s) you need to communicate with, and not worry about getting/passing/storing handles to the things you need.
You also can build extremely dynamic actors where not even the ActorPath needed to do an ActorSelection is hardcoded, but can instead be represented by a message that is passed into your actor.
Let's run w/ this idea of adaptability, because it's important for your happiness as a developer, the resilience of your system, and the speed at which your organization can move.
Since you don't have to couple everything together to make it work, this will speed up your development cycles. You can introduce new actors and entirely new sections into the actor hierarchy without having to go back and change everything you've already written. Your system has a much more flexible communication structure that can expand and accommodate new actors (and requirements) easily.
In a nutshell: ActorSelection makes your system much more adaptable to change and also enables it to be more powerful.
Petabridge published a detailed post on this subject aptly titled "When Should I Use ActorSelection?" - read that for the long version.
Short version: avoid using ActorSelection if you can, but sometimes it's the only way to get into communication with another actor for which you don't currently have an IActorRef.
We encourage you NOT to pass around ActorSelections as parameters, the way you do IActorRefs. The reason for this is that ActorSelections can be relative instead of absolute, in which case it wouldn't produce the intended effects when passed to an actor with a different location in the hierarchy.
Very simple: var selection = Context.ActorSelection("/path/to/actorName");
NOTE: the path to an actor includes the name you assign to an actor when you instantiate it, NOT its class name. If you don't assign a name to an actor when you create it, the system will auto-generate a unique name for you.
For example:
class FooActor : UntypedActor {}
Props props = Props.Create<FooActor>();
// the ActorPath for myFooActor is "/user/barBazActor"
// NOT "/user/myFooActor" or "/user/FooActor"
IActorRef myFooActor = MyActorSystem.ActorOf(props, "barBazActor");
// if you don't specify a name on creation as below, the system will
// auto generate a name for you, so the actor path will
// be something like "/user/$a"
IActorRef myFooActor = MyActorSystem.ActorOf(props);Nope. You Tell() an ActorSelection a message just the same as an IActorRef:
var selection = Context.ActorSelection("/path/to/actorName");
selection.Tell(message);Alright, let's get to it. This exercise will be short. We are only making some small optimizations to our system.
Right now, our ConsoleReaderActor needs to be given an IActorRef to be able to send the messages it reads from the console off for validation. In the current design, that's easy enough.
BUT, imagine that ConsoleReaderActor was far away in the hierarchy from where the FileValidatorActor instance was created (Program.cs currently). In this case, there is no clean/easy way to pass in the needed IActorRef to ConsoleReaderActor without also passing it through every intermediary first.
Without ActorSelection, you'd have to pass the necessary IActorRef through every object between where the handle is created and used. That is coupling more and more objects together--yuck!
Let's fix that by removing the validationActor IActorRef that we're passing in. The top of ConsoleReaderActor should now look like this:
// ConsoleReaderActor.cs
// note: we don't even need our own constructor anymore!
public const string StartCommand = "start";
public const string ExitCommand = "exit";
protected override void OnReceive(object message)
{
if (message.Equals(StartCommand))
{
DoPrintInstructions();
}
GetAndValidateInput();
}Then, let's update the call for message validation inside ConsoleReaderActor so that the actor doesn't have to hold onto a specific IActorRef and can just forward the message read from the console onto an ActorPath where it knows validation occurs.
// ConsoleReaderActor.GetAndValidateInput
// otherwise, just send the message off for validation
Context.ActorSelection("akka://MyActorSystem/user/validationActor").Tell(message);Finally, let's update consoleReaderProps accordingly in Program.cs since its constructor no longer takes any arguments:
// Program.Main
Props consoleReaderProps = Props.Create<ConsoleReaderActor>();Just as with ConsoleReaderActor and FileValidatorActor, the FileValidatorActor currently requires an IActorRef for the TailCoordinatorActor which it does not need. Let's fix that.
First, remove the tailCoordinatorActor argument to the constructor of FileValidatorActor and remove the accompanying field on the class. The top of FileValidatorActor.cs should now look like this:
// FileValidatorActor.cs
// note that we're no longer storing _tailCoordinatorActor field
private readonly IActorRef _consoleWriterActor;
public FileValidatorActor(IActorRef consoleWriterActor)
{
_consoleWriterActor = consoleWriterActor;
}Then, let's use ActorSelection to communicate between FileValidatorActor and TailCoordinatorActor! Update FileValidatorActor like this:
// FileValidatorActor.cs
// start coordinator
Context.ActorSelection("akka://MyActorSystem/user/tailCoordinatorActor").Tell(
new TailCoordinatorActor.StartTail(msg, _consoleWriterActor));And finally, let's update fileValidatorProps in Program.cs to reflect the different constructor arguments:
// Program.Main
Props fileValidatorActorProps = Props.Create(() =>
new FileValidatorActor(consoleWriterActor));Awesome! It's time to fire this baby up and see it in action.
Just as with the last lesson, you should be able to hit F5 and run your log/text file and see additions to it appear in your console.
Hey, wait, go back! What about that consoleWriterActor passed to FileValidatorActor? Wasn't that unnecessarily coupling actors?
Oh. You're good, you.
We assume you're talking about this IActorRef that is still getting passed into FileValidatorActor:
// FileValidatorActor.cs
private readonly IActorRef _consoleWriterActor;
public FileValidatorActor(IActorRef consoleWriterActor)
{
_consoleWriterActor = consoleWriterActor;
}This one is a little counter-intuitive. Here's the deal.
In this case, we aren't using the handle for consoleWriterActor to talk directly to it. Instead we are putting that IActorRef inside a message that is getting sent somewhere else in the system for processing. When that message is received, the receiving actor will know everything it needs to in order to do its job.
This is actually a good design pattern in the actor model, because it makes the message being passed entirely self-contained and keeps the system as a whole flexible, even if this one actor (FileValidatorActor) needs an IActorRef passed in and is a little coupled.
Think about what is happening in the TailCoordinatorActor which is receiving this message: the job of the TailCoordinatorActor is to manage TailActors which will actually observe and report file changes to... somewhere. We get to specify that somewhere up front.
TailActor should not have the reporting output location written directly into it. The reporting output location is a task-level detail that should be encapsulated as an instruction within the incoming message. In this case, that task is our custom StartTail message, which indeed contains the IActorRef for the previously mentioned consoleWriterActor as the reporterActor.
So, a little counter-intuitively, this pattern actually promotes loose coupling. You'll see it a lot as you go through Akka.NET, especially given the widespread use of the pattern of turning events into messages.
Compare your code to the solution in the Completed folder to see what the instructors included in their samples.
Awesome work! Well done on completing this lesson! We're on the home stretch of Unit 1, and you're doing awesome.
Let's move onto Lesson 6 - The Actor Lifecycle.
Come ask any questions you have, big or small, in this ongoing Bootcamp chat with the Petabridge & Akka.NET teams.
If there is a problem with the code running, or something else that needs to be fixed in this lesson, please create an issue and we'll get right on it. This will benefit everyone going through Bootcamp.