4 生产者与消费者之间的调解 下一个示例将涉及将事件广播到消费服务。到目前为止，我们已经将日志事件写入磁盘——一个含有所有事件的日志文件，以及警...

3 使用Graph DSL实现扇入扇出 到目前为止，我们只研究了一个输入和一个输出的线性处理。Akka-stream提供了用于描述扇入和扇出的图...

1 基本流处理 让我们首先看看使用akka-stream处理流的真正含义。图1展示了在某个处理节点上，元素是一个个如何被处理的。一次处理一个元素...