摘要: akka-stream是基于Actor模式的,所以也继承了Actor模式的“坚韧性(resilient)”特点,在任何异常情况下都有某种整体统一的异常处理策略和具体实施方式。在akka-stream的官方文件中都有详细的说明和示范例子。我们在这篇讨论里也没有什么更好的想法和范例,也只能略做一些字面翻阅读全文
posted @ 2017-09-21 16:47 雪川大虫 阅读(47) 评论(1) 编辑
摘要: 在现实应用中akka-stream往往需要集成其它的外部系统形成完整的应用。这些外部系统可能是akka系列系统或者其它类型的系统。所以,akka-stream必须提供一些函数和方法来实现与各种不同类型系统的信息交换。在这篇讨论里我们就介绍几种通用的信息交换方法和函数。 akka-stream提供了m阅读全文
posted @ 2017-09-19 11:28 雪川大虫 阅读(94) 评论(1) 编辑
摘要: 在数据流应用的现实场景中常常会遇到与外界系统对接的需求。这些外部系统可能是Actor系统又或者是一些其它类型的系统。与这些外界系统对接的意思是在另一个线程中运行的数据流可以接收外部系统推送的事件及做出行为改变的响应。 如果一个外界系统需要控制一个运行中数据流的功能环节GraphStage,首先必须在阅读全文
posted @ 2017-09-12 16:52 雪川大虫 阅读(102) 评论(0) 编辑
摘要: 从总体上看:akka-stream是由数据源头Source,流通节点Flow和数据流终点Sink三个框架性的流构件(stream components)组成的。这其中:Source和Sink是stream的两个独立端点,而Flow处于stream Source和Sink中间可能由多个通道式的节点组成阅读全文
posted @ 2017-09-09 11:39 雪川大虫 阅读(90) 评论(1) 编辑
摘要: 在现实中我们会经常遇到这样的场景:有一个固定的数据源Source,我们希望按照程序运行状态来接驳任意数量的下游接收方subscriber、又或者我需要在程序运行时(runtime)把多个数据流向某个固定的数据流终端Sink推送。这就涉及到动态连接合并型Merge或扩散型Broadcast的数据流连接阅读全文
posted @ 2017-08-31 09:53 雪川大虫 阅读(177) 评论(0) 编辑
摘要: akka-stream是多线程non-blocking模式的,一般来说,运算任务提交到另外线程后这个线程就会在当前程序控制之外自由运行了。任何时候如果需要终止运行中的数据流就必须采用一种任务柄(handler)方式来控制在其它线程内运行的任务。这个handler可以在提交运算任务时获取。akka-s阅读全文
posted @ 2017-08-30 08:24 雪川大虫 阅读(115) 评论(0) 编辑
摘要: akka-stream原则上是一种推式(push-model)的数据流。push-model和pull-model的区别在于它们解决问题倾向性:push模式面向高效的数据流下游(fast-downstream-subscriber),pull model倾向高效的上游(fast-upstream-p阅读全文
posted @ 2017-08-28 17:02 雪川大虫 阅读(160) 评论(0) 编辑
摘要: akka-stream的Graph是一种运算方案,它可能代表某种简单的线性数据流图如:Source/Flow/Sink,也可能是由更基础的流图组合而成相对复杂点的某种复合流图,而这个复合流图本身又可以被当作组件来组合更大的Graph。因为Graph只是对数据流运算的描述,所以它是可以被重复利用的。所阅读全文
posted @ 2017-08-24 10:13 雪川大虫 阅读(111) 评论(0) 编辑
摘要: akka-stream的数据流可以由一些组件组合而成。这些组件统称数据流图Graph,它描述了数据流向和处理环节。Source,Flow,Sink是最基础的Graph。用基础Graph又可以组合更复杂的复合Graph。如果一个Graph的所有端口(输入、输出)都是连接的话就是一个闭合流图Runnab阅读全文
posted @ 2017-08-21 13:47 雪川大虫 阅读(169) 评论(0) 编辑
摘要: 在大数据程序流行的今天,许多程序都面临着共同的难题:程序输入数据趋于无限大,抵达时间又不确定。一般的解决方法是采用回调函数(callback-function)来实现的,但这样的解决方案很容易造成“回调地狱(callback hell)”,即所谓的“goto-hell”:程序控制跳来跳去很难跟踪,特阅读全文
posted @ 2017-08-15 13:18 雪川大虫 阅读(212) 评论(0) 编辑