个性化阅读
专注于IT技术分析

Akka Actor转发消息示例

你可以将消息从一个演员转发给另一个演员。在这种情况下, 即使消息正在通过”调解者”, 也将维护Actor的地址/引用。

在编写充当路由器, 负载平衡器, 复制器等的角色时很有用。


Akka演员转发消息示例

import akka.actor.{Actor, ActorSystem, Props};

class ActorExample extends Actor{
  def receive = {
    case message:String => println("Message received from "+sender().path.name+" : "+message);
    val child = context.actorOf(Props[Actor2], "ChildActor");
    println("message forwarded to child Actor");  
    child ! message ;    // Message forwarded to child actor 

    case _ => println("Unknown message");
  }
}

class Actor2 extends Actor{
  def receive ={
    case message:String => println("Message received from "+sender().path.name+" : "+message);
    case _ => println("Unknown message");
  }
}


object ActorExample{
  def main(args:Array[String]){
    val actorSystem = ActorSystem("ActorSystem");
    val actor = actorSystem.actorOf(Props[ActorExample], "RootActor");
    actor ! "Hello"
  }
}

输出

Message received from deadLetters : Hello
message forwarded to child Actor
Message received from RootActor : Hello
赞(0) 打赏
未经允许不得转载:srcmini » Akka Actor转发消息示例
分享到: 更多 (0)

评论 抢沙发

评论前必须登录!

 

觉得文章有用就打赏一下文章作者

微信扫一扫打赏