You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Akka支持可扩展的实时事务处理。我们相信编写出正确的、具有容错性和可扩展性的并发程序太困难了。这多数是因为使用了错误的工具和错误的抽象级别。Akka就是为了改变这种状况而生的。通过使用Actor模型提升了抽象级别,为构建可扩展的、有弹性的响应式并发应用提供了一个更好的平台,详见响应式宣言。在容错性方面Akka采用了“let it crash”(让它崩溃)模型,该模型已经在电信行业构建出“自愈合”的应用和永不停机的系统,取得了巨大成功。Actor还为透明的分布式系统以及真正的可扩展高容错应用的基础进行了抽象。
Actor 模型背景
Actor 模型(Actor model)首先是由Carl Hewitt在1973定义, 由Erlang OTP(Open Telecom Platform)推广,其消息传递更加符合面向对象的原始意图。Actors属于并发组件模型,通过组件方式定义并发编程范式的高级阶段,避免使用者直接接触多线程并发或线程池等基础概念。
流行语言并发是基于多线程之间的共享内存,使用同步方法防止写争夺,Actors使用消息模型,每个Actors在同一时间处理最多一个消息,可以发送消息给其他Actors,保证了单独写原则。从而巧妙避免了多线程写争夺。
Actor 模型特点
AKKA框架是一个实现Actors模型的平台,灵感来自Erlang,能更轻松地开发可扩展,实现多线程安全应用。支持Java和Scala。
Actors是一个轻量级的对象,通过发送消息实现交互。每个Actors在同一时间处理最多一个消息,可以发送消息给其他Actors。在同一时间可以于一个Java虚拟机存在数以百万计的参与者,架构是一个父子层结构,其中父层监控子层的行为。还可以很容易地扩展Actor运行在集群中各个节点之间,无需修改代码。每个演员都可以有内部状态(字段/变量),但通信只能通过消息传递,不会有共享数据结构(计数器,队列)。
Akka vs Netty
Akka是一个建立在Actors概念和可组合Futures之上的并发框架,Akka设计灵感来源于Erlang,Erlang是基于Actor模型构建的。它通常被用来取代阻塞锁如同步、读写锁及类似的更高级别的异步抽象。
Netty是一个异步网络库,使JAVA NIO的功能更好用。
Akka针对IO操作有一个抽象,这和Netty类似。使用Akka可以用来部署计算集群,Actor在不同的机器之间传递消息。从这个角度来看,Akka相对于Netty来说,是一个更高层次的抽象。
Actor Model
What: Actor Model
每个Actor可认为一个EventLoop可简单理解为线程(实际可能多个Actor共享线程)。它有以下组件:
Actor EventLoop 的状态有:
研发会使用异步IO编程来实现具体的Actor。即,具体Actor关心的IO读写事件也会放入Actor自己的信箱。处于【处理事件中】的事件消费程序,不会有IO引起的Block等待。
How: Actor Model
Who: Actor Model
What: Akka
Akka支持可扩展的实时事务处理。我们相信编写出正确的、具有容错性和可扩展性的并发程序太困难了。这多数是因为使用了错误的工具和错误的抽象级别。Akka就是为了改变这种状况而生的。通过使用Actor模型提升了抽象级别,为构建可扩展的、有弹性的响应式并发应用提供了一个更好的平台,详见响应式宣言。在容错性方面Akka采用了“let it crash”(让它崩溃)模型,该模型已经在电信行业构建出“自愈合”的应用和永不停机的系统,取得了巨大成功。Actor还为透明的分布式系统以及真正的可扩展高容错应用的基础进行了抽象。
一个Actor是一个容器,它包含了状态,行为,一个邮箱,子Actor和一个监管策略。所有这些封装在一个Actor引用里。最终在Actor终止时,会有这些发生。
Actor使你能够进行服务失败管理(监控),负载管理(缓和策略、超时和处理隔离),以及水平和垂直方向上的可扩展性(增加cpu核数和/或增加更多的机器)管理。
Akka 实现了独特的混合模型
Actors
容错性
位置透明性
持久性
What: Vert.x
有人说它是java界的Node.js。但它自称性能上,多语言上超越Node.js。他是个异步框架,Web框架,有EventBus,支持Actor模式,支持微服务管理和发现等,听起来十分牛逼的样子。
Actor Arch
Actor 在 Vert.x 中叫 Verticle
EventBus
事件总线,支持事件广播、点到点发送、点对点发送与回复 EventBus
并发编程框架
异步IO编程框架
响应式编程
如果你认为OOP或好莱坞原则的异步Callback编程已经OUT了,或者已经被Callback Hell坑过。那么可以试试Reactive。Vert.x支持 RxJava
集群
跨JVM的集群EventBus,基于hazelcast来实现集群的发现和消费订阅的注册功能。Vert.x Cluster Manager
How: Vert.x Actor Model
Actor模式在Vert.x中是这样体现的:
What: Vert.x EventBus
Vert.x EventBus是个普通的无中心消息框架:
Vert.x EventBus是个打通到客户端的消息框架,是个All in one工具集。由于它包含一个 EventBus SockJS Bridge 模块,浏览器可以通过它提供的JS库,使用sockjs协议(Server-Sent Events/Websocket/HTTP poll)来接入EventBus。后端的事件可以实时通知到浏览器(提供event bus javascript库),实时推浏览器的广播变得相对容易实现。想想一个长后台任务完成,或监控事件触发时,一切都变得实时响应到用户端。浏览器也可以向后端发送异步指令和请求。EventBus Bridge
Resources
Related Posts
The text was updated successfully, but these errors were encountered: