为什么使用akka
akka是Actor模型的实现。Actors为我们提供了以下优点:
1)对并发/并行程序的简单的、高级别的抽象。
2)异步、非阻塞、高性能的事件驱动编程模型。
3)非常轻量的事件驱动处理。
akka提供了容错性
使用“let-it-crash”语义和监管者树形结构来实现容错。非常适合编写永不停机、自愈合的高容错系统。监管者树形结构可以跨...
分类:
其他好文 时间:
2015-05-17 21:57:09
阅读次数:
163
该话题涉及几个概念:
处理器、信道、事件源、日志、状态。
消息可以持久化,通常当前的状态保存在内存中(内存镜像),而事件源机制可以通过重播接收到的消息(在应用程序正常启动或崩溃后)恢复当前(或历史)的状态。
Eventsourced 实现了预写日志(write-ahead log ,WAL)用于跟踪一个Actor 所接收消息,并通过回放记录的消息来恢复其状态。
处理...
分类:
其他好文 时间:
2015-05-17 21:56:23
阅读次数:
151
程序演示了父子结构的Actor处理消息。父Actor接收到消息后调用子Actor处理。
1.创建父子Actor
import java.util.UUID;
import com.center.akka.simple.command.Command;
import com.center.akka.simple.event.Event;
import akka.actor.ActorRef;...
分类:
其他好文 时间:
2015-05-17 21:56:16
阅读次数:
213
程序的演示场景是:处理器发送命令,接收者接收到消息后进行处理并且对发送方发送消息确认表明已经成功收到消息。如果没有发送确认则表明该消息没有被接收并正确处理。失败消息会到达死信箱,系统下次启动时后继续发送死信箱中的发送失败的消息。
1.创建信道回复命令对象
import com.center.akka.simple.command.Command;
public class Channel...
分类:
其他好文 时间:
2015-05-17 21:56:12
阅读次数:
126
以下程序演示了akka的一个简单的示例。创建Actor去处理一条命令,通过消息传递的方式进行交互。
我使用的akka版本和相关jar包参见pom文件:
<project xmlns= "http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schema...
分类:
其他好文 时间:
2015-05-17 21:54:57
阅读次数:
113
AkkaAkka是什么呢?直接引用Akka站点上面的描写叙述吧:Akka is a toolkit and runtime for building highly concurrent, distributed, and fault tolerant event-driven application...
分类:
其他好文 时间:
2015-05-13 18:29:26
阅读次数:
106
Quick Start Guide: Reactive Tweets快速入门指南: Reactive Tweets(reactive tweets 大概可以理解为“响应式推文”,在此可以测试下GFW是否还在正常工作 Twitter)A typical use case for stream proc...
分类:
其他好文 时间:
2015-04-26 19:44:02
阅读次数:
312
本想通过了解一下Akka-actor工程中主要的类的概念,来看下Akka内部运作的机制。无奈里边的类的确太多,注释中对每个类的功能也没有足够的解释。所以还是通过debug的方式,找个入手点,看一下互相之间调用的关系。最初的选择是看一下ActorSystem的实始化过程,但发现难度挺大,因为这个初始化...
分类:
其他好文 时间:
2015-04-19 00:56:51
阅读次数:
280
假如我要设一个像Akka一样的actor框架,该怎么设计呢?猜猜看,看有哪些问题需要考虑。对于actor模型来说,最重要的就是actor。如果把每个actor构造成一个线程,会简单得多,但是线程的数目必须很少,而actor的数目很多,因此对于一个通用的actor框架,不可能每个actor分配一个线程...
分类:
其他好文 时间:
2015-04-18 23:27:51
阅读次数:
148
想搞下Akka HTTP,用于用于我们的开源项目football,发现Akka HTTP的例子里大量用到Akka Stream,而且Akka HTTP是构建Akka Stream之上的。所以还是先看下Akka Stream吧,先了解下这个Akka Stream这个项目的动机。动机Motivation...
分类:
其他好文 时间:
2015-04-13 12:39:54
阅读次数:
141