在现实应用中akka-stream往往需要集成其它的外部系统形成完整的应用。这些外部系统可能是akka系列系统或者其它类型的系统。所以，akka-stream必须提供一些函数和方法来实现与各种不同类型系统的信息交换。在这篇讨论里我们就介绍几种通用的信息交换方法和函数。 akka-stream提供了m ...
分类：
其他好文 时间：
2017-09-19 15:11:01
阅读次数：
236
在数据流应用的现实场景中常常会遇到与外界系统对接的需求。这些外部系统可能是Actor系统又或者是一些其它类型的系统。与这些外界系统对接的意思是在另一个线程中运行的数据流可以接收外部系统推送的事件及做出行为改变的响应。 如果一个外界系统需要控制一个运行中数据流的功能环节GraphStage，首先必须在 ...
分类：
其他好文 时间：
2017-09-12 17:48:21
阅读次数：
208
从总体上看：akka-stream是由数据源头Source，流通节点Flow和数据流终点Sink三个框架性的流构件（stream components）组成的。这其中：Source和Sink是stream的两个独立端点，而Flow处于stream Source和Sink中间可能由多个通道式的节点组成 ...
分类：
其他好文 时间：
2017-09-09 13:08:18
阅读次数：
249
maven shade plugin插件小用 项目中一直使用assembly插件来整合依赖包到一个胖jar,在做这个akka http项目的时候,在scala ide的run/debug中都执行正常,打包后执行就一直报报不到configuration项目的问题. 判断是assembly在解压合并相关 ...
分类：
其他好文 时间：
2017-09-08 15:31:13
阅读次数：
184
官方文档: http://developer.lightbend.com/guides/akka-quickstart-java/?_ga=2.177525157.1012573474.1504767665-546319647.1504766934 一. AKKA Hello World examp ...
分类：
编程语言 时间：
2017-09-07 19:34:52
阅读次数：
221
在现实中我们会经常遇到这样的场景：有一个固定的数据源Source，我们希望按照程序运行状态来接驳任意数量的下游接收方subscriber、又或者我需要在程序运行时（runtime）把多个数据流向某个固定的数据流终端Sink推送。这就涉及到动态连接合并型Merge或扩散型Broadcast的数据流连接 ...
分类：
其他好文 时间：
2017-08-31 11:09:32
阅读次数：
225
akka-stream是多线程non-blocking模式的，一般来说，运算任务提交到另外线程后这个线程就会在当前程序控制之外自由运行了。任何时候如果需要终止运行中的数据流就必须采用一种任务柄（handler）方式来控制在其它线程内运行的任务。这个handler可以在提交运算任务时获取。akka-s ...
分类：
其他好文 时间：
2017-08-30 09:57:20
阅读次数：
191
一、会话的概念 会话可简单理解为：用户开一个浏览器，点击多个超链接，访问服务器多个web资源，然后关闭浏览器，整个过程称之为一个会话。 有状态会话：一个同学来过教室，下次再来教室，我们会知道这个同学曾经来过，这称之为有状态会话。 二、会话过程中要解决的一些问题？ 每个用户在使用浏览器与服务器进行会话 ...
分类：
其他好文 时间：
2017-08-29 12:35:18
阅读次数：
282
在使用一些开源框架的时候（比如spark、hadoop、lucene等），偶尔会见到说找不到某个具体实现类或者某个配置（比如spark的akka配置）不见了。 部分例子如下： 【Lucene】An SPI class of type org.apache.lucene.codecs.Postings ...
分类：
其他好文 时间：
2017-08-24 14:57:59
阅读次数：
260
akka-stream的数据流可以由一些组件组合而成。这些组件统称数据流图Graph，它描述了数据流向和处理环节。Source,Flow,Sink是最基础的Graph。用基础Graph又可以组合更复杂的复合Graph。如果一个Graph的所有端口（输入、输出）都是连接的话就是一个闭合流图Runnab ...
分类：
其他好文 时间：
2017-08-21 14:00:31
阅读次数：
238
