Akka Streams 介绍 第一个示例 Source、Flow、Sink Graph Shape RunnableGraph 深入 Source Source SourceShape Source 怎么生产数据? FileSource 实例讲解 createLogicAndMaterializedValue GraphStageLogic 详解 小结 物化与物化值 Materializer(物化器) Materialized value(物化值) Keep 深入 Flow 深入 Sink 创建 Source 的常用函数 fromPublisher asSubscriber fromIterator cycle fromGraph apply queue 执行转换的 Flow 常用函数 汇聚数据的 Sink 常用函数 Streams 分组 grouped groupedWithin 基于时间的处理 访问文件 FileIO.toPath 写数据到文件 FileIO.fromPath 从文件读数据 访问FTP/sFTP 自定义图(Graph) 实例:使用 Akka Streams 解 Top K 问题 问题描述 解法1:全量排序求Top 10 解法2:遍历一次文件求出Top 10 解法3:使用Akka Streams异步求出Top K个得分最高的电影 自定义Sink:TopKSink 解法4:通过 Akka HTTP 在下载文件的同时求出Top K个得分最高的电影 小结