对于 A => B => C 这种 future 之间的操作,akka 默认会自动的按照顺序执行,但对于数据库操作来说,我们希望几个操作顺序执行,就需要使用语法来声明有两种声明 future 先后关系的方法,第一种是 flatMap,第二种是 forimport scala.concurrent.F...
分类:
其他好文 时间:
2015-04-12 19:10:59
阅读次数:
139
关于什么是Akka本文就不再细说了,可见以下文章:
分布式应用框架Akka快速入门
Storm Akka Finagle对比及使用场景分析
Akka 对比 Storm
本文采用一个“Ping-Pong”(打乒乓球)的Demo进行尝试:
1.首先要定义两个Actor, 相互打。
2.然后要定义流程:初始化,一方发球,然后相互打回合。
3.还需要定义每个消息的结构。...
分类:
其他好文 时间:
2015-04-08 13:16:54
阅读次数:
134
spray 是基于 akka 的轻量级 scala 库,可用于编写 REST API 服务。了解 spray 的 DSL 后可以在很短的时间内写出一个 REST API 服务,它的部署并不需要 tomcat , apche 等容器,可以直接 run。对于每一个 route, spray 都会 spr...
分类:
其他好文 时间:
2015-04-04 12:03:27
阅读次数:
311
Akka 是一个用 Scala 编写的库,用于简化编写容错的、高可伸缩性的 Java 和 Scala 的 Actor 模型应用。它已经成功运用在电信行业。系统几乎不会宕机(高可用性 99.9999999 % 一年只有 31 ms 宕机。
用akka计算pi,计算公式:
这样,我们把这个公式每连续的elements个分成一段,一共分成message段。
然后开worker个acto...
分类:
其他好文 时间:
2015-03-12 22:37:59
阅读次数:
194
Akka 快速入门
Akka的优点太多,高性能、高可靠、高并发、分布式、可容错、可扩展、事件驱动,不一一叙述。不同版本的API差异很大,本文代码运行在 Scala 2.10.3 和 Akka
2.3.2 之上。
dependency>
groupId>com.typesafe.akkagroupId>
artifactId>akka-actor_2.10artifactId...
分类:
其他好文 时间:
2015-03-11 17:17:27
阅读次数:
192
接着上一篇的?tree路径匹配抽象(1),我们开始看如何对tree进行索引,akka的路径匹配包含了远程节点的匹配,这样就得引入多个通信机制(akka采用消息),为了简化,我们先假设只在一个本地tree中进行索引: obj...
分类:
其他好文 时间:
2015-03-02 13:22:55
阅读次数:
134
[c实现的队列](http://www.1024cores.net/home/lock-free-algorithms/queues/non-intrusive-mpsc-node-based-queue) 下面是akka实现的一个MPSC队列。 PS: 代码中注释对链头链尾判定的标准是添加的元素所在的位置...
分类:
其他好文 时间:
2015-03-02 11:28:32
阅读次数:
338
if invoked from an instance that isnotan Actor the sender will bedeadLettersactor reference by default.在akka中使用ask模式可设置超时时间,因为ask模式需等待对方的回应implicit va...
分类:
其他好文 时间:
2015-02-25 18:22:53
阅读次数:
123
Orleans是微软推出的类似Scala Akka的Actor模型,Orleans是一个建立在.NET之上的,设计的目标是为了方便程序员开发需要大规模扩展的云服务, 可用于实现DDD+EventSourcing/CQRS系统。 传统的三层体系结构包括无状态的前端,无状态的中间层和存储层在可伸缩性方面...
分类:
Web程序 时间:
2015-02-17 23:34:49
阅读次数:
226
Cluster讲课的这哥们接下来讲了下Akka Cluster的使用,但是是通过把一个以前讲过的actor 系统改成使用cluster来介绍的Akka cluster. 这部分代码很多,还是直接看视频吧。或者,看这篇文章,Akka Clustering, Step by Step更直白一些,不用事先...
分类:
其他好文 时间:
2015-02-07 11:32:03
阅读次数:
150