Akka Streams: Using TCP

引子

准确来说，IO API 不算是 Akka Streams的内容，但它却是 Streaming IO (TCP) 的基础。

IO API 编程的第一步，是获取一个管理对象的引用。比如我们想针对TCP编程，可以这么获取 TCP Manager：
[crayon-6767730c6ee8d[……]

Akka Streams: Integrating with Actors

引子

Akka Streams 为异步编程提供了管道和流式接口，但如果我们希望结合 actor 模型的消息机制呢？Akka Streams提供了如下解决方案：

Sink.actorRef 产生 ActorRef，做为下游结点接收管道里的流数据
Source.actorRef 产生A[……]

Akka Streams: GraphStage

Stages

Stage 是 Akka Streams 里的核心概念，它代表了在Graph里的单位，是如何定义输入端口（Inlet) / 输出端口(Outlet) 的；常用的基础形态有：

compose_shapes1

Source: 只有一个Outlet
Sink: 只有一个Inlet
Flow:[……]