引子
准确来说,IO API 不算是 Akka Streams的内容,但它却是 Streaming IO (TCP) 的基础。
IO API 编程的第一步,是获取一个管理对象的引用。比如我们想针对TCP编程,可以这么获取 TCP Manager:
[crayon-67516bace3378[……]
准确来说,IO API 不算是 Akka Streams的内容,但它却是 Streaming IO (TCP) 的基础。
IO API 编程的第一步,是获取一个管理对象的引用。比如我们想针对TCP编程,可以这么获取 TCP Manager:
[crayon-67516bace3378[……]
Akka Streams 为异步编程提供了管道和流式接口,但如果我们希望结合 actor 模型的消息机制呢?Akka Streams提供了如下解决方案:
Sink.actorRef
产生 ActorRef,做为下游结点接收管道里的流数据Source.actorRef
产生A[……]Stage 是 Akka Streams 里的核心概念,它代表了在Graph里的单位,是如何定义输入端口(Inlet) / 输出端口(Outlet) 的;常用的基础形态有: