【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” 。你必须为所有收到的邮件提供区分大小写。以防万一, 如果有未知消息, 你需要像上例一样提供默认大小写。
推荐阅读
- Akka Actor回复消息示例详解
- Akka Actor转发消息示例
- Scala特性混合用法示例
- Scala字符串介绍和用法示例
- Scala特质介绍和用法示例
- Scala多维数组
- Scala final关键字用法示例
- Scala数组介绍和用法
- Scala访问修饰符用法实例