Akka Actor介绍和用法详解

【Akka Actor介绍和用法详解】参与者是通过消息传递与其他参与者进行通信的实体。Actor有自己的状态和行为。就像在面向对象的编程中一样, 所有事物都是对象, 就像在基于角色的系统中一切都是角色一样。
换句话说, 我们可以说参与者是封装状态和行为的对象。
如何创建Actor?你可以通过扩展Actor特性并实现它的receive方法来创建actor。参与者每次收到消息时都会调用此方法。 receive方法对接收到的消息进行模式匹配, 然后决定要做什么。
在这里, 我们创建了一个简单的” Hello Akka” 程序。
你好Akka示例

import akka.actor.Actor; // Importing actor trait import akka.actor.ActorSystem; import akka.actor.Props; class HelloAkka extends Actor{// Extending actor trait def receive = {//Receiving message case msg:String => println(msg) case _ => println("Unknown message")// Default case } }object Main{ def main(args:Array[String]){ var actorSystem = ActorSystem("ActorSystem"); // Creating ActorSystem var actor = actorSystem.actorOf(Props[HelloAkka], "HelloAkka")//Creating actor actor ! "Hello Akka"// Sending messages by using ! actor ! 100.52 } }

输出
Hello Akka Unknown message

在上面的示例中, 我们通过扩展Actor特质并覆盖接收方法来创建actor” HelloAkka” 。你必须为所有收到的邮件提供区分大小写。以防万一, 如果有未知消息, 你需要像上例一样提供默认大小写。

    推荐阅读