Akka Actor Communication

In Akka, actors communicate to each other by sending and receiving messages.

Akka Actor Send Messages

Akka provides two predefined methods tell() and ask() for message exchange. An actor can send messages to another Actor through these following methods.

1) Akka Actor tell() Method

It is used to send a message asynchronously. It does not wait and block thread for a message. It works on “fire-forget” approach. You can also use ! (bang) exclamation mark to send message. This is the preferred way of sending messages. It gives the best concurrency and scalability characteristics.

If this method is invoked from within an Actor, the sending actor reference will be implicitly passed along with the message.

If this method is invoked from an instance that is not an Actor, the sender will be deadLetters actor reference by default.

Actor tell() Method Example

 import akka.actor.{Actor,ActorSystem, Props};  class ActorExample extends Actor{   def receive = {     case message:String => println(“Message received: “+message+ ” from – “+ self.path.name);      println(“sender:”+ sender());  // returns ActorRef   } }  object ActorExample{   def main(args:Array[String]){     val actorSystem = ActorSystem(“ActorSystem”);     val actor = actorSystem.actorOf(Props[ActorExample], “RootActor”);     actor ! “Hello”             // Sending message by using !     actor.tell(“Hello”,null);  // Sending message by using tell() method // Sender is not passed here.   } } 

Output:

Message received: Hello from - RootActor sender:Actor[akka://ActorSystem/deadLetters]  // ActorRef refers to deadLetters Message received: Hello from - RootActor sender:Actor[akka://ActorSystem/deadLetters] // ActorRef refers to deadLetters

Akka Actor tell() Method Example2

 import akka.actor.{Actor,ActorSystem, Props};  class ActorExample extends Actor{   def receive = {     case message:String => println(“Message received: “+message+ ” from – “+ self.path.name);     println(“Sender: “+sender())     var child = context.actorOf(Props[Actor2], “ChildActor”);     child ! “Hello”                 } }  class Actor2 extends Actor{   def receive = {     case message:String => println(“Message received: “+message+ ” from – “+ self.path.name);     println(“Sender: “+sender());   } }  object ActorExample{   def main(args:Array[String]){     val actorSystem = ActorSystem(“ActorSystem”);     val actor = actorSystem.actorOf(Props[ActorExample], “RootActor”);     actor ! “Hello”   } } 

Output:

Message received: Hello from - RootActor Sender: Actor[akka://ActorSystem/deadLetters]// Called from outside Actor Message received: Hello from - ChildActor Sender: Actor[akka://ActorSystem/user/RootActor#1451914889]// Called from within Actor

2) Akka Actor ask Method

In akka, ask is a pattern and involves Actors as well as Futures. Ask is used to sends a message asynchronously and it returns a Future which represents a possible reply. If the actor does not reply and complete the future, it will expire after the timeout period. After timeout period, it throws an TimeoutException. You can use either ? (question mark) or ask() to send message.

You should always prefer tell method for performance and ask method, if you want response.

Akka Actor ask Method Example

 import akka.actor.{Actor,ActorSystem, Props}; import akka.util.Timeout; import scala.concurrent.Await import akka.pattern.ask import scala.concurrent.duration._  class ActorExample extends Actor{   def receive = {     case message:String => println(“Message recieved: “+message);   } }  object ActorExample{   def main(args:Array[String]){     val actorSystem = ActorSystem(“ActorSystem”);     val actor = actorSystem.actorOf(Props[ActorExample], “RootActor”);     implicit val timeout = Timeout(2 seconds);     val future = actor ? “Hello”;     val result = Await.result(future, timeout.duration);     println(result);   } } 

Output:

Message recieved: Hello Exception in thread "main" java.util.concurrent.TimeoutException: Futures timed out after [2 seconds]

Akka Actor ask() Method Example2

 import akka.actor.{Actor,ActorSystem, Props, ActorRef}; import akka.util.Timeout; import scala.concurrent.Await import akka.pattern.ask import scala.concurrent.duration._  class ActorExample extends Actor{   def receive = {     case message:String => println(“Message received: “+message+” from outside actor instance”);     println(“Replaying”);     val senderName = sender();     senderName ! “Hello, I got your message.”; // Replying message   } }  object ActorExample{   def main(args:Array[String]){     val actorSystem = ActorSystem(“ActorSystem”);     val actor = actorSystem.actorOf(Props[ActorExample], “RootActor”);     implicit val timeout = Timeout(10 seconds);     val future = actor ? “Hello”;     val result = Await.result(future, timeout.duration);     println(“Message received: “+result);   } } 

Output:

Message received: Hello from outside actor instance Replaying Message received: Hello, I got your message.

Akka Actor Ask Method Example3

 import akka.actor.{Actor,ActorSystem, Props}; import akka.util.Timeout; import scala.concurrent.Await import akka.pattern.ask import scala.concurrent.duration._  class ActorExample extends Actor{   def receive = {     case message:String => println(“Message received: “+message+” from outside actor instance”);     Thread.sleep(5000);      // actor thread is sleeping      println(“Replaying”);     val senderName = sender();     senderName ! “Hello, I got your message.”; // Replying message   } }  object ActorExample{   def main(args:Array[String]){     val actorSystem = ActorSystem(“ActorSystem”);     val actor = actorSystem.actorOf(Props[ActorExample], “RootActor”);     implicit val timeout = Timeout(2 seconds);     val future = actor ? “Hello”;     val result = Await.result(future, timeout.duration);     println(“Message received: “+result);   } } 

Output:

Message received: Hello from outside actor instance Exception in thread "main" java.util.concurrent.TimeoutException: Futures timed out after [2 seconds]

Next TopicAkka Actor Reply Messages

Akka Actor Send Messages

Akka Actor Communication

Akka Actor Send Messages

1) Akka Actor tell() Method

Actor tell() Method Example

Akka Actor tell() Method Example2

2) Akka Actor ask Method

Akka Actor ask Method Example

Akka Actor ask() Method Example2

Akka Actor Ask Method Example3

Verbal Reasoning | Verification of the Truth of the Statement 3

Attribute in Servlet

You may also like