akka actor中的基本概念(学习小结)

注:本文章是看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来进行交流。假设有两个人:学生和聪明的老师。学生每天早上都会给老师发送邮件,而聪明的老师都会回复一句名言。这里需要解释:
  1、学生发送邮件。一旦发送成功,邮件不能再修改。这天然就具备了不可变性;
  2、老师会自己决定何时检查邮箱;
  3、老师还会回复一封邮件(也是不可变的);
  4、学生会自己决定何时检查邮箱;

  5、学生不会一直等待回信(非阻塞的)

以“消息单向传递”为例说明消息传递的原理

消息传递原理图:

实现上述过程的代码如下:

object StudentSimulatorApp extends App{
 
  //Initialize the ActorSystem
  val actorSystem=ActorSystem("UniversityMessageSystem")
 
  //construct the Teacher Actor Ref
  val teacherActorRef=actorSystem.actorOf(Props[TeacherActor])
 
  //send a message to the Teacher Actor
  teacherActorRef!QuoteRequest
 
  //Let‘s wait for a couple of seconds before we shut down the system
  Thread.sleep (2000)
 
  //Shut down the ActorSystem.
  actorSystem.shutdown()
 }

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,代码片段如下:

class TeacherActor extends Actor {
  val quotes = List(
    "Moderation is for cowards",
    "Anything worth doing is worth overdoing",
    "The trouble is you think you have time",
    "You never gonna know if you never even try")
  def receive = {
    case QuoteRequest => {
      import util.Random

//Get a random Quote from the list and construct a response
      val quoteResponse=QuoteResponse(quotes(Random.nextInt(quotes.size)))

println (quoteResponse)
    }
  }
}

Receive方法会接受到各种request,首先要做的是匹配到我们的QuoteRequest,然后从quotes中随机去除一个quote,然后构建一个QuoteResponse对象(我们可以通过这种消息发送的方式将quoteRequest发送给发送者,作为request 的 response)

时间: 2024-11-05 16:04:46

akka actor中的基本概念(学习小结)的相关文章

2014.8.12-AKKA和Actor model 分布式开发环境学习小结

学习使用AKKA 断断续续有一年了.目前还是习惯用java来写akka下面的程序.对于原生的scala还是没有时间和兴趣去学习它. 毕竟学习一门语言需要兴趣和时间的. AKKA学习资源还是不算丰富. 看过最多的就是官方的编程手册,还有就是AKKA Essentials 这两本.  自己动手写的程序还不算多,也放在github上面. 另外,在akka编译配置.升级版本上,以及部署多台服务器组建akka cluster 方面花费了不少时间.因为项目需要,上周重新在办公室用两台mac台式机和一台thi

.net中实现伪静态的学习小结

好久不写博文了,回想起来上一篇博文应该是很久以前写的了.今天写点过去的学习心得——.net中实现伪静态. 比如:类似这样的链接list.aspx?id=1&pid=5,我们并不想在浏览器地址栏中(注意这句话)看到后缀和参数的传递,我们想让他变成list-1-5.html这样的.原理很简单,首先展现给客户点击的部分就写成list-1-5.html或者是其他的静态的.html链接,比如:list/1/5.html或者list_1_5.html等,在前台部分都这样写,浏览器不管你处理的页面,他只知道你

TCL中Expect 交互的学习小结

Expect作为一种重要的TCL扩展包,主要有以下几个命令: spawn用于启动一个进程,之后所有expect操作都在这个进程中进行. 如果没有装expect或者直接在默认的SHELL下执行是找不到spawn命 令的.所以不要用 "which spawn"之类的命令去找spawn命令.    spawn ssh [email protected]    spawn telnet 135.251.193.217 2. expect & exp_send  expect "

WEB前端开发学习小结

[引言] 在经过了将近六个月的学习时间终于对B/S的学习有了一定认识,在这段时间里可以说自己的收获非常的多,从一 个对web开发没有任何基础的小小小菜鸟变为了一个菜鸟,虽然自己现在还是一个菜鸟,但是自己和半年前的自己对 比进步还是巨大的,因为现在的自己至少到了知道"是什么?"的阶段,对已项目中用到的知识还是比较熟悉的(宏 观),在这个过程中也会因为一个错误困扰自己很长时间,因为那是自己对于挑错还是非常不熟悉的,像哪些辅助工 具firebug等都不知道是什么,而现在运用的还算是比较灵活,

MogileFS学习小结

大纲: 一.关于MogileFS 二.常见分布式文件系统 三.MogileFS基本原理 四.MogileFS的实现 一.关于MogileFS 当下我们处在一个互联网飞速发展的信息社会,在海量并发连接的驱动下每天所产生的数据量必然以几何方式增长,随着信息连接方式日益多样化,数据存储的结构也随着发生了变化.在这样的压力下使得人们不得不重新审视大量数据的存储所带来的挑战,例如:数据采集.数据存储.数据搜索.数据共享.数据传输.数据分析.数据可视化等一系列问题. 传统存储在面对海量数据存储表现出的力不从

JavaSE中Collection集合框架学习笔记(2)——拒绝重复内容的Set和支持队列操作的Queue

前言:俗话说“金三银四铜五”,不知道我要在这段时间找工作会不会很艰难.不管了,工作三年之后就当给自己放个暑假. 面试当中Collection(集合)是基础重点.我在网上看了几篇讲Collection的文章,大多都是以罗列记忆点的形式书写的,没有谈论实现细节和逻辑原理.作为个人笔记无可厚非,但是并不利于他人学习.希望能通过这种比较“费劲”的讲解,帮助我自己.也帮助读者们更好地学习Java.掌握Java. 无论你跟我一样需要应聘,还是说在校学生学习Java基础,都对入门和进一步启发学习有所帮助.(关

自动化测试Selenium Webdriver (JAVA)学习小结

自动化测试--Selenium学习小结 一.自动化测试的概念及意义: 1.什么是自动化测试: 一般是指软件测试的自动化,软件测试就是在预设条件下运行系统或应用程序,评估运行结果,预先条件应包括正常条件和异常条件. 2.意义: 让测试更有效率,利用更多的空余时间,减少人力资源. 二.selenium工具 我用的是java语言,所以接下来的例子和方法都是基于java的. 1.环境配置 (1)Jdk的配置: 我用的是1.7的jdk,配置方法都一样,新建一个JAVA_HOME,把你装好的jdk的路径复制

pthread多线程编程的学习小结

pthread多线程编程的学习小结 程序员必上的开发者服务平台 —— DevStore pthread多线程编程整理 1 Introduction 不用介绍了吧… 2 Thread Concepts 1.     Thread由下面部分组成: a.     Thread ID b.     Stack c.     Policy d.     Signal mask e.     Errno f.      Thread-Specific Data 3 Thread Identification

PowerShell_零基础自学课程_5_自定义PowerShell环境及Powershell中的基本概念

PowerShell_零基础自学课程_5_自定义PowerShell环境及Powershell中的基本概念 据我个人所知,windows下的cmd shell除了能够通过修改系统参数来对其中的环境变量进行改变外,其环境的可自定义性相对来说很困难,而在Linux环境中,可以通过修改/etc目录下的某些配置文件来达到配置shell环境的目的.也许这也是某些人诟病cmd shell功能不强的原因之一. 而目前这种状况在windows powershell中得到了改善,可以说PS中提供的自定义环境的功能