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

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

---

核心内容:
1、Akka中的第二种消息发送方式以及Future使用代码实战详解

---

1、Akka中的第二种消息发送方式以及Future使用代码实战详解

1>this.getSender().tell(“message having received!”,this.getSelf());的具体的含义：
this.getSender()返回的是一个ActorRef的句柄，指向消息的发送者。 （如main方法所在的Actor）
this.getSelf()指向的是消息自身的发送者。(如Worker所在的Actor)
2>Patterns的三个参数:第一个参数是给哪个Actor发送消息、第二个参数是发送什么样的消息、第三个参数是超时时间
Future future = Patterns.ask(worker, “Spark and Hadoop scala and Java”, timeout);
3>我们常用future实例对象来接受对方Actor发送过来的结果，并且future接受到具体消息之后，可以用future提取出相应的结果。
4>Future对象其实是Java中后来推出的，在线程结束之后接受另外一个线程结果的一个对象。
5>TimeOut：等待对方Actor返回结果给future的超时时间。

---

实例程序1:

package com.test.scala.app;

import akka.actor.Ac