引言 在Akka中, 一个Future是用来获取某个并发操作的结果的数据结构。这个操作一般是由Actor运行或由Dispatcher直接运行的. 这个结果能够以同步（堵塞）或异步（非堵塞）的方式訪问。 Future提供了一种简单的方式来运行并行算法。 Future直接使用 Future中的一个常见用 ...
分类：
其他好文 时间：
2018-03-30 12:17:56
阅读次数：
307
1、让列表中的每个元素都乘以2 print map(lambda x: x * 2, range(1,11)) 2、求列表中的所有元素之和 print sum(range(1,1001)) 3、判断一个字符串中是否存在某些词 wordlist = ["scala", "akka", "play fr ...
分类：
编程语言 时间：
2018-03-19 13:26:01
阅读次数：
216
Lagom是JAVA系下响应式 微服务框架，其特性包括： 目前，大多数已有的微服务框架关注于简化单个微服务的构建，Lagom将其扩展到了微服务所构成的系统，分布式系统的复杂性。 通信默认是异步的，基于消息（akka actor）和流(akka stream)——但是，如果需要的话，也可以考虑同步的R ...
分类：
其他好文 时间：
2018-02-12 13:35:45
阅读次数：
167
一个actorSystem 是一个重量级的结构。它会分配N个线程。所以对于每一个应用来说只用创建一个ActorSystem。 Actor是种可怜的“生物”，它们不能独自存活。Akka中的每一个Actor都是由一个Actor系统（Actor System）来创建和维护的。一个Actor系统会提供一整套 ...
分类：
其他好文 时间：
2018-02-07 14:44:01
阅读次数：
167
(引用 http://shiyanjun.cn/archives/1168.html) 一： 什么是Akka？ Akka是JAVA虚拟机JVM平台上构建高并发、分布式和容错应用的工具包和运行时,是一个框架。Akka用Scala语言写成，同时提供了Scala和JAVA的开发接口。 Akka处理并发的方 ...
分类：
其他好文 时间：
2018-02-07 12:04:57
阅读次数：
271
Orleans与Akka对比，为什么选用Orleans？ 答: Akka对参与开发的人员要求更高一些，普遍是专家级别，Orleans框架进一步抽象了一层，结合C#语言特性，能普遍降低开发难度。 下面是知乎网友的答案，可以参考： 原文地址：https://www.zhihu.com/question/ ...
分类：
其他好文 时间：
2018-01-28 12:50:10
阅读次数：
224
Akka实现WordCount(Scala): 架构图： 项目结构： pom.xml 消息： Actors： MasterActor MapActor： ReduceActor： AggregateActor： 主程序： 运行结果： (for,1)(name,1)(count,1)(is,2)(am ...
分类：
其他好文 时间：
2018-01-21 19:14:12
阅读次数：
191
再有两天就进入2018了,想想还是要准备一下明年的工作方向。回想当初开始学习函数式编程时的主要目的是想设计一套标准API給那些习惯了OOP方式开发商业应用软件的程序员们，使他们能用一种接近传统数据库软件编程的方式来实现多线程，并行运算，分布式的数据处理应用程序，前提是这种编程方式不需要对函数式编程语 ...
分类：
其他好文 时间：
2017-12-31 22:33:49
阅读次数：
235
akka集群是高容错、去中心化、不存在单点故障以及不存在单点瓶颈的集群。它使用gossip协议通信以及具备故障自动检测功能。 Gossip收敛 集群中每一个节点被其他节点监督(默认的最大数量为5)。集群中的节点互相监督着，某节点所监督的状态也正在被其他 ...
分类：
其他好文 时间：
2017-12-25 22:13:59
阅读次数：
292
Akka本身使用了 来序列化内部消息(比如gossip message)。Akka系统还可以配置自定义序列化机制。 配置conf 默认的，在local actor之间(the same JVM)的消息是不会序列化的。可以通过 配置，来序列化所有消息(local和remote)。序列化所有的消息不回给 ...
分类：
其他好文 时间：
2017-12-25 22:11:59
阅读次数：
125
