[转自: http://blog.csdn.net/zjw10wei321/article/details/46911825] 容错 实际中的故障处理 容错案例图解 容错案例所有源码 创建新的监管策略 默认监管策略 停止监管策略 记录actor失败的消息 顶层角色的监管 应用测试 容错 正如角色系统 ...
分类:
编程语言 时间:
2016-11-15 16:42:44
阅读次数:
308
Akka提供的默认日志系统只输出到控制台,这种日志系统不可以用到产品环境,当然你可以整合SLF4J这样的日志系统,下面介绍如何在Akka中使用Logback记录日志。 1. 创建Maven工程引入相关依赖。 2. 添加akka配置文件,指定使用SLF4J日志系统。 3. 创建Logback.xml配 ...
分类:
其他好文 时间:
2016-09-30 12:06:15
阅读次数:
200
pom.xml 可能遇到的问题: java.lang.NoClassDefFoundError: scala/collection/GenTraversableOnce$class 用的akka包跟依赖的scala包版本不一致导致(貌似scala不向下兼容它的旧版本),笔者一开始用的2.11.7报错 ...
分类:
其他好文 时间:
2016-09-12 18:56:48
阅读次数:
238
Akka v2.4-ARTERY-M4 发布了。Akka 是一个用 Scala 编写的库,用于简化编写容错的、高可伸缩性的 Java 和 Scala 的 Actor 模型应用。暂未发现该版本更新内容,点击下面链接保持关注更新: http://akka.io/news/ https://github. ...
分类:
其他好文 时间:
2016-09-11 12:41:24
阅读次数:
115
Akka 是一个用 Scala 编写的库,用于简化编写容错的、高可伸缩性的 Java 和 Scala 的 Actor 模型应用。它已经成功运用在电信行业。系统几乎不会宕机(高可用性 99.9999999 % 一年只有 31 ms 宕机)。 Actor模型并非什么新鲜事物,它由Carl Hewitt于 ...
分类:
其他好文 时间:
2016-08-24 12:31:02
阅读次数:
146
Actor UntypedActor actor的基类,继承并实现onReceive方法就可以得到一个Actor。 Props 配置类,用Props.create可以创建一个按指定配置生成的Actor。 Props的推荐实践,创建Actor时,搞一个static的Props.create方法。可以少 ...
分类:
其他好文 时间:
2016-08-12 13:32:42
阅读次数:
209
Akka.NET 1.1的主要目标是将Akka.Cluster由Beta测试版程序包变成最终版(RTM)程序包。该版本还提供了测试工具,对在生产环境里运行Akka.NET集群的过程中可能出现的大量各种不同的网络场景进行了测试。 ...
分类:
Web程序 时间:
2016-07-30 13:40:12
阅读次数:
168
因为最近工作的关系,要把异步任务从应用服务器中拆分到专门的异步处理服务器中.方案一是采用MQ的方式将任务消息发出,在服务端进行处理,如下图所示:
这种方案是采用MQ作为中间的媒介,在服务端采用线程池异步处理任务,处理完成之后将结果发送到MQ中,客户端采用侦听的方式得到结果继续进行处理。
这种方案的不足是,可能在某些需求的情况下,需要将结果存放到共享的HashMap或者Threadlocal...
分类:
其他好文 时间:
2016-07-29 15:38:54
阅读次数:
155
大数据科学丛书系列的最新一本《Scala语言基础与开发实战》即将面市,预计月底上架。内容还是不错的,文笔简介,内容实用,值得学、用。大数据资深培训师王家林新作。详细介绍大数据开发语言Scala及其在分布式框架Akka和Kafka中的应用。秉承“实战”类图书特点,解析大量代码的..
分类:
编程语言 时间:
2016-07-07 17:41:26
阅读次数:
280
输入DStreams表示从数据源获取的原始数据流。Spark Streaming拥有两类数据源
(1)基本源(Basic sources):这些源在StreamingContext API中直接可用。例如文件系统、套接字连接、
Akka的actor等。
(2)高级源(Advanced sources):这些源包括Kafka,Flume,Kinesis,Twitter等等。
1、基本数据...
分类:
其他好文 时间:
2016-07-06 10:24:06
阅读次数:
863