欢迎关注Hadoop、Spark、Flink、Hive、Hbase、Flume等大数据资料分享微信公共账号:iteblog_hadoop
  1. 文章总数:977
  2. 浏览总数:11,937,915
  3. 评论:3936
  4. 分类目录:106 个
  5. 注册用户数:6110
  6. 最后更新:2018年12月13日
过往记忆博客公众号iteblog_hadoop
欢迎关注微信公众号:
iteblog_hadoop
大数据技术博客公众号bigdata_ai
大数据猿:
bigdata_ai

Akka学习笔记:Actor消息处理-请求和响应(1)

  在前面的文章《Akka学习笔记:Actor消息传递(1)》《Akka学习笔记:Actor消息传递(2)》。我们仅仅将消息发送到Actor,并没有期待从Actor发来的响应。
  从技术上讲,我们给Actor发送消息,除了没有响应,目标的Actor将对这条消息进行如下操作:
  1、给发送者发送一个响应,在我们的例子中,TeacherActor将发送一个quote 到StudentActor作为响应。或者
  2、给其他的Actor响应,而这个Actor可能也会作出响应或者转发等。Routers和Supervisors就是这个例子,我们将在后面看到。

请求和响应

  这里我们只研究场景1


如果想及时了解Spark、Hadoop或者Hbase相关的文章,欢迎关注微信公共帐号:iteblog_hadoop

  上图传达了我们此刻想表达的意思。为了简单,我没有在图中画出ActorSystem、Dispatcher 和Mailboxes。
  1、DriverApp个StudentActor发送了一个InitSignal消息;
  2、StudentActor对InitSignal消息作出反应,并且发送了QuoteRequest 消息给TeacherActor;
  3、TeacherActor用QuoteResponse作出了响应;
  4、StudentActor仅仅将QuoteResponse 作为日志打印到控制台/logger。
  我们将在testcase中进行确认。让我们先来看看上面4点:

一、DriverApp个StudentActor发送了一个InitSignal消息


如果想及时了解Spark、Hadoop或者Hbase相关的文章,欢迎关注微信公共帐号:iteblog_hadoop

  到现在为止,你可能已经猜到了DriverApp将要做的事,仅仅4件事
  1)、初始化ActorSystem

//Initialize the ActorSystem
  val system = ActorSystem("UniversityMessageSystem")

  2)、创建TeacherActor

//create the teacher actor
  val teacherRef = system.actorOf(Props[TeacherActor], "teacherActor")

  3)、创建StudentActor

//create the Student Actor - pass the teacher actorref 
//as a constructor parameter to StudentActor
  val studentRef = system.actorOf(Props(new StudentActor(teacherRef)), "studentActor")

  你可能注意到,我用TeacherActor 作为StudentActor构造参数,并传入到ActorRef 中,这样StudentActor 将可以用ActorRef发送消息到TeacherActor。还有其他的方法可以实现类似的功能(比如利用Props),但是当我们想查看 Supervisors 和Routers的时候,这个方法很方便。我们很快看到一个自Actors,但是在这里的语义不对:Student创建Teacher听起来很不好。不是吗?
  4)、最后,DriverApp将给StudentActor发送InitSignal。所以StudentActor可以给TeacherActor发送QuoteRequest 消息。

//send a message to the Student Actor
  studentRef ! InitSignal

  这就是DriverClass所做的。完整的代码如下

package me.rerun.akkanotes.messaging.requestresponse

import akka.actor.ActorSystem  
import akka.actor.Props  
import me.rerun.akkanotes.messaging.protocols.StudentProtocol._  
import akka.actor.ActorRef

object DriverApp extends App {

  //Initialize the ActorSystem
  val system = ActorSystem("UniversityMessageSystem")

  //construct the teacher actor
  val teacherRef = system.actorOf(Props[TeacherActor], "teacherActor")

  //construct the Student Actor - pass the teacher actorref
 // as a constructor parameter to StudentActor
  val studentRef = system.actorOf(Props(new StudentActor(teacherRef)), "studentActor")

  //send a message to the Student Actor
  studentRef ! InitSignal

  //Let's wait for a couple of seconds before we shut down the system
  Thread.sleep(2000)

  //Shut down the ActorSystem. 
  system.shutdown()

}

本文英文地址:http://rerun.me/2014/10/06/akka-notes-actor-messaging-request-and-response-3/

本博客文章除特别声明,全部都是原创!
转载本文请加上:转载自过往记忆(https://www.iteblog.com/)
本文链接: 【Akka学习笔记:Actor消息处理-请求和响应(1)】(https://www.iteblog.com/archives/1161.html)
喜欢 (5)
分享 (0)
发表我的评论
取消评论

表情
本博客评论系统带有自动识别垃圾评论功能,请写一些有意义的评论,谢谢!
(6)个小伙伴在吐槽
  1. 比如:DriverApp个StudentActor发送了一个InitSignal消息
    eclipse_spring2015-01-07 20:20 回复
  2. 楼主,此文有语句不通顺的地方啊
    eclipse_spring2015-01-07 20:20 回复