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

  • 时间:
  • 浏览:0

中使用

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

代码:

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

我虽然文章不错?扫描关注

发送的这条消息这样被处置,这样任何的处置逻辑。在实际开发过程中,可能性会对不到被处置的消息增加一些应对逻辑,此时要能重写unhandled妙招,代码如下:

太难看出,对于

Actor中的主要成员变量和妙招定义如下:

时候 在创建MyActor时执行MyActor中定义的preStart妙招

整体代码如下:

FirstActor作为MyActor的Supervisor,会先停止MyActor,再停止自身,时候 先调用MyActor的postStop妙招,再调用FirstActor的postStop妙招。

代码运行结果:

在执行

对这条消息进行处置。receive妙招在处置

unhandled妙招用于处置这样被receive妙招处置的消息,下面的代码给出的是当不重写unhandled妙招时的代码

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

代码输出:

其它如preRestart等妙招的使用将在Akka容错次要进行讲解。

中分别对postStop、preStart妙招进行了重写,在preStart妙招中通过代码

运行结果:

“test”消息时,会调用

代码输出结果:

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

向自身发送了一根绳子 消息,receive妙招通过

创建FirstActor时,便会调用preStart妙招完成MyActor的创建,时候 首先会执行FirstActor中的preStart()妙招

在代码

本节主要内容:

对成员变量child进行初始化,时候 在postStop妙招中使用