Actors编程模型

　　Actors模型(Actor model)首先是由Carl Hewitt在1973定义， 由Erlang OTP (Open Telecom Platform) 推广，其 消息传递更加符合面向对象的原始意图。 Actors属于并发组件模型 ，经过组件方式定义并发编程范式的高级阶段，避免使用者直接接触多线程并发或线程池等基础概念。

　　 传统多数流行的语言并发是基于多线程之间的共享内存，使用同步方法防止写争夺，Actors使用消息模型，每一个Actors在同一时间处理最多一个消息，能够发送消息给其余Actors，保证了单独写原则 。从而巧妙避免了多线程写争夺。

　　 Actors模型的特色是：

• 隔离计算实体
• "Share nothing"
• 没有任何地方同步
• 异步消息传递
• 不可变的消息 消息模型相似mailbox / queue

　　 AKKA框架是一个实现Actors模型的Scala或Java平台，灵感来自ERlang，能更轻松地开发可扩展，实现多线程安全应用。

　　Actors是一个轻量级的对象，经过发送消息实现交互。每一个Actors在同一时间处理最多一个消息，能够发送消息给其余Actors。在同一时间能够于一个Java虚拟机存在数以百万计的参与者，构架是一个分层的父层（管理） - 子层，其中父层监控子层的行为。还能够很容易地扩展Actor运行在集群中各个节点之间 - 无需修改一行代码。每一个演员均可以有内部状态（字段/变量） ，但通讯只能经过消息传递，不会有共享数据结构（计数器，队列） 。Akka框架支持两种语言Java和Scala，

 

WhatsApp成功背后的Erlang语言

Actor模型和CSP模型的区别

高级并发：Akka Actors和JavaEE7的EJB比较

Akka教程

AKKA框架介绍

使用Akka发送1000万消息

使用Akka实现MapReduce的单词计数

Akka+ZeroMQ消息生产者和消费者

软件事务内存STM

RXJAVA的Observable和AKKA ACTOR综合使用

为何Actor模型是高并发事务的终极解决方案？

actor并发模型&基于共享内存线程模型

Spray + Akka高性能异步IO并发

使用Scala的Akka HTTP,Akka Stream和Reactive Mongo创建REST服务

单独写原则

LMAX架构

go reactive宣言

Scala入门之函数编程

Scala入门之基本概念

vertx入门教程

使用Kafka和ZeroMQ实现分布式Quasar Actor

 

相关参考

Actors模型更多专题

AKKA更多专题

reactive编程

Scala专题

Disruptor专题

并发编程

性能专题

EDA事件驱动专题

 

 

过去十几年CPU一直遵循着摩尔定律发展，单核频率愈来愈快，可是最近这几年，摩尔定律已然失效，CPU的工艺制程和发热稳定性之间难以取舍，取而代之的策略则是增长核心数量，目前家用电脑四核已经很是常见，服务器更是达到了32核64线程。为了有效地利用多核CPU，咱们在代码层面就应该考虑到并发性。十几年的痛苦开发经历告诉咱们，threads并非获取并发性的好方法，每每会带来难以查找的bug，可是不用惧怕，今天咱们有不少其余方法来得到易用的并发性，好比咱们接下来介绍的Actor模型。

模型 Model

Actor模型是一个概念模型，用于处理并发计算。它定义了一系列系统组件应该如何动做和交互的通用规则，最著名的使用这套规则的编程语言是Erlang。这篇文章更关注模型自己而不是它在不一样语言的实现。

Actors

一个Actor指的是一个最基本的计算单元。它能接收一个消息而且基于其执行计算。

这个理念很像面向对象语言，一个对象接收一条消息（方法调用），而后根据接收的消息作事（调用了哪一个方法）。

Actors一大重要特征在于actors之间相互隔离，它们并不互相共享内存。这点区别于上述的对象。也就是说，一个actor能维持一个私有的状态，而且这个状态不可能被另外一个actor所改变。

积少成多

One ant is no ant, one actor is no actor.
光有一个actor是不够的，多个actors才能组成系统。在actor模型里每一个actor都有地址，因此它们才可以相互发送消息。

Actors有邮箱

只得指明的一点是，尽管许多actors同时运行，可是一个actor只能顺序地处理消息。也就是说其它actors发送了三条消息给一个actor，这个actor只能一次处理一条。因此若是你要并行处理3条消息，你须要把这条消息发给3个actors。

消息异步地传送到actor，因此当actor正在处理消息时，新来的消息应该存储到别的地方。Mailbox就是这些消息存储的地方。

 

Actors经过异步消息沟通，在处理消息以前消息被存放在Mailbox中

Actors作什么

当一个actor接收到消息后，它能作以下三件事中的一件：

• Create more actors; 建立其余actors
• Send messages to other actors; 向其余actors发送消息
• Designates what to do with the next message. 指定下一条消息到来的行为

前两件事比较直观，第三件却颇有意思。

我以前说过一个actor能维持一个私有状态。「指定下一条消息来到作什么」意味着能够定义下条消息来到时的状态。更清楚地说，就是actors如何修改状态。

设想有一个actor像计算器，它的初始状态是数字0。当这个actor接收到add(1)消息时，它并不改变它本来的状态，而是指定当它接收到下一个消息时，状态会变为1。

容错 Fault tolerance

Erlang 引入了「随它崩溃」的哲学理念，这部分关键代码被监控着，监控者的惟一职责是知道代码崩溃后干什么（如将这个单元代码重置为正常状态），让这种理念成为可能的正是actor模型。

每段代码都运行在process中，process是erlang称呼actor的方式。这个process彻底独立，意味着它的状态不会影响其余process。咱们有个supervisor，实际上它只是另外一个process（全部东西都是actor），当被监控的process挂了，supervisor这个process会被通知并对此进行处理。这就让咱们能建立「自愈」系统了。若是一个actor到达异常状态并崩溃，不管如何，supervisor均可以作出反应并尝试把它变成一致状态，这里有不少策略，最多见的是根据初始状态重启actor。

分布式 Distribution

另外一个关于actor模型的有趣方面是它并不在乎消息发送到的actor是本地的或者是另外节点上的。

转念一想，若是actor只是一些代码，包含了一个mailbox和一个内部状态，actor只对消息作出响应，谁会关注它运行在哪一个机器上呢？只要咱们能让消息到达就好了。这容许咱们基于许多计算机上构建系统，而且恢复其中任何一台。

进一步了解

这里是一个快速的概念模型回顾，其中的概念被运用到许多知名语言和库中，好比Erlang和Elixir， Akka (for the JVM) 和 Celluloid (for Ruby)。

若是你想更深刻了解actor及其背后的原理，你能够进一步阅读下面书籍和文章：

• Seven Concurrency Models in Seven Weeks: When Threads Unravel
• Programming Elixir
• Elixir in Action
• Actor模型
• 为何Actor模型是高并发事务的终极解决方案？

这个视频比较完整地讨论了Actor的概念模型。
The Actor Model (everything you wanted to know)

Scala或Erlang的进程信箱都是一种Actor模型，也有Java的专门的Actor模型，这里是几种Actor模型比较明白了Actor模型原理，使用Disruptor这样无锁队列也能够本身实现Actor模型，让一个普通对象与外界的交互调用经过Disruptor消息队列实现，好比LMAX架构就是这样实现高频交易，从2009年成功运行至今，被Martin Fowler推崇。

原文地址： http://www.brianstorti.com/the-actor-model/

做者：时见疏星连接：https://www.jianshu.com/p/449850aa8e82來源：简书著做权归做者全部。商业转载请联系做者得到受权，非商业转载请注明出处。