第102讲:通过案例解析Akka中的Actor运行机制以及Actor的生命周期学习笔记

时间:2020-12-31 14:42:25

102讲:通过案例解析Akka中的Actor运行机制以及Actor的生命周期学习笔记

Actor是构建akka程序的核心基石,akkaactor提供了构建可伸缩的,容错的,分布式的应用程序的基本抽象,

actor是异步的,非阻塞式的,事件驱动的轻量级的模型,

 

actor中都有自己的成员,也有receive方法,在receive中处理具体的逻辑。

 

actor间沟通只能通过发消息。

!发消息是异步的过程,MasterActor只会对自己的邮箱感兴趣,不断循环自己的邮箱,

收到消息后进行处理。

 

actor内部创建其他actor是通过ActorSystem.ActorOf(Props[MasterActor])

创建出工作的actor后,actor就进入start状态,开始查看邮箱中是否有邮件,

有邮件时就处理邮件,直到收到停止的指令。

 

Actor的生命周期:

1)初始化:preStart

2)接收消息、处理消息。用模式匹配的方式匹配到消息就处理

3stop处理消息进行清理工作。

 

为什么会出现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