使用Akka流
介绍 在Hootsuite,Play框架已成为我们基于Scala的微服务的重要组成部分。 但是,随着我们改进实践,我们开始在比Play框架更低的抽象水平上进行实验。 实际上,从2.5版开始,Play的流式API一直基于Akka Streams。 由于我们新的微服务框架内置了Akka依赖项,因此我们决定直接使用Akka Streams满足我们所有的流媒体需求。 什么是流媒体? “大数据”是一个时髦的词汇,在最近的记忆中已经泛滥成灾。 随着社交媒体和IoT等景观的增长,人们越来越重视实时响应大量数据。 为了实时分析数据,我们需要一种流传输此数据的方法。 因此,Reactive Streams接口诞生了。 Akka流是Reactive Streams接口的实现。 作为其核心,Reactive Streams接口旨在成为“为无阻塞背压的异步流处理提供标准的倡议。” Akka流式API的四个主要抽象是:…