scala - Akka Streams 是否利用 Akka Actors？

Question

我开始学习Akka Streams ，这是一个具有背压功能的数据处理框架。该库是 Akka 的一部分将自己描述为:

Akka is a toolkit and runtime for building highly concurrent, distributed, and resilient message-driven applications on the JVM.

这些能力来自 Akka Actor 的本质。然而，从我的角度来看，流处理和参与者是彼此不相关的概念。

问题:Akka Streams 是否利用了 Akka Actor 的这些功能？如果是，您能解释一下 Actor 如何帮助直播吗？

Answer 1

Akka Streams 是比 actor 更高级别的抽象。它是构建在 Actor 模型之上的 Reactive Streams 的实现。它利用了所有 actor 功能，因为它使用了 actor。

您甚至可以返回直接在流的任何部分使用 actor。查看 ActorPublisher 和 ActorSubscriber。