Akka并发编程——第三节:Actor模型(二)

  • 时间:
  • 浏览:0
  • 来源:大发5分排列3_大发5分排列3官方

发送的这条消息只有 被处置,只有 任何的处置逻辑。在实际开发过程中,可能会对只有被处置的消息增加或者 应对逻辑,此时可不须要重写unhandled土依据,代码如下:

unhandled土依据用于处置只有 被receive土依据处置的消息,下面的代码给出的是当不重写unhandled土依据时的代码

代码输出结果:

中使用

停止MyActor的运行。在使用代码

整体代码如下:

中分别对postStop、preStart土依据进行了重写,在preStart土依据中通过代码

对成员变量child进行初始化,或者 在postStop土依据中使用

在执行

Scala学习(公众微信号:ScalaLearning)每天为亲戚亲戚其他同学带来或者 Scala语言、Spark、Kafka、Flink、AKKA等大数据技术干货及相关技术资讯。技术永无止境,勇攀高峰,一往直前!

我我觉得文章不错?扫描关注

其它如preRestart等土依据的使用将在Akka容错每段进行讲解。

没有看出,对于

本节主要内容:

向自身发送了一条消息,receive土依据通过

对这条消息进行处置。receive土依据在处置

在代码

Actor中的主要成员变量和土依据定义如下:

代码输出:

或者 在创建MyActor时执行MyActor中定义的preStart土依据

代码运行结果:

运行结果:

“test”消息时,会调用

FirstActor作为MyActor的Supervisor,会先停止MyActor,再停止自身,或者 先调用MyActor的postStop土依据,再调用FirstActor的postStop土依据。

处置消息时又向MyActor回送该消息,或者 最终的输出有六个 unknown message,分别对应123和”message from MyActor”

创建FirstActor时,便会调用preStart土依据完成MyActor的创建,或者 首先会执行FirstActor中的preStart()土依据

代码:

向sender(本例中为FirstActor)发送”message from MyActor”消息,FirstActor使用