标签:
注:本文章是看blog后的一个阶段小结,只作为个人笔记, 原文链接:http://www.iteblog.com/archives/1154
官网地址贴上:http://doc.akka.io/docs/akka/snapshot/scala/actors.html
什么是akka
akka的actor模式提供了一个写并发和分布式系统的高层次抽象,将程序员从锁和线程管理等问题中解放出来,是一个在JVM上构建高并发、分布式和可快速恢复的消息驱动应用的工具集和运行时,actors 模式是在Carl Hewitt 1973的论文中定义的,最初是在 Erlang 语言中流行,Ericsson用它成功地实现了高并发高可靠的通讯系统。
什么是actor
我们这把Actors当作是一个人,这个人不会自己和其他的人直接说话,他们只通过mail来进行交流。假设有两个人:学生和聪明的老师。学生每天早上都会给老师发送邮件,而聪明的老师都会回复一句名言。这里需要解释:5、学生不会一直等待回信(非阻塞的)
以“消息单向传递”为例说明消息传递的原理
消息传递原理图:
实现上述过程的代码如下:
ActorSystem是进入Actor世界的切入点,通过ActorSystem你可以创建和停止Actors,甚至关掉整个Actor环境!另一方面,Actor是一个体系,ActorSystem类似于java.lang.Object or scala.Any,能够容纳所有的Actor!它是所有的Actor的父类。当你创建一个Actor,你可以用ActorSystem的actorOf方法。
ActorRef 是真实 Actor 的代理,客户端不直接和 Actor 进行通信,而将消息发送给Actor的代理,在此之后消息经过Dispatcher、MailBox到达真实Actor,而后面的这个过程我们在代码中不需要做任何实现 。这是Actor Model中的处理方式,该方式避免直接让问 Actor 或者任何Actor中的任何custom/private方法或者变量。
Dispatcher做一些很有趣的事,Dispatcher仅仅是将message从ActorRef 传递到MailBox中,此外我们还需要知道,Dispatcher 包装了一个 ExecutorService (ForkJoinPool 或者 ThreadPoolExecutor).而MailBox就运行在ExecutorService之上,也就是说MailBox是由Dispatcher来运行的。
每个Actor都有一个MailBox(后面我们将看到一个特殊情况)。在我们之前的模型中,每个Teacher也有一个MailBox。Teacher需要检查MailBox并处理其中的message。MailBox中有个队列并以FIFO方式储存和处理消息。当MailBox的run方法被运行,它将从队列中取出消息,并传递到Actor进行处理,在目标Actor其实是个receive 方法。TeacherActor 是基本的类,并且拥有一系列的quote,很明显,receive 负责匹配各种request,并作出response,代码片段如下:
Receive方法会接受到各种request,首先要做的是匹配到我们的QuoteRequest,然后从quotes中随机去除一个quote,然后构建一个QuoteResponse对象(我们可以通过这种消息发送的方式将quoteRequest发送给发送者,作为request 的 response)
标签:
原文地址:http://www.cnblogs.com/key1309/p/5354724.html