大数据系列修炼-Scala课程102

阳凌
2023-12-01

大数据系列修炼-Scala课程102


核心内容:
1、通过案例解析Akka中的Actor运行机制以及Actor的生命周期


1、通过案例解析Akka中的Actor运行机制以及Actor的生命周期

1、Akka的生命周期从总体上而言分为3个部分:
1>Actor自身资源的初始化工作(prestart),在prestart方法中可以完成资源的初始化工作。类似于MapReduce中的setup方法。
2>Actor通过receive方法接受消息并进行消息的模式匹配处理。类似于MapReduce中的Map与reduce阶段。
3>进入stop后,停止对消息的处理,进行资源的清理工作。类似于MapReduce中的cleanup阶段。

2、Actor之间是通过发消息的方式来进行沟通的,而一个Actor之所以能够给另外一个Actor发送消息,是因为握住了另外一个Actor邮箱的句柄,
而从Akka的角度讲,则为Address的地址。

3、一个Actor想让另外一个Actor做事情或者改变另外一个Actor的状态,只有通过发消息的方式。

4、Actor是构建Akka程序的核心基石,在Akka中,通过Actor可以帮我们构建可伸缩的、可分布式的、以及容错的应用程序。
Actor是异步的,非阻塞的,即Actor发送消息的过程是一个Synchronized的过程。


实例程序1:Actor通过receive偏函数不断循环自己的邮箱,并进行消息的匹配处理。

  override  
 类似资料: