我开始学习
Akka Streams,这是一个使用反压功能处理数据的框架.该库是
Akka的一部分,它将自己描述为:
Akka is a toolkit and runtime for building highly concurrent,
distributed,and resilient message-driven applications on the JVM.
这些能力来自Akka演员的本质.但是,从我的角度来看,流处理和演员是彼此无关的概念.
题:
Akka Streams是否利用了Akka演员的这些功能?如果是的话,你会解释演员如何帮助流吗?
解决方法
Akka Streams是比演员更高层次的抽象.它是Reactive Streams的一个实现,它构建在actor模型之上.它利用了所有actor的功能,因为它使用了actor.
您甚至可以直接在流的任何部分使用actor.查看ActorPublisher和ActorSubscriber.