第102讲:通过案例解析Akka中的Actor运行机制以及Actor的生命周期学习笔记
Actor是构建akka程序的核心基石,akka中actor提供了构建可伸缩的,容错的,分布式的应用程序的基本抽象,
actor是异步的,非阻塞式的,事件驱动的轻量级的模型,
actor中都有自己的成员,也有receive方法,在receive中处理具体的逻辑。
actor间沟通只能通过发消息。
!发消息是异步的过程,MasterActor只会对自己的邮箱感兴趣,不断循环自己的邮箱,
收到消息后进行处理。
在actor内部创建其他actor是通过ActorSystem.ActorOf(Props[MasterActor])
创建出工作的actor后,actor就进入start状态,开始查看邮箱中是否有邮件,
有邮件时就处理邮件,直到收到停止的指令。
Actor的生命周期:
1)初始化:preStart
2)接收消息、处理消息。用模式匹配的方式匹配到消息就处理
3)stop处理消息进行清理工作。
为什么会出现preRestart/postRestart呢?
如actor崩溃了(exception),被supervisor重新启动时,preRestart/postRestart就会被调用,进行状态恢复
创建actor有多种方式,如ActorSystem,接下来讲解其他方式。
以上内容是从王家林老师DT大数据课程第102讲的学习笔记。
DT大数据微信公众账号:DT_Spark
王家林老师QQ:1740415547
王家林老师微信号:18610086859
DT大数据梦工厂1至103集scala的所有视频、PPT和代码在百度云盘的链接:http://pan.baidu.com/share/home?uk=4013289088#category/type=0&qq-pf-to=pcqq.group
第102讲视频网站地址:
酷6网 |
http://v.ku6.com/show/kua2BKQLuJco4OrTl3nHpQ...html?from=my |
优酷 |
http://v.youku.com/v_show/id_XMTMzNTg1OTEwMA==.html |