actor简介及应用

《actor简介及应用》由会员上传分享，免费在线阅读，更多相关内容在行业资料-天天文库。

1、Actor简介&实战张波bo.zhang86@gmail.comActor是什么TheActormodelincomputerscienceisamathematicalmodelofconcurrentcomputationthattreats"actors"astheuniversalprimitivesofconcurrentdigitalcomputation:inresponsetoamessagethatitreceives,anactorcanmakelocaldecisions,createmoreactors,sendmoremessages,anddetermineho

2、wtorespondtothenextmessagereceivedActor是什么nActor模型在并发编程中是比较常见的一种模型。很多开发语言都提供了原生的Actor模型。例如erlang,scala等nActor，可以看作是一个个独立的实体，他们之间是毫无关联的。但是，他们可以通过消息来通信。一个Actor收到其他Actor的信息后，它可以根据需要作出各种相应。消息的类型可以是任意的，消息的内容也可以是任意的。n一个Actor如何处理多个Actor的请求呢？它先建立一个消息队列，每次收到消息后，就放入队列，而它每次也从队列中取出消息体来处理。通常我们都使得这个过程是循环的。让Actor

3、可以时刻处理发送来的消息。nActor在很多语言实现中（scala，erlang等），都以轻量级进程的形式存在，简单的说，一个actor就是一个执行上下文，绑定了actor的相关数据，实际运行时被调度到真正vm线程中运行。Actor是什么Erlang 例子Akka 例子Scala 例子Pid = val helloActor = spawn(Mod,func,Args) %val pong = new Pongsystem.actorOf(Props[Hell起一个进程oActor])class Pong extends Actor {func()‐>    def act(

4、) {class HelloActor extends     receive        case Ping  // loop & Actor {        {From,Msg}‐> %收到react    def receive = {一个消息            // do something        case “hello” =>            %% do something            // do somethingpong ! PingPid ! {From,Msg}helloActor ! “hello”Actor特性轻量级进程（非操作

5、系统线程），占用资源非常少，创建速度快erlang:309字，其中233为堆空间，耗时1~3微秒akka:1GB2.5millionactors，50millionmsg/sec分布式计算抽象，把任务切分到细粒度，并发完成任务沟通基于消息，避免锁的问题进程完全隔离......Actor组件actor(msg处理，容错)调度器(Scheduler/Dispatcher)执行线程邮箱(Mailbox)路由(Routing)Actor实现Scala：在java基础上增加了一些语法糖Akka：重写actor实现，替换scalaactor，类似erlangOTPErlang

6、：比java更早，语言级别支持actorErlangOTP：支持分布式，容错，并发等的一套框架Go：发展迅猛，目前以协程模拟actorClojure：跑在jvm上，提倡函数式编程Akka基于Scalaactorlibrary&framework很容易编写支持并发和分布式的代码性能非常棒（重写Scalaactor和调度器，以及所有操作基于事件）监控树体系扩展不错，并有不少扩展包去中心化架构一般通过配置来完成负载，路由，远程actor访问等，类似于注册表erlang也基本这样，封装更全，网络程序通常基于dnsAkkaActor例子AkkaSupervisor例子Ak

7、ka中每个parentactor都是子actor的supervisor应用Scala应用案例：LinkedinFacebooktwitter国外比较火热，国内使用较少专题：监控树相关actor，以树形结构组织，supervisor监控actor，当发生“异常”时，supervisor对事件进行处理supervisor有对事件处理的策略，常用有allforone&oneforonesupervi