阿卡接口_阿卡vs风暴

阿卡接口

我最近在Twitter的Storm上工作了一段时间，这让我想知道，它与另一个高性能的并发数据处理框架Akka相比如何。

什么是Akka和Storm？

让我们从两个系统的简短描述开始。 Storm是一种分布式实时计算系统。在Storm集群上，您执行拓扑，该拓扑处理元组（数据）流。每个拓扑都是一个由喷口（生成元组）和螺栓（转换元组）组成的图形。 Storm负责群集通信，群集之间的故障转移和拓扑分布。

Akka是用于构建分布式，并发，容错应用程序的工具包。在Akka应用程序中，基本构造是actor ； actor异步处理消息，并且保证每个actor实例一次最多使用一个线程运行，从而使并发变得更加容易。 Actor也可以远程部署。即将提供一个集群模块，该模块将处理集群节点上的参与者的自动故障转移和分配。两种系统都可以很好地扩展，并且可以处理大量数据。但是何时使用一个，何时使用另一个？

关于该主题还有另一篇不错的博客文章，但我想进一步进行比较：让我们看看Storm中的基本构造与Akka中的基本构造相比。

比较基础

首先，Storm中数据的基本单位是元组。一个元组可以有任意数量的元素，每个元组元素可以是任何对象，只要有一个序列化器即可。在Akka中，基本单位是message ，它可以是任何对象，但是它也应该可序列化（用于将其发送给远程参与者）。因此，这里的概念几乎是等效的。

让我们看一下基本的计算单位。在Storm中，我们有一些组成部分 ：螺栓和芽。螺栓可以是任何代码，它可以对传入的元组进行任意处理。它还可以存储一些可变数据，例如以累积结果。此外，螺栓在单个线程中运行，因此，除非您在螺栓中启动其他线程，否则不必担心并发访问螺栓数据。这与演员非常相似，不是吗？因此，暴风雨螺栓/萌芽对应于Akka演员。这两个如何详细比较？参与者可以接收任意消息；螺栓可以接收任意元组。预计两者都将根据接收到的数据进行一些处理。两者都具有内部状态，该状态是私有的，并且可以防止并发线程访问。

演员和螺栓：差异

一个关键的区别是角色和螺栓之间的通信方式。演员可以将消息发送给其他任何演员，只要它具有ActorRef （如果没有，则可以按名称查找演员）。它还可以将回复发送给正在处理的邮件的发件人。另一方面，暴风雨是单向的 。您无法发送回邮件；您也无法将消息发送到任意螺栓。您还可以将元组发送到命名通道（流），这将导致元组（消息）广播到拓扑中定义的所有侦听器。（螺栓还会向发短信确认消息，这也是通信的一种形式。）

在Storm中，可以并行运行螺栓/新芽代码的多个副本（取决于并行性设置 ）。因此，这对应于一组（可能是远程的）actor，在它们前面有一个负载均衡器actor 。在Akka的路线中众所周知的概念。关于元组如何路由到Storm中的螺栓实例（随机，字段上的一致性哈希），有两种选择，这大致对应于Akka中的各种路由器选项（轮询，消息上的一致性哈希）。

螺栓和演员的“重量”也有所不同。在Akka，通常会有很多演员 （多达数百万）。在Storm中，预期的螺栓数量要少得多；无论如何这都不是Storm的缺点，而是设计上的决定。同样，Akka角色通常共享线程 ，而每个螺栓实例都倾向于具有专用线程 。